RocketMQ消息模型

• 核心模型：RocketMQ本质上是基于拉模式的。
• 长轮询技术：使用长轮询技术，减少了拉取消息的延迟，同时保持了拉模式的控制优势。

长轮询技术详解

• 工作原理：

  1. 请求保持开放：消费者向服务器发出获取消息的请求，如果无消息，请求保持开放状态。
  2. 等待消息：服务器在有消息或达到超时时间前，保持请求不关闭。
  3. 发送响应：一旦有消息或超时，服务器立即响应消费者。
  4. 重启请求：消费者处理完消息后，再次发起长轮询请求。

• 效果：

  • 实时性提升：消费者可以接近实时地接收到消息。
  • 降低资源消耗：减少了因频繁轮询而产生的网络流量和服务器负担。
  • 提高效率：只在有消息时进行通信，提升了资源使用效率。

RocketMQ网络通信协议

• 基于TCP：使用持久的TCP连接，减少连接开销。
• Netty框架：利用Netty的异步处理和事件驱动能力。
  • 消息编解码：高效处理消息的编码和解码。
  • 请求响应匹配：精确匹配请求和响应。
  • 心跳检测：维持连接活跃性。
  • 数据传输：优化数据传输过程。
• 自定义协议：特别关注数据传输效率和减少网络延迟。

总结

• 优势结合：RocketMQ通过长轮询结合了拉模式的控制性和推模式的实时性。
• 适用场景：适合需要高实时性同时希望控制消息流的业务场景。
• 性能保持：在保持高性能的同时，适应多样化的使用需求。