官方网站建设平台下载百度免费

背景：

        开发中我们往往需要用到mq中间件进行消息处理，但是市面上的mq中间件实在太多了，导致我们在集成过程中困难重重，尤其在微服务当中，比如我们有一个订单模块、物流模块 他们都用到了mq，订单用的是rabbitmq 物流用的是kafka 导致当我们需要向这两个模块推送mq消息时，需要考虑两种mq的对接方式，非常麻烦。由此当我们学习了springcloud-mq-stream后，这个问题就不算问题了。废话不多说，直接上代码

我们创建两个服务：服务A 生产者、服务B消费者

服务A 和服务B依赖与配置 

pom依赖：项目中我用的是rabbitmq

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