用Spring cloud Stream来开发基于MQ消息驱动的微服务

Spring boot对MQ类如RabbitMQ、kafka支持都很好，可是仍然要写一些模板代码。Spring cloud stream进一步掩盖了这个差别，仅仅使用配置就能够完成。

 

Spring cloud Stream 用了基于topic-subsriber的模式，虽然不支持所有MQ的特性，但绝大多数应用来讲，这样就足够用了，毕竟方便不少。具体用法以下：

包含的包

　　　　　　　　<dependency> <groupId>org.springframework.cloud</groupId> <artifactId>spring-cloud-starter-bus-amqp</artifactId> </dependency> <dependency> <groupId>org.springframework.cloud</groupId> <artifactId>spring-cloud-starter-stream-rabbit</artifactId> </dependency>

MQ接口

public interface MyMQInterface{ @Input("通道名") SubscribableChannel inputChannel(); @Output("通道名") MessageChannel outputChanel(); }

• 通道名发送方和接受方必须是一致的
• 一个应用不能既是同一个通道的发送方和接收方，不然会警告。这实际上也没有意义。
• 声明后，启用绑定

　　@EnableBinding(MyMQInterface.class)

• 能够绑定多个接口

发送MQ消息

 @Autowired MyMQInterface myInterface; ..... myInterface.inputChannel().send(MessageBuilder....);

接受消息

@SystemListener("通道名") public void onReceive(Message content)

应用集群问题

• 若是某个应用起来多个实例，如上面的配置，会致使每条消息每一个实例都会收到，若是你不想这么作，请在配置里面加上：

spring.cloud.stream.bindings.testOrders.group=分组名

• 每一个应用定义一个惟一的分组名，很差和其余应用重复。

消息处理异常

• 若是收到消息处理有问题，好比写入数据库失败，请抛出RuntimeException异常，MQ会重试，不太重试几回后会失败，这个要注意。