ToB企服应用市场:ToB评测及商务社交产业平台

标题: SpringBoot解决RabbitMQ消费几条消息后不再消费的bug [打印本页]
作者: 知者何南    时间: 2024-7-18 08:01
标题: SpringBoot解决RabbitMQ消费几条消息后不再消费的bug

近来小编在开辟项目中，偶然间遇到了这样一个bug,在利用本地RabbitMQ时候，生产者生产消息及消费者消费消息都很及时，但是当把项目部署到Linux服务器后，就会发生生产者生产消息后，有时候只有第一条会被消费，有时候消费几条以后，就不再消费了，初见这样的bug,一时百思不得其解，遇到就解决呗，由于项目的业务比力复杂，所以小编做了个RabbitMQ的demo,经过观察，排查，终于发现了bug的缘故原由，在这里作为履历总结给各人。
首先排查配置题目，由于是同样的配置，本地是链接、消息生产和消费是正常的，服务器上也会出现消费，所以对于RabbitMQ的链接是没题目的。
由于出题目的是服务器的RabbitMQ，小编做出的demo 用同样的配置链接服务器的RabbitMQ，IP必要利用服务器的IP,

这里必要留意一点，服务器必要开放5672端口，本地才华链接；RabbitMQ默认的用户名暗码是guest,guest,但是由于测试归属于服务器的RabbitMQ,而默认用户是不支持长途链接的，所以小编新建了个长途用户，admin,admin
小编这里简朴给各人写一下创建服务器RabbitMQ长途用户并赋予长途权限的指令，百度上有很多。
开启RabbitMQ webui管理
  1. rabbitmq-plugins enable rabbitmq_management
复制代码
添加用户 rabbitmqctl add_user 用户名 暗码
  1. rabbitmqctl add_user admin admin
复制代码
设置权限
  1. rabbitmqctl set_permissions -p "/" admin ".*" ".*" ".*"
复制代码
设置用户脚色：rabbitmqctl set_user_tags admin administrator
检察用户列表：rabbitmqctl list_users

RabbitMQ消息生产者：
  1. /**
  2.      * 向直接交换器发送数据
  3.      *
  4.      *
  5.      * @param massage
  6.      */
  7.     public void sendzongheDirectTestQueue(String massage) {
  8.         try{
  9.             rabbitTemplate.convertAndSend(RabbitConfig.zonghe_direct_exchange,
  10.                     RabbitConfig.zonghe_direct_exchange_key, massage);
  11.             System.out.println("发送消息到交换器："+massage);
  12.         }
  13.         catch (Exception e){
  14.             System.out.println("生产者生产消息出现异常："+e.getMessage());
  15.         }
  17.     }
复制代码
RabbitMQ消息消费者：
  1.    /**
  2.      * 监听直接测试队列数据
  3.      * @param massage
  4.      */
  5.     @RabbitListener(
  6.             bindings =
  7.                     {
  8.                             @QueueBinding(value = @Queue(value = RabbitConfig.zonghe_direct_queue, durable = "true"),
  9.                                     exchange = @Exchange(value = RabbitConfig.zonghe_direct_exchange),
  10.                                     key = RabbitConfig.zonghe_direct_exchange_key)
  11.                     })
  12.     @RabbitHandler
  13.     public void zongheprocessDirectMsg(Message massage) {
  14.         String msg = new String(massage.getBody(), StandardCharsets.UTF_8);
  15.         log.info("\r\n接收到综合测试队列 消息==>"+msg);
  16.     }
复制代码
消息生产调用，小编做了个简朴的定时任务，间隔5秒生产一次消息，用随机字符区分消息的不同性。
  1. @Autowired
  2.     private MsgProducer msgProducer;
  4.     @Scheduled(initialDelay = 5000, fixedRate = 5000)
  5.     public void test(){
  6.         try {
  7.             msgProducer.sendzongheDirectTestQueue("我是发送给rabbitmq综合交换器的消息"+StringTimeUtil.nonce(5));
  8.             System.out.println(StringTimeUtil.now()+"间隔5秒发送消息完成");
  9.         }catch (Exception e){
  10.             System.out.println("RabbitMQ发送消息异常："+e.getMessage());
  11.         }
  12.     }
复制代码
结果如下：

出现了这样的环境，生产者生产了3条消息后，RabbitMQ demo才消费了末了一条，而消息生产并未出现非常，也就是说，定时任务调用生产者生产消息均是正常的，但demo里面只消费了末了一条消息，之前生产的两条消息不知什么环境，是丢失了照旧发生返回了，假如发生返回，后面应该会再次被demo消费掉，但是好久也没有查到之前的两条消息的消费环境。唉，索性小编又开放了服务器的ui管理端口，通过访问服务器RabbitMQ的ui管理来查查吧，同样的，在外面访问ui管理仍然必要利用新建的长途用户举行登录。

由于满是英文，小编也不懂啊，不外由于经常利用，照旧能看懂些单词的。小编首先进入交换器。

看样子是没什么非常的，交换器是正常创建的，密钥也正确，durable:true状态也正常。然后检察队列。


看表格这里是正常的，能收到消息，也在消费，点进去检察：
小编发现，关于消息交换器和消息队列绑定也是正常的，也没有发生回传重试，但忽然留意到消息队列的消费者有三个，而且下面的Consumers详细的列出了三个消费者。由此猜想，八成是demo中生产的三条消息，前两条被其他消费者消费掉了，末了一条消息由demo本身的消费者消费了。经过排查测试确实是这样，小编本地开辟项目在链接着服务器的RabbitMQ，服务器正运行的项目也在连接着RabbitMQ，加上本地demo恰恰三个，当把除了demo其他两个服务均关闭后，结果就正常了。
关闭后的web管理界面结果如下：

消费者变成了一个，而且demo的消费也变正常了，生产一个，demo本地就消费一个。

到这里，题目已然基本解决了，个人感觉，通过消息队列在处理并发异步上是比力方便的。好了，以上如有不足之处，接待指正，希望各人多多关注多多支持小编，制作不易！

免责声明：如果侵犯了您的权益，请联系站长，我们会及时删除侵权内容，谢谢合作！更多信息从访问主页：qidao123.com:ToB企服之家，中国第一个企服评测及商务社交产业平台。



欢迎光临 ToB企服应用市场:ToB评测及商务社交产业平台 (https://dis.qidao123.com/) Powered by Discuz! X3.4