首页 > TAG信息列表 > msgInner
【RocketMQ】消息的存储
Broker对消息的处理 BrokerController初始化的过程中，调用registerProcessor方法注册了处理器，在注册处理器的代码中可以看到创建了处理消息发送的处理器对象SendMessageProcessor，然后将其注册到远程服务中： public class BrokerController { // 初始化 public boolean initi【RocketMQ】消息的存储
Broker对消息的处理 BrokerController初始化的过程中，调用registerProcessor方法注册了处理器，在注册处理器的代码中可以看到创建了处理消息发送的处理器对象SendMessageProcessor，然后将其注册到远程服务中： public class BrokerController { // 初始化 public boolean initi