RabbitMQ学习笔记之快速入门

灰太狼 2024-03-31 14:54 89阅读 0赞

**目录**

创建一个maven项目

2.1. 依赖

2.2. 消息生产者

2.3. 消息消费者

--------------------

将用 Java 编写两个程序。发送单个消息的生产者和接收消息并打印

出来的消费者,介绍 Java API 中的一些细节。

在下图中，“ P”是我们的生产者，“ C”是我们的消费者。中间的框是一个队列-RabbitMQ 代

表使用者保留的消息缓冲区

![79a206408c7436c9c669f000297eef66.png][]

## 创建一个maven项目 ##

### **2.1.** **依赖** ###

<build>
        <plugins>
          <plugin>
            <groupId>org.apache.maven.plugins</groupId>
            <artifactId>maven-compiler-plugin</artifactId>
            <configuration>
              <source>8</source>
              <target>8</target>
            </configuration>
          </plugin>
        </plugins>
      </build>
    
      <dependencies>
        <dependency>
          <groupId>com.rabbitmq</groupId>
          <artifactId>amqp-client</artifactId>
          <version>5.8.0</version>
        </dependency>
    
        <dependency>
          <groupId>commons-io</groupId>
          <artifactId>commons-io</artifactId>
          <version>2.6</version>
        </dependency>
      </dependencies>

### **2.2.** **消息生产者** ###

public class Producer {
        // 队列名称
        public static  final String QUEUE_NAME="hello";
    
        // 发消息
        public static void main(String[] args) throws IOException, TimeoutException {
            // 创建一个连接工厂
            ConnectionFactory factory = new ConnectionFactory();
    
            // 工厂IP连接RabbitMQ的队列
            factory.setHost("服务器ip");
            // 用户名
            factory.setUsername("admin");
            // 密码
            factory.setPassword("123456");
    
            factory.setPort(5672);
    
            // 创建连接
            Connection connection = factory.newConnection();
            // 获取信道
            Channel channel = connection.createChannel();
            /*
             * 生成一个队列
             * 参数1：队列名称
             * 参数2：队列里面的消息是否持久化，默认情况下，消息存储在内存中
             * 参数3：该队列是否只供一个消费者进行消费，是否进行消费共享，true可以多个消费者消费，
             *        false只能一个消费者消费
             * 参数4：是否自动删除：最后一个消费者断开连接之后，该队列是否自动删除，true则自动删除，
             *        false不自动删除
             * 参数5：其他参数
             * */
            channel.queueDeclare(QUEUE_NAME,false,false,false,null);
            // 发消息
            String message = "hello world";
            /*
             * 发送一个消息
             * 参数1：发送到哪个交换机
             * 参数2：路由的key值是那个，本次是队列的名称
             * 参数3：其他参数信息
             * 参数4：发送消息的消息体
             * */
            channel.basicPublish("",QUEUE_NAME,null,message.getBytes(StandardCharsets.UTF_8));
            System.out.println("消息发送完毕！");
    
        }
    }

运行结果:

![5b36aea435c20fe3b08cdd1be5604372.png][]

### **2.3.** **消息消费者** ###

/**
     * @author xingchen
     * @version V1.0
     * @Package com.xingchen.mq
     * @date 2022/12/4 15:37
     */
    public class Consumer {
        // 队列名称
        public static final String QUEUE_NAME = "hello";
    
        // 接受消息
        public static void main(String[] args) throws IOException, TimeoutException {
            // 创建连接工厂
            ConnectionFactory factory = new ConnectionFactory();
    
            factory.setHost("110.40.211.224");
            factory.setUsername("admin");
            factory.setPassword("123456");
            Connection connection = factory.newConnection();
            Channel channel = connection.createChannel();
    
            // 声明 接受消息
            DeliverCallback deliverCallback = (consumerTag, message) -> {
                System.out.println(new String(message.getBody()));
            };
    
            // 声明 取消消息
            CancelCallback cancelCallback = consumer -> {
                System.out.println("消息消费被中断");
            };
    
            /*
             * 消费者接收消息
             * 参数1：表示消费哪个UI列
             * 参数2：消费成功之后，是否需要自动应答，true表示自动应答，false表示手动应答
             * 参数3：消费者成功消费的回调
             * 参数4：消费者取消消费的回调
             */
            channel.basicConsume(QUEUE_NAME,true,deliverCallback,cancelCallback);
        }
    }

运行结果

![e8365aac778bada823100eb10ff1ddc6.png][]

[79a206408c7436c9c669f000297eef66.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/31/5118d88e38984a2fbbc6f8f5ebf2fd23.png
[5b36aea435c20fe3b08cdd1be5604372.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/31/4a178ec439c14509b42dd3a3b3bed66b.png
[e8365aac778bada823100eb10ff1ddc6.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/31/94c1cd8ca00447f68566e4d599dc439a.png