RPCHook rpcHook

这篇文章，我们聊一聊 RocketMQ 的消息轨迹设计思路。 查询消息轨迹可作为生产环境中排查问题强有力的数据支持 ，也是研发同学解决线上问题的重要武器之一。 消息轨迹是指一条消息从生产者发送到 Broker , 再到消费者消费，整个过程中的各个相关节点的时间、状态等数据汇聚而成的完整链路信息。 当我们需要查询消息轨迹时，需要明白一点：消息轨迹数据是存储在 Broker 服务端，我们需要定义一个主题，在生产者，消费者端定义轨迹钩子。 2.1 修改 Broker 配置文件 # 开启消息轨迹 traceTopicEnable=true 2.2 生产者配置 public DefaultMQProducer(final String producerGroup, boolean enableMsgTrace) public DefaultMQProducer(final String producerGroup, boolean enableMsgTrace, final String customizedTraceTopic) 在生产者的构造函数里，有两个核心参数：...

这篇文章，我们聊一聊 RocketMQ 的消息轨迹设计思路。 查询消息轨迹可作为生产环境中排查问题强有力的数据支持 ，也是研发同学解决线上问题的重要武器之一。 消息轨迹是指一条消息从生产者发送到 Broker , 再到消费者消费，整个过程中的各个相关节点的时间、状态等数据汇聚而成的完整链路信息。 当我们需要查询消息轨迹时，需要明白一点：消息轨迹数据是存储在 Broker 服务端，我们需要定义一个主题，在生产者，消费者端定义轨迹钩子。 2.1 修改 Broker 配置文件 # 开启消息轨迹 traceTopicEnable=true 2.2 生产者配置 public DefaultMQProducer(final String producerGroup, boolean enableMsgTrace) public DefaultMQProducer(final String producerGroup, boolean enableMsgTrace, final String customizedTraceTopic) 在生产者的构造函数里，有两个核心参数：...

checkConfig方法检查消费者的配置信息: 如果consumerGroup为空, 或者长度大于255个字符, 或者包含非法字符, 或者消费者组名为默认组名DEFAULT_CONSUMER, 或者messageModel为空, 或者consumeFromWhere为空, 或者consumeTimestamp为空, 或者allocateMessageQueueStrategy为空, 满足以上任意条件都校验不通过抛出异常。 调用copySubscription方法, 拷贝订阅关系, 然后为集群消费模式的消费者配置重试主题用于实现消费重试。 调用getOrCreateMQClientInstance方法, 根据clientId获取或者创建CreateMQClientInstance实例, 并赋给mQClientFactory变量。 设置负载均衡服务rebalanceImpl的相关属性。 创建消息拉取核心对象PullAPIWrapper, 封装了消息拉取以及结果解析逻辑的api。 根据消息模式设置不同的OffsetStore,...