RocketMQ命令总结[v1.0]
2020-12-21 10:09:36 1 举报AI智能生成
RocketMQ处理器以及命令盘点
作者其他创作
大纲/内容
NameSrv
DefaultRequestProcessor
线程池说明
使用线程池 RemotingExecutorThread_
一共8个线程
处理命令
PUT_KV_CONFIG
向Namesrv追加KV配置
GET_KV_CONFIG
从Namesrv获取KV配置
DELETE_KV_CONFIG
从Namesrv删除KV配置
QUERY_DATA_VERSION
从brokerLiveTable获取最新的topic的配置信息
REGISTER_BROKER
注册一个Broker，数据都是持久化的，如果存在则覆盖配置
UNREGISTER_BROKER
卸载一个Broker，数据都是持久化的
GET_ROUTEINTO_BY_TOPIC
根据Topic获取Broker Name、topic配置信息
GET_BROKER_CLUSTER_INFO
获取注册到Name Server的所有Broker集群信息
WIPE_WRITE_PERM_OF_BROKER
去掉BrokerName的写权限
GET_ALL_TOPIC_LIST_FROM_NAMESERVER
从Name Server获取完整Topic列表
DELETE_TOPIC_IN_NAMESRV
从Namesrv删除Topic配置
GET_KVLIST_BY_NAMESPACE
通过NameSpace获取所有的KV List
GET_TOPICS_BY_CLUSTER
获取指定集群下的所有 topic
GET_SYSTEM_TOPIC_LIST_FROM_NS
获取所有系统内置 Topic 列表
GET_UNIT_TOPIC_LIST
单元化相关 topic
GET_HAS_UNIT_SUB_TOPIC_LIST
获取含有单元化订阅组的 Topic 列表
GET_HAS_UNIT_SUB_UNUNIT_TOPIC_LIST
获取含有单元化订阅组的非单元化 Topic 列表
UPDATE_NAMESRV_CONFIG
更新nameserver的配置
GET_NAMESRV_CONFIG
获取nameser的配置
Client
ClientRemotingProcessor
线程池说明
使用线程池NettyClientPublicExecutor_
数量使用Runtime.getRuntime().availableProcessors()
处理命令
CHECK_TRANSACTION_STATE
处理broker发来的事务消息状态回查指令
NOTIFY_CONSUMER_IDS_CHANGED
broker通知:consumer有变动,需要这个消费组的机器立即执行rebalance
RESET_CONSUMER_CLIENT_OFFSET
处理broker指令:重置消费位点,用于重新消费某些消息
GET_CONSUMER_STATUS_FROM_CLIENT
broker发来管理命令查询:查询消费组的状态
GET_CONSUMER_RUNNING_INFO
broker发来管理命令查询:查询消费组运行状态
CONSUME_MESSAGE_DIRECTLY
让指定消费这消费消息指令
Broker
SendMessageProcessor
线程池说明
使用线程池sendMessageExecutor
线程数:1,队列数10000
处理命令
SEND_MESSAGE
处理消息发送命令
SEND_MESSAGE_V2
处理消息发送命令
SEND_BATCH_MESSAGE
处理批量消息发送
CONSUMER_SEND_MSG_BACK
消息发送失败回传给broker,客户端定时消息清理回传
PullMessageProcessor
线程池说明
使用线程池PullMessageThread_
线程数16 + Runtime.getRuntime().availableProcessors() * 2
队列数: 100000
处理命令
PULL_MESSAGE
处理客户端的消息拉取指令
QueryMessageProcessor
线程池说明
使用线程池QueryMessageThread_
线程数8 + Runtime.getRuntime().availableProcessors()
队列数20000
处理命令
QUERY_MESSAGE
消息查询,走index
VIEW_MESSAGE_BY_ID
根据id查询,直接走commitlog,根据偏移量拿消息
ClientManageProcessor
线程池说明
使用线程池 HeartbeatThread_
线程数1,队列数:50000
处理命令
HEART_BEAT
处理客户端的心跳,进行相应的更新
UNREGISTER_CLIENT
取消注册客户端,一般在客户端执行shutdown的时候执行
CHECK_CLIENT_CONFIG
客户端发出来用于检查注册情况，确认该实例已经在broker注册成功，否则抛异常
ConsumerManageProcessor
线程池说明
使用线程池 ConsumerManageThread_
线程数 32
处理命令
GET_CONSUMER_LIST_BY_GROUP
UPDATE_CONSUMER_OFFSET
客户端更新偏移量(非广播模式)
QUERY_CONSUMER_OFFSET
客户端查询偏移量(非广播模式)
EndTransactionProcessor
线程池说明
使用线程池 EndTransactionThread_
线程数:8 + Runtime.getRuntime().availableProcessors() * 2
队列数:100000
END_TRANSACTION
处理事务消息的第二阶段指令
AdminBrokerProcessor
线程池说明
线程池: AdminBrokerThread_
线程数 16
作为broker的default处理器,上面process都找不到处理器的时候,走这个processor
处理命令
UPDATE_AND_CREATE_TOPIC
创建topic,并注册到nameserver
DELETE_TOPIC_IN_BROKER
删除topic
GET_ALL_TOPIC_CONFIG
查询topicconfig
UPDATE_BROKER_CONFIG
更新broker的配置
GET_BROKER_CONFIG
查询broker配置
SEARCH_OFFSET_BY_TIMESTAMP
查询某一个消息队列的偏移量(根据时间)
GET_MAX_OFFSET
查询最大偏移量
GET_MIN_OFFSET
查询最小偏移量
GET_EARLIEST_MSG_STORETIME
查询队列最早消息对应时间
GET_BROKER_RUNTIME_INFO
Broker 获取Broker运行时信息
LOCK_BATCH_MQ
Broker Consumer向Master锁定队列
UNLOCK_BATCH_MQ
Broker Consumer向Master解锁队列
UPDATE_AND_CREATE_SUBSCRIPTIONGROUP
更新订阅组
GET_ALL_SUBSCRIPTIONGROUP_CONFIG
获取订阅组配置
DELETE_SUBSCRIPTIONGROUP
删除订阅组
GET_TOPIC_STATS_INFO
toipc的统计状态查询
GET_CONSUMER_CONNECTION_LIST
消费者连接查询
GET_PRODUCER_CONNECTION_LIST
生产者连接查询
GET_CONSUME_STATS
消费者状态
GET_ALL_CONSUMER_OFFSET
Broker 获取所有Consumer Offset
GET_ALL_DELAY_OFFSET
Broker 获取所有定时进度
INVOKE_BROKER_TO_RESET_OFFSET
通知 broker 调用 offset 重置处理
INVOKE_BROKER_TO_GET_CONSUMER_STATUS
通知 broker 调用客户端订阅消息处理
QUERY_TOPIC_CONSUME_BY_WHO
Broker 查询topic被谁消费
REGISTER_FILTER_SERVER
向Broker注册Filter Server
QUERY_CONSUME_TIME_SPAN
根据 topic 和 group 获取消息的时间跨度
GET_SYSTEM_TOPIC_LIST_FROM_BROKER
获取内置topic列表
CLEAN_EXPIRED_CONSUMEQUEUE
清理失效队列
CLEAN_UNUSED_TOPIC
清理无用topic
GET_CONSUMER_RUNNING_INFO
通过Broker查询Consumer内存数据
QUERY_CORRECTION_OFFSET
查找被修正 offset (转发组件）
CONSUME_MESSAGE_DIRECTLY
通过Broker直接向某个Consumer发送一条消息，并立刻消费，返回结果给broker，再返回给调用方
CLONE_GROUP_OFFSET
克隆某一个组的消费进度到新的组
VIEW_BROKER_STATS_DATA
查看Broker上的各种统计信息
GET_BROKER_CONSUME_STATS
查询broker的消费者状态
QUERY_CONSUME_QUEUE
查询指定topic指定queueid的信息
UPDATE_AND_CREATE_ACL_CONFIG
创建acl(权限相关)配置
DELETE_ACL_CONFIG
删除acl配置
GET_BROKER_CLUSTER_ACL_INFO
查询broker集群acl信息
UPDATE_GLOBAL_WHITE_ADDRS_CONFIG
更新全局白名单配置
RESUME_CHECK_HALF_MESSAGE
半消息检查命令
![RocketMQ命令总结[v1.0]](https://www.processon.com/chart_image/template/thumb/5fe003e0762131023bede379.png?tid=5fdc61fe7d9c0855ea73afa1)
收藏
职业：暂无
0 条评论
下一页
