在使用spring cloud云架构的时候，我们不得不使用Spring cloud Stream，因为消息中间件的使用在项目中无处不在，我们公司后面做了娱乐方面的APP，在使用spring cloud做架构的时候，其中消息的异步通知，业务的异步处理都需要使用消息中间件机制。spring cloud的官方给出的集成建议（使用rabbit mq和kafka），我看了一下源码和配置，只要把rabbit mq集成，kafka只是换了一个pom配置jar包而已，闲话少说，我们就直接进入配置实施：
1. 简介：
Spring cloud Stream数据流操作开发包，封装了与Redis,Rabbit、Kafka等发送接收消息。
2. 使用工具：
rabbit，具体的下载和安装细节我这里不做太多讲解，网上的实例太多了
3. 创建commonservice-mq-producer消息的发送者项目，在pom里面配置stream-rabbit的依赖
4. 在yml文件里面配置rabbit mq
5. 定义接口ProducerService
6. 定义绑定
7. 定义发送消息业务ProducerController
8. 创建commonservice-mq-consumer1消息的消费者项目，在pom里面配置stream-rabbit的依赖
9. 在yml文件中配置：
9. 定义接口ConsumerService
10. 定义启动类和消息消费
11. 分别启动commonservice-mq-producer、commonservice-mq-consumer1
12. 通过postman来验证消息的发送和接收
可以看到接收到了消息，下一章我们介绍mq的集群方案。
到此，整个消息中心方案集成完毕（企业架构源码可以加求球：叁五三陆二肆柒二伍玖）！！
欢迎大家和我一起学习spring cloud构建微服务云架构，我这边会将近期研发的spring cloud微服务云架构的搭建过程和精髓记录下来，帮助更多有兴趣研发spring cloud框架的朋友，大家来一起探讨spring cloud架构的搭建过程及如何运用于企业项目。
