深圳宝安股票,机械类网站如何做网站优化,网站优化,农产品网络营销策划方案上一篇#xff1a; springboot整合rabbitMQ模拟简单收发消息
https://blog.csdn.net/m0_67930426/article/details/134904766?spm1001.2014.3001.5502 在这篇文章的基础上进行操作
基本思路#xff1a;
1.在rabbitMQ控制台创建一个新的队列
2.在publisher服务中定义一个…上一篇 springboot整合rabbitMQ模拟简单收发消息
https://blog.csdn.net/m0_67930426/article/details/134904766?spm1001.2014.3001.5502 在这篇文章的基础上进行操作
基本思路
1.在rabbitMQ控制台创建一个新的队列
2.在publisher服务中定义一个测试方法在1秒内产生40条消息发送到新创建的队列
3.在consumer服务中定义两个消息监听者监听新创建的队列
1.在rabbitMQ控制台创建一个新的队列 2.在publisher服务中定义一个测试方法在1秒内产生40条消息发送到新创建的队列 Testvoid Test2Send() {String queueName work.queue;for (int i 1 ; i 40; i) {String msg hello,message_i;rabbitTemplate.convertAndSend(queueName, msg);try {Thread.sleep(30);} catch (InterruptedException e) {throw new RuntimeException(e);}}} 3.在consumer服务中定义两个消息监听者监听新创建的队列 RabbitListener(queues work.queue)
public void ccc(String msg){System.out.println(消费者c收到了work.queue的消息:【msg】);
}RabbitListener(queues work.queue)
public void ddd(String msg){System.err.println(消费者d收到了work.queue的消息:【msg】);
}
调试 消费者消息推送限制
默认情况下rabbitMQ会将消息依次投递给绑定在队列上的每一个消费者但这并没有考虑到
消费者是否处理完消息就很可能出现消息堆积现象
应对这一现象我们可以在application.yml上设置preFetch的值为1每次只能获取1条消息
处理完才能获取下一条消息
在消费者模块的配置文件里设置
