spring cloud stream 是一个用来为微服务应用构建消息驱动能力的框架。 它可以基于spring boot 来创建独立的、 可用于生产的 spring 应用程序。 它通过使用 spring integration 来连接消息代理中间件以实现消息事件驱动。 spring cloud stream 为一些供应商的消息中间件产品提供了个性化的自动化配置实现，并且引入了发布-订阅、 消费组以及分区这三个核心概念。 简单地说， spring cloud stream 本质上就是整合了 spring boot 和 springintegration, 实现了一套轻量级的消息驱动的微服务框架。到目前为止，springcloud stream 只支持下面两个著名的消息中间件的自动化配置：

• rabbitmq
• kafka

快速入门

pom.xml 中的依赖关系

lt;parentgt; 
　　lt;groupidgt;org.springframework.bootlt;/groupidgt; 
　　lt;artifactidgt;spring-boot-starter-parentlt;/artifactidgt; 
　　lt;versiongt;l.3.7.releaselt;/versiongt; 
　　lt;relativepath/gt; lt;!-- lookup parent from repository --gt; 
lt;/parent＞
lt;dependenciesgt; 
　　lt;dependencygt; 
　　　　lt;groupidgt;org.springframework.bootlt;/groupidgt; 
　　　　lt;artifactidgt;spring-boot-starter-weblt;/artifactidgt; 
　　lt;/dependencygt; 
　　lt;dependencygt; 
　　　　lt;groupidgt;org.springframework.bootlt;/groupidgt; 
　　　　lt;artifactidgt;spring-boot-starter-testlt;/artifactidgt; 
　　　　lt;scopegt;testlt;/scopegt;
　　lt;/dependencygt; 
　　lt;dependencygt; 
　　　　lt;groupidgt;org.springframework.cloudlt;/groupidgt; 
　　　　lt;artifactidgt;spring-cloud-starter-stream-rabbitlt;/artifactidgt;
　　lt;/dependencygt; 
lt;/dependenciesgt; 
lt;dependencymanagementgt; 
　　lt;dependenciesgt; 
　　　　lt;dependencygt; 
　　　　　　lt;groupidgt;org.springframework.cloudlt;/groupidgt; 
　　　　　　lt;artifactidgt;spring-cloud-dependencieslt;/artifactidgt; 
　　　　　　lt;versiongt;brixton.srslt;/versiongt;
　　　　　　lt;typegt;pomlt;/typegt; 
　　　　　　lt;scopegt;importlt;/scopegt; 
　　　　lt;/dependencygt; 
　　lt;/dependenciesgt; 
lt;/dependencymanagement＞

创建用于接收来自 rabbitmq 消息的消费者 sinkreceiver

@enablebinding{sink.class) 
public class sinkreceiver { 

　　private static logger logger = loggerfactory. getlogger (helloapplication. class}; 

　　@streamlistener(sink.input) 
　　public void receive(object payload) { 
　　　　logger.info("received: " + payload); 
   }
}

第十章 消息驱动的微服务： spring cloud stream

原文地址：https://www.cnblogs.com/hzzjj/p/10291627.html