消息队列RocketMQ版消息轨迹名词:消费耗时是什么?

消息队列RocketMQ版消息轨迹名词:消费耗时是什么?

展开
收起
Lee_tianbai 2021-01-01 17:03:20 753 分享 版权
1 条回答
写回答
取消 提交回答
  • 这个时间是消费耗时,是调用客户端的 consume() 的整个花费的时间。也就是 图 2 的 SubAfter 的 TimeStamp 减去 SubBefore 的 TimeStamp 的时间。 消费段的代码逻辑可以看

    com.aliyun.openservices.shade.com.alibaba.rocketmq.client.impl.consumer.
    ConsumeMessageConcurrentlyService.ConsumeRequest#run()(注意,这是非顺序消费的执行
    逻辑)中执行的
    com.aliyun.openservices.ons.api.impl.tracehook.
    OnsConsumeMessageHookImpl#consumeMessageBefore
    com.aliyun.openservices.ons.api.impl.tracehook.
    OnsConsumeMessageHookImpl#consumeMessageAfter
    
    2021-01-01 17:03:53
    赞同 展开评论

涵盖 RocketMQ、Kafka、RabbitMQ、MQTT、轻量消息队列(原MNS) 的消息队列产品体系,全系列产品 Serverless 化。RocketMQ 中文社区:https://rocketmq-learning.com/

还有其他疑问?
咨询AI助理