首页 > 代码库 > rocketmq 问题

rocketmq 问题

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--

rocketmq 问题