1、Spring Cloud Stream

Spring Cloud Stream

Spring Cloud Stream是一个框架，用于构建与共享消息系统连接的高度可扩展的事件驱动微服务。

官网：https://docs.spring.io/spring-cloud-stream/docs/current/reference/html/

官网概述：https://docs.spring.io/spring-cloud-stream/docs/current/reference/html/spring-cloud-stream.html#spring-cloud-stream-preface-notable-deprecations

该框架提供了一个灵活的编程模型，该模型基于已经建立和熟悉的Spring习惯用法和最佳实践，包括对持久pub/sub 语义、消费者组和有状态分区的支持。

简单的理解就是Spring Cloud Stream 通过在上层定义统一消息的编程模型，屏蔽了底层消息中间件的差异，降低了使用成本。下图展示了Spring Cloud Stream的处理架构

Spring Cloud Stream 处理架构

Spring Cloud Stream的核心构建块（编程模型）是：

• Destination Binders: 负责提供与外部消息传递系统集成的组件。Binders 可以生成Bindings。
• *Bindings: * 外部消息系统和应用程序之间的桥梁，提供消息的生产者和消费者（由目标绑定器创建）。即用来绑定消息生产者和消息消费者。它有两种类型，INPUT和OUTPUT，INPUT对应消费者，OUTPUT对应生产者。
• Message: 生产者和消费者用于与目标绑定器（以及通过外部消息系统与其他应用程序）通信的规范的数据结构。

2. Spring Cloud Stream的执行流程