RabbitMQ 基础教程-轮询分发消息案例

一个队列可以有多个消费者，多个消费者分摊消费这个队列中的消息。

下面通过案例演示：在这个案例中我们会启动两个工作线程，一个消息发送线程，我们来看看他们两个工作线程是如何工作的。

1）抽取工具类

    public class RabbitMqUtils {
        //得到一个连接的 channel
        public static Channel getChannel() throws Exception{
            //创建一个连接工厂
            ConnectionFactory factory = new ConnectionFactory();
            factory.setHost("182.92.234.71");
            factory.setUsername("admin");
            factory.setPassword("123");
            Connection connection = factory.newConnection();
            Channel channel = connection.createChannel();
            return channel;
        }
    }

2）启动两个消费者

下面是消费者代码，咱们启动2次，让2个消费者一起工作，idea需要设置下，见下图

    public class Worker01 {
        private static final String QUEUE_NAME="hello";
        public static void main(String[] args) throws Exception {
            Channel channel = RabbitMqUtils.getChannel();
            DeliverCallback deliverCallback=(consumerTag,delivery)->{
                String receivedMessage = new String(delivery.getBody());
                System.out.println("接收到消息:"+receivedMessage);
            };
            CancelCallback cancelCallback=(consumerTag)->{
                System.out.println(consumerTag+"消费者取消消费接口回调逻辑");
            };
            System.out.println("C2 消费者启动等待消费......");
            channel.basicConsume(QUEUE_NAME,true,deliverCallback,cancelCallback);
        }
    }

3）启动一个发送线程

    public class Task01 {
        private static final String QUEUE_NAME="hello";
        public static void main(String[] args) throws Exception {
            try(Channel channel=RabbitMqUtils.getChannel();) {
                channel.queueDeclare(QUEUE_NAME,false,false,false,null);
                //从控制台当中接受信息
                Scanner scanner = new Scanner(System.in);
                while (scanner.hasNext()){
                    String message = scanner.next();
                    channel.basicPublish("",QUEUE_NAME,null,message.getBytes());
                    System.out.println("发送消息完成:"+message);
                }
            }
        }
    }

5）结果展示

通过程序执行发现生产者总共发送 4 个消息，消费者 1 和消费者 2 分别分得两个消息，并且是按照有序的一个接收一次消息