............................................................................... 35 11.3.2 针对 Consumer ............................................................................................... ...................................................................................... 42 14 Consumer 最佳实践 .......................................................................................... 产生消息。  Consumer 消息消费者，负责消费消息，一般是后台系统负责异步消费。  Push Consumer Consumer 的一种，应用通常吐 Consumer 对象注册一个 Listener 接口，一旦收到消息，Consumer 对象立 刻回调 Listener 接口方法。  Pull Consumer Consumer 的一种，应用通常主劢调用

本文来自『中间件兴趣圈』公众号，仅作技术交流，未授权任何商业行为。 11 > 1.1 RocketMQ 核心概念扫盲篇 3. Client 消息客户端，包括 Producer(消息发送者)和 Consumer(消费消费者)．客户端在同一 时间只会连接一台 nameserver，只有在连接出现异常时才会向尝试连接另外一台。客户 端每隔 30s 向 Nameserver 发起 topic 的路由信息查询。 order_consumer 来订阅 order_topic，并且基于分布式部署， order-service-app 的部署情况如下： 本文来自『中间件兴趣圈』公众号，仅作技术交流，未授权任何商业行为。 1.1 RocketMQ 核心概念扫盲篇 < 12 即 order-service-app 部署了 3 台服务器，每一个 jvm 进程可以看做是消费组 order_consumer 消费组的其中一个消费者。 ConsumerGroup: consumer-grouptest The consumerId: c onsumer-client-id-clusterA-192.168.3.122@21932 not in cidAll: [consumer-client-id-clust erA-192.168.3.123@22164] 上面的日志显示在队列负载时候，当前节点竟然不属于 consumer-grouptest

................ 12 第二章 consumer .......................................................................................................................... 14 一：consumer 启动流程 ..................... 第二章 consumer 有别于其他消息中间件由 broker 做负载均衡并主动向 consumer 投递消息，RocketMq 是基于 拉模式拉取消息，consumer 做负载均衡并通过长轮询向 broker 拉消息。 Consumer 消费拉取的消息的方式有两种 1. Push 方式：rocketmq 已经提供了很全面的实现， consumer 通过长轮询拉取消息后回调 因为绝大多数是由 push 消费方式来使用 rocketmq 的。 一：consumer 启动流程 指定 group 订阅 topic 注册消息监听处理器，当消息到来时消费消息 消费端 Start 复制订阅关系 初始化 rebalance 变量 构建

Producer A Topic A Broker B Topic B ConsumerGroupA ConsumerGroupB Consumer 1 Consumer 2 Producer B Consumer 1 Consumer 2 MessageQueue1 MessageQueue2 MessageQueue1 MessageQueue2 部署模型 组件细节 In Memory except KV config info Netty RemotingServer topic register and heart beats Producer Consumer NRC BrokerAddrTlb send Msg topic route heatbeats MsgQueList callback/check NRC pull MsgExt | a5 - a4+1 | h3 doDispatch() Consumer config/consumerOffset.json commitOffset() ConsumerOffsetManager "offsetTable":{ "TopicTest@consumer-g1":{0:0,1:21,2:0}, ... } index

gz解压后的目录结构： . ├── LICENSE ├── NOTICE ├── README.md ├── benchmark │ ├── batchproducer.sh │ ├── consumer.sh │ ├── producer.sh │ ├── runclass.sh │ ├── shutdown.sh │ └── tproducer.sh ├── bin │ server是多台集群的话，就用分号分隔 namesrvAddr=192.168.166.20:9876;192.168.166.206:9876 # 每个topic对应队列的数量，默认为4，实际参考consumer实例的数量，值过小不利于consumer负 均衡 defaultTopicQueueNums=8 # 是否允许broker自动创建Topic，生产建议关闭 autoCreateTopicEnable=true # server是多台集群的话，就用分号分隔 namesrvAddr=192.168.166.20:9876;192.168.166.206:9876 # 每个topic对应队列的数量，默认为4，实际参考consumer实例的数量，值过小不利于consumer负 均衡 defaultTopicQueueNums=8 # 是否允许broker自动创建Topic，生产建议关闭 autoCreateTopicEnable=true #

yByCircle,AllocateMachineRoomNearb y, AllocateMessageQueueConsistentHash, etc, Rebalance logic consumer, MQFaultStrategy, ConsistentHash,etc - KEDA - After deployment, we could validate the deployment case(add dependencies rocketmq-client), send async/sync/ 1way mode, consume message - Broadcast with consumer set to broadcast mode, register message listener and consume messge concurrently - Schedule example: out message - Logappender example: - Open Message example: OMS Producer & OMS Pull consumer, OMS Push Consumer - Transaction example: send transactional message and implement transaction listener

在我们看来，它最大的创新点在于能够通过精巧的横向、纵向扩展，不断满足与日俱增的海量消息在 吞吐、高可靠、低延迟方面的要求。 目前RocketMQ主要由NameServer、Broker、Producer以及Consumer四部分构成，如下图所示。 原文链接：Apache RocketMQ 介绍 NameServer以轻量级的方式提供服务发现和路由功能，每个NameServer存有全量的路由信息，提 对等的读写服务，支持快速扩缩容。 cs统计以及告警机 。这些都是传统消息系统无法比拟的。 Producer由用户进行分布式部署，消息由Producer通过多种负载均衡模式发送到Broker集群，发送 延时，支持快速失败。 Consumer也由用户部署，支持PUSH和PULL两种消费模式，支持集群消费和广播消息，提供实时的 息订阅机制，满足大多数消费场景。 特点 ● RocketMQ支持异步实时刷盘，同步刷盘，同步复制，异步复制。具有高可靠性。不会因为操作系 Tools ActiveMQ Java, .NET, C++ etc. Push model, support OpenWire, STOMP, AMQP, M TT, JMS Exclusive Consumer or Exclusive Queues can ensure ordering Supported ot Supported Supported Supported Not Supported

 消除 Consumer 与 Queue 的 Binding 关 系，一个 Queue 可以由多个消费者消费  无 rebalance ，降低消费延迟概率  集群中某些消费端假死不影响整体消费进度  客户端更加轻量，多语言友好 流批一体  在Streaming场景下，单一消费者消费保证顺 序  在 batch 场景下，无需保证顺序，可以多个 consumer 加快数据读取速度

consumers's progress, speed consumerStatus Query consumer's internal data structure clusterList List all of clusters resetOffsetByTime Reset consumer offset by timestamp(without client restart). …

apache.rocketmq.example.quickstart.Producer // 消费消息 ./tools.sh org.apache.rocketmq.example.quickstart.Consumer [文档：docker部署rocketmq服务.note 链接：http://note.youdao.com/noteshare?id=41831bf1 b70d4662f852ab0c6b