各种消息处理器
| 类 | 作用 |
|---|---|
| SendMessageProcessor | 处理消息存储请求 |
| PullMessageProcessor | 处理消息拉取请求 |
| ReplyMessageProcessor | Producer端发出消息后以同步或异步的方式等待Consumer消费这条消息并响应 |
| QueryMessageProcessor | 处理消息查询请求 |
| ClientManageProcessor | |
| ConsumerManageProcessor | 集群模式消息进度存储 |
| EndTransactionProcessor | 处理二阶段的事务消息 |
| AdminBrokerProcessor | 处理管控台的请求,如创建topic等 |
remotingServer和fastRemotingServer的区别
Broker端:remotingServer可以处理客户端所有请求。而fastRemotingServer可以处理除了消息拉取之外的客户端所有请求
Client端:默认情况下生产者发送消息是请求fastRemotingServer,我们也可以配置让其请求remotingServer,消费者拉取只能请求remotingServer
好的系列
[1]https://www.zhihu.com/people/TaXueWWL/posts
ReplyMessageProcessor的作用
[2]https://cloud.tencent.com/developer/news/592569



