RocketMQ 5.0 无状态实时性消费详解
💡
原文中文，约3800字，阅读约需9分钟。
📝
内容提要
RocketMQ 5.0引入了SimpleConsumer客户端类型，通过无状态的弹出机制解决了负载均衡问题。然而，当客户端和消息都很少时，这种机制可能导致消息消费延迟。RocketMQ的当前长轮询机制在与代理模块一起使用时存在问题。客户端的长轮询和代理的长轮询耦合在一起，当客户端少而多个Broker可用时会出现问题。为了解决这个问题，提出了一种名为“带通知的弹出”（pop with notify）的新解决方案，它将客户端的长轮询与Broker的长轮询解耦，并允许代理优先选择具有消息的Broker。该解决方案设计简单可靠，并考虑了自适应切换到传统长轮询的情况。使用指标来监控长轮询的性能和成本。Apache RocketMQ中的最小长轮询超时设置为5秒。总体而言，该解决方案提供了实时消费，同时减少了不必要的请求和网络开销。
🎯
关键要点
-
RocketMQ 5.0引入了SimpleConsumer客户端类型，采用无状态的弹出机制解决负载均衡问题。
-
当客户端和消息数量较少时，可能会出现消息消费延迟。
-
当前的长轮询机制在Proxy模块下存在耦合问题，导致客户端无法实时接收到消息。
-
提出了“带通知的弹出”解决方案，将客户端长轮询与Broker长轮询解耦，允许代理优先选择有消息的Broker。
-
该方案设计简单可靠，能够自适应切换到传统长轮询。
-
使用指标监控长轮询的性能和成本，最小长轮询超时设置为5秒。
-
通过重构NOTIFICATION，改进了消息获取机制，确保高效处理消息。
-
消费任务从队列获取结果，避免并发操作导致的消息未处理情况。
-
设计了一组指标记录长轮询表现，帮助进一步调优。
-
总结方案成功实现了实时消费，减少无效请求和网络开销。
➡️
