【SpringCloud】Spring Cloud Stream 消息驱动（二十三）
2021-01-28 07:17
标签：信道 输入 bit 需要 overview png info 发布-订阅 应用 Spring Cloud Stream，官方定义Spring Cloud Stream是一个构建消息驱动微服务的框架 应用程序通过 inputs 或者 outputs 来与 Spring Cloud Stream 中的binder对象交互，通过配置binding（绑定），而 Spring Cloud Stream 的binder对象负载与消息中间件交互，所以，我们只需要高清楚如何与 Spring Cloud Stream 交互就可以方便使用消息驱动的方式，通过使用Spring Integration 来连接消息代理中间件以实现消息事件驱动。 Spring Cloud Stream 为一些供应商的消息中间件产品提供了个性化的自动化配置实现，引用了发布-订阅、消费组、分区的三个核心概念 目前仅支持RabbitMQ、Kafka 官网：https://spring.io/projects/spring-cloud-stream 中文手册：https://www.springcloud.cc/spring-cloud-greenwich.html#spring-cloud-stream-overview-introducing 【SpringCloud】Spring Cloud Stream 消息驱动（二十三） 标签：信道 输入 bit 需要 overview png info 发布-订阅 应用 原文地址：https://www.cnblogs.com/h--d/p/12840086.htmlSpring Cloud Stream介绍
Spring Cloud Stream处理架构
组成
说明
Middleware
中间件，目前只支持RabbitMQ和Kafka
Binder
Binder是应用与消息中间件之间的封装，目前实行了Kafka和RabbitMQ的Binder，通过Binder可以很方便的连接中间件，可以动态的改变消息类型(对应于Kafka的topic，RabbitMQ的exchange)，这些都可以通过配置文件来实现
@Input
注解标识输入通道，通过该输入通道接收到的消息进入应用程序
@Output
注解标识输出通道，发布的消息将通过该通道离开应用程序
@StreamListener
监听队列，用于消费者的队列的消息接收
@EnableBinding
指信道channel和exchange绑定在一起
上一篇：Java 中 Lombok 的使用，提高开发速度必备
下一篇：C语言 数组与指针
文章标题：【SpringCloud】Spring Cloud Stream 消息驱动（二十三）
文章链接：http://soscw.com/index.php/essay/48130.html