RabbitMQ简单队列模式

Bertha 。 2022-05-16 04:38 267阅读 0赞

### 简单队列模式 ###

红色：队列  
P：消息的生产者  
C：消息的消费者  
![这里写图片描述][70]  
生产者，将消息发送到队列  
消费者，从队列中获取消息

### 配置依赖 ###

导入RabbitMQ客户端依赖

<dependency>
        <groupId>com.rabbitmq</groupId>
        <artifactId>amqp-client</artifactId>
        <version>3.4.1</version>
    </dependency>

### ConnectionUtil ###

获取连接

package cn.itcast.rabbitmq.util;
    
    import com.rabbitmq.client.ConnectionFactory;
    import com.rabbitmq.client.Connection;
    
    public class ConnectionUtil { 
    
        public static Connection getConnection() throws Exception {
            // 定义连接工厂
            ConnectionFactory factory = new ConnectionFactory();
            // 设置服务地址
            factory.setHost("localhost");
            // 端口
            factory.setPort(5672);
            // 设置账号信息，用户名、密码、vhost
            factory.setVirtualHost("/taotao");
            factory.setUsername("taotao");
            factory.setPassword("taotao");
            // 通过工程获取连接
            Connection connection = factory.newConnection();
            return connection;
        }
    
    }

### Send ###

发送者

package cn.itcast.rabbitmq.simple;
    
    import cn.itcast.rabbitmq.util.ConnectionUtil;
    
    import com.rabbitmq.client.Channel;
    import com.rabbitmq.client.Connection;
    
    public class Send { 
    
        private final static String QUEUE_NAME = "test_queue";
    
        public static void main(String[] argv) throws Exception {
            // 获取到连接以及mq通道
            Connection connection = ConnectionUtil.getConnection();
            // 从连接中创建通道
            Channel channel = connection.createChannel();
    
            // 声明（创建）队列
            channel.queueDeclare(QUEUE_NAME, false, false, false, null);
    
            // 消息内容
            String message = "Hello World!";
            channel.basicPublish("", QUEUE_NAME, null, message.getBytes());
            System.out.println(" [x] Sent '" + message + "'");
    
            //关闭通道和连接
            channel.close();
            connection.close();
        }
    }

### Recv ###

接收者

package cn.itcast.rabbitmq.simple;
    
    import cn.itcast.rabbitmq.util.ConnectionUtil;
    
    import com.rabbitmq.client.Channel;
    import com.rabbitmq.client.Connection;
    import com.rabbitmq.client.QueueingConsumer;
    
    public class Recv { 
    
        private final static String QUEUE_NAME = "test_queue";
    
        public static void main(String[] argv) throws Exception {
    
            // 获取到连接以及mq通道
            Connection connection = ConnectionUtil.getConnection();
            Channel channel = connection.createChannel();
    
            // 声明队列
            channel.queueDeclare(QUEUE_NAME, false, false, false, null);
    
            // 定义队列的消费者
            QueueingConsumer consumer = new QueueingConsumer(channel);
            // 监听队列
            channel.basicConsume(QUEUE_NAME, true, consumer);
    
            // 获取消息
            while (true) {
                QueueingConsumer.Delivery delivery = consumer.nextDelivery();
                String message = new String(delivery.getBody());
                System.out.println(" [x] Received '" + message + "'");
            }
        }
    }

### 发送消息 ###

查看队列消息  
可以设置，更新频率  
![这里写图片描述][70 1]  
查看队列详情  
![这里写图片描述][70 2]  
查看队列消息  
![这里写图片描述][70 3]

### 消费者 ###

声明队列  
因为，消费者不知道这个队列是否存在

如果，队列不存在，创建队列  
如果，队列存在，会忽略声明队列语句  
![这里写图片描述][70 4]  
接收之后

查看队列消息，消息为0  
![这里写图片描述][70 5]  
被接收之后，消息就没有了  
消费者，处于监听状态

再次，发送一条消息  
消费者，会马上接收到消息  
![这里写图片描述][70 6]

[70]: /images/20220516/9eb4327279954765a83198ee89fe9879.png
[70 1]: /images/20220516/8b40ec06d28b48ea90c70ee49b52a56a.png
[70 2]: /images/20220516/b2c1b9fb728a4977b58b84c1dfcf09ab.png
[70 3]: /images/20220516/e2748309de6a4344a4d28a20e63287f4.png
[70 4]: /images/20220516/18deb239349c489699470e5da07c62c2.png
[70 5]: /images/20220516/fad52a22e4a348f2a0050e6f6e14a444.png
[70 6]: /images/20220516/11939ddba3964614aa4c97d598892aeb.png