标签：input obj ble tor 个性化 from 概念 通过 构建
Spring Cloud Stream 是一个用来为微服务应用构建消息驱动能力的框架。 它可以基于Spring Boot 来创建独立的、 可用于生产的 Spring 应用程序。 它通过使用 Spring Integration 来连接消息代理中间件以实现消息事件驱动。 Spring Cloud Stream 为一些供应商的消息中间件产品提供了个性化的自动化配置实现，并且引入了发布-订阅、 消费组以及分区这三个核心概念。 简单地说， Spring Cloud Stream 本质上就是整合了 Spring Boot 和 SpringIntegration, 实现了一套轻量级的消息驱动的微服务框架。到目前为止，SpringCloud Stream 只支持下面两个著名的消息中间件的自动化配置：
pom.xml 中的依赖关系
<parent> <groupid>org.springframework.boot</groupid> <artifactid>spring-boot-starter-parent</artifactid> <version>l.3.7.RELEASE</version> <relativePath/> <!-- lookup parent from repository --> </parent＞ <dependencies> <dependency> <groupid>org.springframework.boot</groupid> <artifactid>spring-boot-starter-web</artifactid> </dependency> <dependency> <groupid>org.springframework.boot</groupid> <artifactid>spring-boot-starter-test</artifactid> <scope>test</scope> </dependency> <dependency> <groupid>org.springframework.cloud</groupid> <artifactid>spring-cloud-starter-stream-rabbit</artifactid> </dependency> </dependencies> <dependencyManagement> <dependencies> <dependency> <groupid>org.springframework.cloud</groupid> <artifactid>spring-cloud-dependencies</artifactid> <version>Brixton.SRS</version> <type>pom</type> <scope>import</scope> </dependency> </dependencies> </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
标签：input obj ble tor 个性化 from 概念 通过 构建
原文地址：https://www.cnblogs.com/hzzjj/p/10291627.html
