Spring Boot整合RocketMQ

在本小节中，我们将讨论在Spring Boot中整合RocketMQ。

我们选用官方推荐的Spring Boot拓展rocketmq-spring-boot-starter

依赖接入

首先，需要在Spring Boot中添加依赖:

compile 'com.qianmi:spring-boot-starter-rocketmq:1.1.0-RELEASE'

配置RocketMQ的服务器

在配置中，我们需要设定RocketMQ的服务器集群

spring.rocketmq:
    nameServer: 127.0.0.1:9876
    producer.group: lmsia-abc

如上所示：

• spring.rocketmq.nameServer 配置元服务器的地址
• spring.rocketmq.producer.group 是Producer Group。我们这里设定为微服务的名字，即相同的微服务都认为是同一个Producer Group。

在Spring Boot中首发消息

按照上述进行配置后，自动配置会被激活，并自动注入RocketMQTemplate用于生成发消息、ListenerContainer用于收消息。

上述对使用方都是透明的，在Spring Boot中收发消息非常简单，如下：

@Service
@RocketMQMessageListener(topic = TOCPIC, consumerGroup = LmsiaAbcConstant.PROJECT_NAME)
public class MyEventHandlerImpl implements MyEventHandler, RocketMQListener<MyEvent> {

    private Logger LOG = LoggerFactory.getLogger(getClass());

    @Resource
    private RocketMQTemplate rocketMQTemplate;

    @Override
    public void send(MyEvent event) {
        rocketMQTemplate.convertAndSend(TOCPIC, event);
    }

    @Override
    public void onMessage(MyEvent message) {
        LOG.info("receive message, data = {}", message.getData());
    }
}

如上所述:

• topic需要配置成一致的，即TOPIC常量，类似的，consumerGroup定义为微服务名称，即认为同一个微服务的所有节点属于同一个组。
• 我们自动注入了RocketMQTemplate用于发消息，消息默认继承自Serializable
• RocketMQListener会在收到消息后回调onMessage方法。

如果你使用过RocketMQ的官方客户端的话，会发现其易用性要远低于spring-boot-starter-rocketmq。

RocketMQ还支持顺序消息、广播消息等更多功能，spring-boot-starter-rocketmq中都支持了具体的实现，可以直接参考上述项目主页的说明。