事件驱动

事件驱动系统反映了现代企业实际运作方式——每天每时每刻都会发生数千次微小变化。Spring 能够处理事件并让开发人员围绕事件构建应用程序，这意味着你的应用程序将与你的业务保持同步。Spring 有许多事件驱动选项可供选择，从集成和流式传输到云函数和数据流。

事件驱动的微服务

当与微服务结合使用时，事件流将带来激动人心的机会——事件驱动架构就是一个常见的例子。Spring 简化了事件的生成、处理和使用，提供了几个有用的抽象。

流式传输数据

流式传输数据表示事件的持续流。一个例子可能是股票行情。每次股票价格发生变化时，都会创建一个新事件。之所以称为“流式传输数据”，是因为有数千个此类事件导致持续的数据流。

集成

任何事件驱动系统的基石都是消息处理。连接到消息平台、路由消息、转换消息、处理消息。使用 Spring，你可以快速解决这些集成难题。

Spring Cloud Stream

Spring Cloud Stream 提高了你在使用 Apache Kafka、RabbitMQ、Azure Event Hub 等时的工作效率，提供了三个关键抽象来简化你的代码。“Binder”与外部消息系统集成。“Binding”弥合了消息系统和你的代码之间的差距。“消息”提供了你的代码用于发送和接收数据的结构。

Spring Cloud Stream 还提供对供应、内容转换、错误处理、配置管理、消费者组、分区、监控和运行状况检查的支持。

开始使用流处理

Spring [Cloud] Stream 和 Spring 解决方案帮助我们为命令式和响应式需求提供一个内聚的解决方案。

ANIL GURSEL，软件工程师，PAYPAL

Spring Cloud Function

Spring Cloud Function 使您能够编写一次函数，然后在任何地方（AWS、Azure 等）运行它们，同时继续使用所有熟悉的和全面的 Spring API。您可以将多个函数链接在一起以创建新的功能。对多个输入和输出的支持使合并、联接和其他更高级的用例触手可及。

@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 Cloud Data Flow

Spring Cloud Data Flow 为开发人员提供了一系列工具和自动化，用于处理各种数据源和目标。Spring Cloud Data Flow 帮助您跨多个云原生平台开发、部署、管理和扩展高吞吐量流数据管道。它还具有一个丰富的用户界面，用于构建和监控您的应用程序。

了解更多

Spring Cloud Kafka Streams

Spring Cloud Stream 提供了一个第二个、更具体的绑定器，专门用于处理 Kafka Streams。此特殊绑定器仍然专注于开发人员的工作效率，但增加了对 Kafka 特定功能（如 KStream、KTable 和 GlobalKTable）的支持。与常规 Spring Cloud Stream 一样，绑定器还负责连接到 Kafka，以及创建、配置和维护流和主题。

了解更多