线程池说明
线程池: AdminBrokerThread_
线程数 16
作为broker的default处理器,上面process都找不到处理器的时候,走这个processor
处理命令
UPDATE_AND_CREATE_TOPIC
创建topic,并注册到nameserver<br>
DELETE_TOPIC_IN_BROKER
删除topic<br>
GET_ALL_TOPIC_CONFIG
查询topicconfig<br>
UPDATE_BROKER_CONFIG
更新broker的配置<br>
GET_BROKER_CONFIG
查询broker配置<br>
SEARCH_OFFSET_BY_TIMESTAMP
查询某一个消息队列的偏移量(根据时间)<br>
GET_MAX_OFFSET
查询最大偏移量<br>
GET_MIN_OFFSET
查询最小偏移量<br>
GET_EARLIEST_MSG_STORETIME
查询队列最早消息对应时间<br>
GET_BROKER_RUNTIME_INFO
Broker 获取Broker运行时信息<br>
LOCK_BATCH_MQ
Broker Consumer向Master锁定队列<br>
UNLOCK_BATCH_MQ
Broker Consumer向Master解锁队列<br>
UPDATE_AND_CREATE_SUBSCRIPTIONGROUP
更新订阅组<br>
GET_ALL_SUBSCRIPTIONGROUP_CONFIG
获取订阅组配置<br>
DELETE_SUBSCRIPTIONGROUP
删除订阅组<br>
GET_TOPIC_STATS_INFO
toipc的统计状态查询<br>
GET_CONSUMER_CONNECTION_LIST
消费者连接查询<br>
GET_PRODUCER_CONNECTION_LIST
生产者连接查询<br>
GET_CONSUME_STATS
消费者状态<br>
GET_ALL_CONSUMER_OFFSET
Broker 获取所有Consumer Offset<br>
GET_ALL_DELAY_OFFSET
Broker 获取所有定时进度<br>
INVOKE_BROKER_TO_RESET_OFFSET
通知 broker 调用 offset 重置处理<br>
INVOKE_BROKER_TO_GET_CONSUMER_STATUS
通知 broker 调用客户端订阅消息处理<br>
QUERY_TOPIC_CONSUME_BY_WHO
Broker 查询topic被谁消费<br>
REGISTER_FILTER_SERVER
向Broker注册Filter Server<br>
QUERY_CONSUME_TIME_SPAN
根据 topic 和 group 获取消息的时间跨度
GET_SYSTEM_TOPIC_LIST_FROM_BROKER
获取内置topic列表
CLEAN_EXPIRED_CONSUMEQUEUE
清理失效队列<br>
CLEAN_UNUSED_TOPIC
清理无用topic<br>
GET_CONSUMER_RUNNING_INFO
通过Broker查询Consumer内存数据<br>
QUERY_CORRECTION_OFFSET
查找被修正 offset (转发组件）<br>
CONSUME_MESSAGE_DIRECTLY
通过Broker直接向某个Consumer发送一条消息，并立刻消费，返回结果给broker，再返回给调用方<br>
CLONE_GROUP_OFFSET
克隆某一个组的消费进度到新的组<br>
VIEW_BROKER_STATS_DATA
查看Broker上的各种统计信息<br>
GET_BROKER_CONSUME_STATS
查询broker的消费者状态<br>
QUERY_CONSUME_QUEUE<br>
查询指定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)
