springboot搭建 rockemq
2019-08-15 22:17:51 0 举报springboot 搭建 rocketmq
作者其他创作
大纲/内容
根据DefaultMQPushConsumer中的定义registerMessageListener(MessageListenerConcurrently messageListener) 猜测：rocketmq客户端在收到消息后会调用这里注册进去的监听器实体对象的consumeMessage()方法
@Autowired
@Value
application.properties
MQConsumeMsgListenerProcessor
@Bean
实现接口重写方法
consumeMessage()方法中根据不同的topic 、tag选择不通的MQMsgProcessor进行处理，调用他们的handle 方法
return new DefaultMQPushConsumer().register(mqMessageListenerProcessor)
DemoNewTopicConsumerMsgProcessImpl
AbstractMQMsgProcessor
DefaultMQPushConsumer getRocketMQConsumer()
MQConsumerConfiguration
@Autowired注入
MQMsgProcessor
consumeMessage()
namesrvAddr、groupName
@SpringBootConfiguration
MessageListenerConcurrently
0 条评论
下一页
