TAGS :消息,RocketMQ的合集
【RocketMQ】消息的存储

Broker对消息的处理 BrokerController初始化的过程中,调用registerProcessor方法注册了处理器,在注册处理器的代码中可以看到创建了处理消息发送的处理器对象SendMe