Skip To Main Content
RPCHook rpcHook on Muck Rack

RPCHook rpcHook

As seen in: cnblogs.com, CSDN
Is this you? As a journalist, you can create a free Muck Rack account to customize your profile, list your contact preferences, and upload a portfolio of your best work. Claim your profile
Back to RPCHook rpcHook’s profile

Articles by RPCHook rpcHook

聊聊 RocketMQ 消息轨迹

|
By Boolean Enable MsgTrace, consumer.setNamesrv Addr, Thread.currentThread .getName, RPCHook rpcHook
| cnblogs.com
这篇文章，我们聊一聊 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) 在生产者的构造函数里，有两个核心参数：...
Open in Who Shared Issue with article?

聊聊RocketMQ 消息轨迹-阿里云开发者社区

|
By Thread.currentThread .getName, RPCHook rpcHook, Boolean Enable MsgTrace, consumer.setNamesrv Addr
| dasizhe.cn
这篇文章，我们聊一聊 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) 在生产者的构造函数里，有两个核心参数：...
Open in Who Shared Issue with article?

[RocketMQ] Consumer消费者启动主要流程源码 (六)

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