RabbitMQ实现工作模式Work queues
前提条件
已经实现了监听队列接收消息,具体步骤查看:RabbitMQ实现监听队列接收消息
介绍
工作模式是一个或者多个消费者共同消费一个队列中的消息,队列中的每一个消息只可能被其中一个消费者消费,比如:多个人抢一个蛋糕,只有一个人可以抢到
应用场景:对于消息任务很多的情况,可以使用工作队列提高任务处理的速度
原理:集群处理大量的消息
实现过程
批量发送消息
为了方便测试,在rabbitmq-producer模块下添加一个批量发送消息功能,可以自定义批量发送的消息数量
首先在sendInformationPage.html中添加一个form标签:
1 | <form action="/sendInformationBatch"> |
在IndexController类添加一个方法:
1 | /** |
消费消息
在rabbitmq-consumer模块下修改
先在RabbitMQConsumerService类添加一个接口方法:
1 | /** |
然后在RabbitMQConsumerServiceImpl类中实现上面的接口方法
1 |
|
测试
启动rabbitmq-producer模块和rabbitmq-consumer模块,然后在浏览器地址栏输入:http://localhost/toSendInformationPage 进入发送消息页面,根据自己的需要填入批量发送的消息数量,然后点击发送,最后去rabbitmq-consumer模块启动控制台查看结果
本博客所有文章除特别声明外,均采用 CC BY-NC-SA 4.0 许可协议。转载请注明来自 LeDao's Blog!
评论