当与微服务结合使用时，事件流开启了令人兴奋的机会——事件驱动架构就是一个常见的例子。 Spring 简化了事件的生成、处理和消费，提供了几个有用的抽象。
流式传输数据表示事件的持续流动。一个例子可能是股票行情。每次股票价格发生变化时，都会创建一个新事件。之所以称为“流式传输数据”，是因为有成千上万个事件导致数据的持续流。
任何事件驱动系统的基石都是消息处理。连接到消息平台、路由消息、转换消息、处理消息。借助 Spring，您可以快速解决这些集成挑战。
Spring Cloud Stream 在使用 Apache Kafka、RabbitMQ、Azure Event Hub 等时提高了您的生产力，提供了三个关键抽象来简化您的代码。“绑定器”与外部消息传递系统集成。“绑定”弥合了消息传递系统和您的代码之间的差距。“消息”提供您的代码用于发送和接收数据的结构。
Spring Cloud Stream 还提供对配置、内容转换、错误处理、配置管理、消费者组、分区、监控和运行状况检查的支持。
Spring [Cloud] Stream 和 Spring 解决方案帮助我们为命令式和反应式需求提供一个有凝聚力的解决方案。
@SpringBootApplication
public class Application {
public static void main(String[] args) {
SpringApplication.run(Application.class, args);}
@Bean
public Function<String, String> uppercase() {
return value -> value.toUpperCase();}
}
通过 Spring AMQP 和 Spring for Apache Kafka 项目，您可以将核心 Spring 概念应用于基于 Kafka 或 RabbitMQ 的消息传递解决方案的开发。
两者都包含“模板”作为高级消息处理抽象，并支持具有“侦听器容器”的消息驱动的 POJO。
