rocketmq5.2的几个小疑问
来源:9-8 【案例实现】Spring Boot集成 RocketMq 案例实现
小耶哥
2024-05-26
诗集成rocketmq,我在官网看他是用的这个
org.apache.rocketmq
rocketmq-client-java
${rocketmq-client-java-version}
,然后巴拉巴拉写了很多,包括消费者也是,都先自己初始化,我想请教下,一般情况下,我们是使用官方给出的demo那样写,还是按照你这样写?有什么区别吗?再有一个,我有一个问题请教一下你,我的消息发送正常(并发20),接收消息时,偶尔会有1-3条消息接收不到,其余的都是可以的,但是这种情况不经常出现,偶发性的,其实也有点必然,就是多测试几次,就会出现一次。这种是什么问题?我的版本是5.2
写回答
1回答
-
Tim老师
2024-05-26
先解释一下你第一个问题,一般我们不会按照你说的官方方式一个一个创建,starter相关API的目的就是简化这种代码。另外一个根据你的描述,是20个并发消息发送成功,但是消费端偶尔几条接受不到?单纯根据你这点描述很难知道你那边什么问题,但是有一个问题想确认,就是消息发送成功你是怎么确定的?通常如果是本地玩,自己模拟并发,有时候是本地可能机器问题,导致收不到消息。此时最好装一下rocketmq的控制台,在界面上看看消费位点,或者看看日志有什么错误,如果broker中转消息失败会报错00
相似问题