这是提问:
rocketmq 消费者,订阅的topic的用户单聊消息的聊天内容。需求是现在需要统计 用户单聊中被找的人回复时长。现在的问题是多个消费消费 导致统计的出现错误。错误原因,多个消费者消费会将用户单聊中回复的话被当做第一次聊天记录。出现错误统计。请从消费性能,程序稳定性等角度考虑如何解决这个问题
这是回答:
为了解决多个消费者同时消费导致的统计错误问题,我们需要确保每个消息只被一个消费者处理。可以采用RocketMQ的消息顺序消费特性,通过设置消息的key来保证同一个用户的单聊消息被同一个消费者顺序处理。具体修改如下:
修改消费者的消费模式为顺序消费模式:通过设置consumeMode为ORDERLY。
设置消息的key:在发送消息时,设置消息的key为用户的唯一标识(例如用户ID),这样同一个用户的单聊消息会被同一个消费者顺序处理。
回答内容 没有用。考虑的不够全面。
对比新的deepseek 的回答。相差太多了
希望可以通义也可以提供这样的相关思路。解决方案
版权声明:本文内容由阿里云实名注册用户自发贡献,版权归原作者所有,阿里云开发者社区不拥有其著作权,亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容,填写侵权投诉表单进行举报,一经查实,本社区将立刻删除涉嫌侵权内容。