getWhichBrokerW henConsumeSlowly()); } else { responseHeader.setSuggestWhichBrokerId(MixAll.MASTER_ID); } switch (this.brokerController.getMessageStoreConfig().getBrokerRole()) { // @2 case ASYNC_MASTER: onGroupConfig.ge tBrokerId()); } } else { responseHeader.setSuggestWhichBrokerId(MixAll.MASTER_ID); } 代码@1：如果从 commitlog 文件查找消息时，发现消息堆积太多，默认超过物理内 存的 40%后，会建议从从服务器读取。 本文来自『中间件兴趣圈』公众号，仅作技术交流，未授权任何商业行为。 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

{���} ( {ID} varchar, {��} varchar, {��} varchar, {��} varchar, ) with ( topic = ’{���MQ}', consumerGroup = ‘C01’ ); select d.{��ID}, d.{����}, s.{ID} from {���} as s inner join {��} as d on s.{ID} = d.{���ID} {���ID} where cast(s.{�����} as bigint) > 90; create table {��} ( {��ID} varchar, {����} varchar, {���ID} varchar, {�����} varchar ) with ( topic = ’{��MQ}', consumerGroup = 'C02' ); ������

1 VPC VPC 必填项 您希望部署到的已有 VPC ID（例 如, vpc0343606e）。 2 Primary Node Subnet PrimaryNodeSubnet 必填项 要将主 RocketMQ 节点部署到的 VPC 中现 有⼦网的 ID (例如， subnet-a0246dcd) 。此⼦网需要 在您选择的 VPC RocketMQ 节点所在⼦网 ID。此 ⼦网需存在于所选 VPC 中。 4 Secondary1 Node Subnet Secondary1NodeSubnet 必填项 副本集中第⼆个 secondary RocketMQ 节点所在的⼦网的 ID 。此⼦网需存在于所选 VPC 中。 5 Bastion Security Group ID BastionSecurityGroupI BastionSecurityGroupI D 必填项 希望用于堡垒机的安 全组的 ID (例如 sg7f16e910)。此安全组 需 要存在于您选择的 VPC 中。 Security Configuration 安全配置 6 Key Name KeyPairName 必填项 密钥对，用于连接 EC2 实例。 Page 11 of 18

VPC VPC 必填项 您希望部署到的已有 VPC ID （例如, vpc0343606e）。 2 Primary Node Subnet PrimaryNodeSubnet 必填项 要将主 RocketMQ 节点部署到 的 VPC 中现 有⼦⽹的 ID (例如 ，subnet-a0246dcd) 。此⼦⽹ 需要在您选择的 VPC 节点所在⼦⽹ ID。 此⼦⽹需存在于所选 VPC 中。 4 Secondary1 Node Subnet Secondary1NodeSubne t 必填项 副本集中第⼆个 secondary RocketMQ 节点所在的⼦⽹的 ID。此⼦⽹需存在于所选 VPC 中。 5 Bastion Security Group ID BastionSecurityGroupI D 必填项 希望⽤于堡垒机的安 全组的 ID (例如 sg7f16e910)。此安全组 需要存在于您选择的 VPC 中。 Security Configuration 安全配置 6 Key Name KeyPairName 必填项 密钥对，⽤于连接 EC2 实例。 AMAZON QuickStart

........................................................................... 20 7.3.1 挄照 Message Id 查询消息 ............................................................................................. 项目开源主页：https://github.com/alibaba/RocketMQ 20 7.3 消息查询 7.3.1 挄照 Message Id 查询消息 消息所属Broker地址 8Byte Commit Log Offset 8Byte 图表 7-2 Message Id 组成 MsgId 总共 16 字节，包含消息存储主机地址，消息 Commit Log offset。从 MsgId 中解析出 选填，代表这条消息的业务关键词，服务器会根据 keys 创建哈希索引，设置后， 可以在 Console 系统根据 Topic、Keys 来查询消息，由于是哈希索引，请尽可能 保证 key 唯一，例如订单号，商品 Id 等。 Flag 0 选填，完全由应用来设置，RocketMQ 不做干预 DelayTimeLevel 0 选填，消息延时级别，0 表示不延时，大于 0 会延时特定的时间才会被消费

topicRoute Examine topic route info topicStatus Examine topic Status info queryMsgById Query Message by Id queryMsgByKey Query Message by Key consumerProgress Query consumers's progress, speed consumerStatus M i d d l e w a r e G r o u p $sh mqadmin querymsgbykey -k Query_Key -t ORDER_TOPIC #Message ID #QID ORDER_TOPIC Tags: [ApacheCon] Keys: [Query_Key] Queue ID: 0 Queue Offset: 1 CommitLog Offset: 148053682794 Reconsume Times: 0 Born

链接：http://note.youdao.com/noteshare?id=41831bf1 b70d4662f852ab0c6b1a3dd&sub=6704265BC771455E8A835F8E7462D595](文档：docke 部署rocketmq服务.note 链接：http://note.youdao.com/noteshare?id=41831bf1db70d4662f85 ab0c6b1

TxCoordinator 3 store TxQue Master Broker TxEvent Commit/Rollback Global Transaction ID Branch Transaction ID 1 RMQ Producer 2 CallbackListener 3 TxMessageProcessor begin begin begin begin TxBranch1

Map brokerData 由 brokerName 和它的 broker ids 和 address id 表示是 master 还是 slave id = 0 为 master 大于 0 为 slave Map> queueData 由 brokerName，