rocketmq5.2的几个小疑问

Question

诗集成rocketmq，我在官网看他是用的这个
org.apache.rocketmq
rocketmq-client-java
${rocketmq-client-java-version}
，然后巴拉巴拉写了很多，包括消费者也是，都先自己初始化，我想请教下，一般情况下，我们是使用官方给出的demo那样写，还是按照你这样写？有什么区别吗？再有一个，我有一个问题请教一下你，我的消息发送正常（并发20），接收消息时，偶尔会有1-3条消息接收不到，其余的都是可以的，但是这种情况不经常出现，偶发性的，其实也有点必然，就是多测试几次，就会出现一次。这种是什么问题？我的版本是5.2

Answer 1

Tim老师 2024-05-26 19:05:16

先解释一下你第一个问题，一般我们不会按照你说的官方方式一个一个创建，starter相关API的目的就是简化这种代码。另外一个根据你的描述，是20个并发消息发送成功，但是消费端偶尔几条接受不到？单纯根据你这点描述很难知道你那边什么问题，但是有一个问题想确认，就是消息发送成功你是怎么确定的？通常如果是本地玩，自己模拟并发，有时候是本地可能机器问题，导致收不到消息。此时最好装一下rocketmq的控制台，在界面上看看消费位点，或者看看日志有什么错误，如果broker中转消息失败会报错