| processor名称 | 接口编码 | 功能描述 |
|---|---|---|
| AckMessageProcessor | ACK_MESSAGE | pop模式，ack消息 |
| BATCH_ACK_MESSAGE | pop模式，批量ack消息 | |
| AdminBrokerProcessor | UPDATE_AND_CREATE_TOPIC | 创建topic |
| DELETE_TOPIC_IN_BROKER | ||
| GET_ALL_TOPIC_CONFIG | ||
| GET_TIMER_CHECK_POINT | ||
| GET_TIMER_METRICS | ||
| UPDATE_BROKER_CONFIG | ||
| GET_BROKER_CONFIG | ||
| UPDATE_COLD_DATA_FLOW_CTR_CONFIG | ||
| REMOVE_COLD_DATA_FLOW_CTR_CONFIG | ||
| GET_COLD_DATA_FLOW_CTR_INFO | ||
| SET_COMMITLOG_READ_MODE | ||
| SEARCH_OFFSET_BY_TIMESTAMP | ||
| GET_MAX_OFFSET | ||
| GET_MIN_OFFSET | ||
| GET_EARLIEST_MSG_STORETIME | ||
| GET_BROKER_RUNTIME_INFO | ||
| LOCK_BATCH_MQ | ||
| UNLOCK_BATCH_MQ | ||
| UPDATE_AND_CREATE_SUBSCRIPTIONGROUP | ||
| GET_ALL_SUBSCRIPTIONGROUP_CONFIG | ||
| DELETE_SUBSCRIPTIONGROUP | ||
| GET_TOPIC_STATS_INFO | ||
| GET_CONSUMER_CONNECTION_LIST | ||
| GET_PRODUCER_CONNECTION_LIST | ||
| GET_ALL_PRODUCER_INFO | ||
| GET_CONSUME_STATS | ||
| GET_ALL_CONSUMER_OFFSET | ||
| GET_ALL_DELAY_OFFSET | ||
| GET_ALL_MESSAGE_REQUEST_MODE | ||
| INVOKE_BROKER_TO_RESET_OFFSET | ||
| INVOKE_BROKER_TO_GET_CONSUMER_STATUS | ||
| QUERY_TOPIC_CONSUME_BY_WHO | ||
| QUERY_TOPICS_BY_CONSUMER | ||
| QUERY_SUBSCRIPTION_BY_CONSUMER | ||
| QUERY_CONSUME_TIME_SPAN | ||
| GET_SYSTEM_TOPIC_LIST_FROM_BROKER | ||
| CLEAN_EXPIRED_CONSUMEQUEUE | ||
| DELETE_EXPIRED_COMMITLOG | ||
| CLEAN_UNUSED_TOPIC | ||
| GET_CONSUMER_RUNNING_INFO | ||
| QUERY_CORRECTION_OFFSET | ||
| 还有很多 | ||
| ChangeInvisibleTimeProcessor | pop模式消费失败，修改消息的可见时间 | |
| ClientManageProcessor | HEART_BEAT | 心跳，注册消费者订阅列表，创建重试topic； 注册生产者发布列表 |
| UNREGISTER_CLIENT | 注销 | |
| CHECK_CLIENT_CONFIG | 客户端调用，检查一下客户端filter配置是否正确 | |
| ConsumerManageProcessor | GET_CONSUMER_LIST_BY_GROUP | pull模式查询消费组的消费者列表 |
| UPDATE_CONSUMER_OFFSET | pull模式，ack消息 | |
| QUERY_CONSUMER_OFFSET | pull模式，查询消费offset | |
| EndTransactionProcessor | 事务消息，提交事务 | |
| NotificationProcessor | pop模式，提交主动给客户端推送消息的任务 ??? | |
| PeekMessageProcessor | ??? | |
| PollingInfoProcessor | 查询polling请求的任务数量 ??? | |
| PullMessageProcessor | PULL_MESSAGE | pull模式，拉取消息 |
| PopMessageProcessor | POP_MESSAGE | pop模式，拉取消息 |
| QueryAssignmentProcessor | QUERY_ASSIGNMENT | 服务端重平衡，一般pop模式调用，查询自己应该消费哪些队列的消息 |
| SET_MESSAGE_REQUEST_MODE | 设置消费组的消费模式，pop还是push | |
| QueryMessageProcessor | QUERY_MESSAGE | 根据key查询消息 |
| VIEW_MESSAGE_BY_ID | 根据commitLogOffset查询消息 | |
| ReplyMessageProcessor | SEND_REPLY_MESSAGE_V2 | ？？？ |
| SEND_REPLY_MESSAGE | ||
| SendMessageProcessor | CONSUMER_SEND_MSG_BACK | push模式，消费失败的消息，会调用这个，写入重试topic |
| SEND_MESSAGE | 生产者发送消息 | |
| SEND_MESSAGE_V2 | sendSmartMsg时，发送的这种消息 | |
| SEND_BATCH_MESSAGE | 生产者批量发送消息 |
rocketmq中的各个processor的作用
©著作权归作者所有,转载或内容合作请联系作者
【社区内容提示】社区部分内容疑似由AI辅助生成，浏览时请结合常识与多方信息审慎甄别。
平台声明：文章内容（如有图片或视频亦包括在内）由作者上传并发布，文章内容仅代表作者本人观点，简书系信息发布平台，仅提供信息存储服务。
【社区内容提示】社区部分内容疑似由AI辅助生成，浏览时请结合常识与多方信息审慎甄别。
平台声明：文章内容（如有图片或视频亦包括在内）由作者上传并发布，文章内容仅代表作者本人观点，简书系信息发布平台，仅提供信息存储服务。
相关阅读更多精彩内容
- 一、RocketMQ 是什么? 是一个队列模型的消息中间件，具有高性能、高可靠、高实时、分布式特点； Produc...
