pache顶级项目下，拥有不少子项目，包括 HornetMQ演变而来的Artemis，基于Scala号称下一代AMQ的Apollo等。 而Kafka最初被设计用来做日志处理，是一个不折不扣的大数据通道，追求高吞吐，存在丢消息的可 。其背后的研发团队也围绕着Kafka进行了商业包装，目前在一些中小型公司被广泛使用。 下表是一目了然的快速参考，可快速发现RocketMQ及其最受欢迎的替代产品之间的差异。

client 心跳 ClientManageProcessor 处理 client 的心跳请求 1. 构建 ClientChannelInfo 对象 1） 持有 channel 对象，表示与客户端的连接通道 2） ClientID 表示客户端 ….. 2. 每次心跳会更新 ClientChannelInfo 的时间戳，来表示 client 还活着 3. 注册或者更新 consumer 的订阅关系（是以

错误，Broker 不重试？ 为了解开这个谜团，接下来会采用源码分析的手段去探究真相。接下来将以消息同步发 送为例揭示其消息发送处理流程中的核心关键点。 MQ Client 消息发送端首先会利用网络通道将请求发送到 Broker，然后接收到请求 结果后并调用 processSendResponse 方法对响应结果进行解析，如下图所示： 在这里，RemotingCommand 的 code 为