rocketmq 问题

Posted 2020-09-13

1. 收不到消息-consumerOffset.json 信息错位

这种情况一般是，手动删除了store/commitlog目录里的数据等非常规手段造成了consumerOffset.json中记录的还是原来的信息，导致consumer收不到消息。

rocketmq的broker，一个消息主题对应多个队列，这些队列的消费进度会记录在consumerOffset.json文件中。所以一旦这个文件中记录的还是老的offset信息，那么既然就消费不到消息。

一个主题对应几个队列，是记录在$home/store/config/topics.json中的。

topics.json同事发现 如果是自动创建topic，则此处值默认是4，对应broker配置文件的defaultTopicQueueNums项目。如果是手动创建，此处值是8。

注意上面这个文件的路径，目前分析来看，即使你在broker的配置文件中指定了storePathRootDir在其他路径，但是topics.json的信息还是在上面读取。因为这个定制配置信息是后加载的。(rocketmq版本 3.5.8)

这种问题处理办法，如果不是生产环境，可以停掉broker然后把store目录删除，重启broker。

此处收不到 消息没有任何报错。

 

2. 收不到消息-subscription group not exist

这种情况是在broker的配置文件中设置了autoCreateSubscriptionGroup项为false(默认这一项值true)。

解决办法：要么将上述配置项修改成true。要么用命令行创建订阅组。

sh mqadmin updateSubGroup -g test_group -n localhost:9876 -b localhost:10911

注意：这种情况 在pull形式消费时会报错，在push形式消费时没有任何错误。

错误异常代码：

response.setCode(ResponseCode.SUBSCRIPTION_GROUP_NOT_EXIST);
response.setRemark("subscription group not exist, " + requestHeader.getConsumerGroup() + " "
                    + FAQUrl.suggestTodo(FAQUrl.SUBSCRIPTION_GROUP_NOT_EXIST));

 

3. 收不到消息-一般需要定位哪些代码

正常来讲，分为两个方面，一是看producer端发送消息有没有成功，而是看consumer端有没有拿到消息

1. producer端定位broker服务的

com.alibaba.rocketmq.store.CommitLog.putMessage(MessageExtBrokerInner)

看看这个方法的返回的result是不是成功的即可。

详细分析参见我之前写的  rocketmq源码分析2-broker的消息接收

 

2. consumer端定位broker服务的

com.alibaba.rocketmq.broker.processor.PullMessageProcessor.processRequest(Channel, RemotingCommand, boolean)

看看能不能走到方法体中的case found分支即可。

详细分析参见我之前写的 rocketmq源码分析3-consumer消息获取

 

4. 消费完的消息 哪去了

我们在消费完消息后，如果是push的形式 我们会回一个success的状态，如果是pull的形式我们会更新offset。此处可以看到，消费完之后，更新的消息消费的offset，以使mq不会再定时push给你。

那么消费完的消息在broker上还在不在？答案是在的，硬盘上有存储。因为我们可以通过根据消息id查看的消息的方式找到消息。

MessageExt viewMessage = consumer.viewMessage("0A00007400002A9F0000000000010C5E");

当然，rocketmq允许你配置，消息留存多长时间，以及每天几点清除。

--EOF--