《RabbitMQ系列教程-第四章-02-RabbitMQ工作模式之Work模式》

逃离我推掉我的手 2023-01-02 03:21 173阅读 0赞

# 教程说明 #

*  本系列教程目录大纲：[《RabbitMQ系列教程-目录大纲》][RabbitMQ_-]

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

*  本系列教程配套代码：[https://gitee.com/lvshuichangliu/rabbitmt.git][https_gitee.com_lvshuichangliu_rabbitmt.git]（码云地址）

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

# RabbitMQ工作模式之Work模式 #

### 4.2.1 简介 ###

Work模式与Simple模式几乎是一模一样的，只不过我们在只有一个Producer和一个Consumer时习惯把这种模式成为Simple模式，而当一个Producer有多个Consumer时我们把这样的模式成为Work模式，因此Work模式和Simple模式的代码是一模一样的，只不过是多个Consumer监听同一个队列而已；

![在这里插入图片描述][20210104153756921.png_pic_center]

> Work模式官网介绍：https://www.rabbitmq.com/tutorials/tutorial-two-java.html

### 4.2.2 生产者 ###

package com.lscl.rabbitmq;
    
    import com.rabbitmq.client.Channel;
    import com.rabbitmq.client.Connection;
    import com.rabbitmq.client.ConnectionFactory;
    
    public class Producer02_WorkQueues { 
    
        public static void main(String[] args) throws Exception { 
            // 创建连接工厂,用于获取频道channel
            ConnectionFactory factory = new ConnectionFactory();
    
            factory.setHost("192.168.40.132");
            factory.setPort(5672);
            factory.setUsername("lscl");
            factory.setPassword("admin");
            factory.setVirtualHost("/lscl");
    
            // 2.创建连接
            Connection connection = factory.newConnection();
    
            // 3.创建频道
            Channel channel = connection.createChannel();
    
            // 4.创建队列
            channel.queueDeclare("work_queues", true, false, false, null);
    
            //5. 循环发送10条消息到work_queues队列
            for (int i = 1; i <= 10; i++) { 
                String body = "hello" + i;
                channel.basicPublish("", "work_queues", null, body.getBytes());
            }
    
            //6.释放资源
            channel.close();
            connection.close();
        }
    }

### 4.2.3 消费者1 ###

package com.lscl.rabbitmq;
    
    import com.rabbitmq.client.*;
    import java.io.IOException;
    
    public class Consumer02_WorkQueues { 
    
        public static void main(String[] args) throws Exception{ 
            // 创建连接工厂,用于获取频道channel
            ConnectionFactory factory=new ConnectionFactory();
    
            factory.setHost("192.168.40.132");
            factory.setPort(5672);
            factory.setUsername("lscl");
            factory.setPassword("admin");
            factory.setVirtualHost("/lscl");
    
            // 2.创建连接
            Connection connection = factory.newConnection();
    
            // 3.创建频道
            Channel channel = connection.createChannel();
    
            // 4.创建队列
            channel.queueDeclare("work_queues",true,false,false,null);
    
            // 5. 接收消息
            channel.basicConsume("work_queues", true, new DefaultConsumer(channel){ 
    
                // 回调方法,当收到消息之后,会自动执行该方法
                public void handleDelivery(String consumerTag, Envelope envelope, AMQP.BasicProperties properties, byte[] body) throws IOException { 
    
                    System.out.println("body："+new String(body));
                }
            });
            // 不释放资源,让rabbitmq一直监听
        }
    }

### 4.2.4 消费者2 ###

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L0JiMTUwNzAwNDc3NDg_size_16_color_FFFFFF_t_70_pic_center]

运行后在控制台可以看到多个窗口

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L0JiMTUwNzAwNDc3NDg_size_16_color_FFFFFF_t_70_pic_center 1]

### 4.2.5 rabbitmq负载均衡 ###

当rabbitmq存在有多个Consumer时，会自动采用轮询方式实现消息的负载均衡，将消息分担到不同的Consumer进行消费  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L0JiMTUwNzAwNDc3NDg_size_16_color_FFFFFF_t_70_pic_center 2]

### 4.2.6 Work模式小结 ###

Work模式与上一节所学的Simple模式在代码上看来是一模一样的，只不过RabbitMQ官方为了区别一个消费者和多个消费者监听同一个队列提出了Simple和Work不同的两种模式；

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

下一篇：[《RabbitMQ系列教程-第四章-03-RabbitMQ工作模式之Pub/Sub发布订阅模式》][RabbitMQ_-_-03-RabbitMQ_Pub_Sub]

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

[RabbitMQ_-]: https://blog.csdn.net/Bb15070047748/article/details/112194912
[https_gitee.com_lvshuichangliu_rabbitmt.git]: https://gitee.com/lvshuichangliu/rabbitmt.git
[20210104153756921.png_pic_center]: /images/20221120/d9253867c3284a9a8c82dc0bf17eb8e9.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L0JiMTUwNzAwNDc3NDg_size_16_color_FFFFFF_t_70_pic_center]: /images/20221120/dedfa675503d463394c4f819796cea7d.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L0JiMTUwNzAwNDc3NDg_size_16_color_FFFFFF_t_70_pic_center 1]: /images/20221120/db7be63556c74ec7bf8e4167d7ce1d54.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L0JiMTUwNzAwNDc3NDg_size_16_color_FFFFFF_t_70_pic_center 2]: /images/20221120/b293cff5100e45178483473017190c27.png
[RabbitMQ_-_-03-RabbitMQ_Pub_Sub]: https://blog.csdn.net/Bb15070047748/article/details/112184019