RabbitMQ工作模式（二）

2022-05-14 97

版权

本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。

简介： Work queues 工作队列模式

一、工作队列介绍

Work queues：比简单模式多了一个或者多个消费者，多个消费者消费同一个队列中的消息
应用场景：对于任务过重或者过多的情况下，可以提高任务处理的速度

二、示例

基础代码及工具类全都在第一篇中，需要请查看《RabbitMQ工作模式（一）》

1、生产者代码

packagecom.cui.producer;
importcom.cui.common.RabbitMqUtils;
importcom.rabbitmq.client.Channel;
importcom.rabbitmq.client.Connection;
importjava.io.IOException;
/*** 工作队列生产者*/publicclassProducer_WorkQueues {
publicstaticvoidmain(String[] args) throwsIOException {
//获得连接Connectionconnection=RabbitMqUtils.getConnection();
//创建channelChannelchannel=connection.createChannel();
//创建队列channel.queueDeclare("work_queues", true, false, false, null);
//发送消息for (inti=0; i<10; i++) {
Stringbody="hello_Word"+i;
channel.basicPublish("", "work_queues", null, body.getBytes());
        }
//释放资源RabbitMqUtils.close(channel, connection);
    }
}

2、消费者代码

packagecom.cui.consumer;
importcom.cui.common.RabbitMqUtils;
importcom.rabbitmq.client.*;
importjava.io.IOException;
/*** 工作队列消费者Consumer_WorkQueues1，可复制一份同样的代码充当消费者2*/publicclassConsumer_WorkQueues1 {
publicstaticvoidmain(String[] args) throwsIOException {
Connectionconnection=RabbitMqUtils.getConnection();
Channelchannel=connection.createChannel();
channel.queueDeclare("work_queues", true, false, false, null);
//接收消息Consumerconsumer=newDefaultConsumer(channel){
@OverridepublicvoidhandleDelivery(StringconsumerTag, Envelopeenvelope, AMQP.BasicPropertiesproperties, byte[] body) throwsIOException {
Stringmessage=newString(body, "UTF-8");
System.out.println("接收到消息："+message);
            }
        };
channel.basicConsume("work_queues", true, consumer);
    }
}