Spring Cloud Stream

Spring Cloud Stream

Spring Cloud Stream 是一个框架，用于构建与共享消息系统连接的高度可扩展的事件驱动微服务。
该框架提供了一个灵活的编程模型，该模型建立在已经建立和熟悉的 Spring 习惯用法和最佳实践之上，包括对持久发布/订阅语义、消费者组和有状态分区的支持。

https://spring.io/projects/spring-cloud-stream

Binder 实现

• RabbitMQ

• Apache Kafka

• Kafka Streams

• Amazon Kinesis

• Google PubSub (partner maintained)

• Solace PubSub+ (partner maintained)

• Azure Event Hubs (partner maintained)

• Azure Service Bus (partner maintained)

• AWS SQS (partner maintained)

• AWS SNS (partner maintained)

• Apache RocketMQ (partner maintained)

Spring Cloud Stream 的核心构建块是：

Destination Binders：负责提供与外部消息传递系统集成的组件。

目标绑定：外部消息传递系统和最终用户提供的应用程序代码（生产者/消费者）之间的桥梁。

Message：生产者和消费者用来与 Destination Binders（以及其他应用程序通过外部消息系统）进行通信的规范数据结构。