Spring Cloud Stream
Spring Cloud Stream 在使用 Apache Kafka、RabbitMQ、Azure Event Hub 等方面提高了您的生产力,提供了三个关键抽象来简化您的代码。“绑定器”与外部消息系统集成。“绑定”弥合了消息系统和您的代码之间的差距。“消息”提供了您的代码用于发送和接收数据的结构。
Spring Cloud Stream 还提供对配置管理、消费者组、分区、监控和健康检查的支持。
结合微服务使用事件流会带来令人兴奋的机会——事件驱动架构就是一个常见的例子。Spring 简化了事件的生产、处理和消费,提供了几个有用的抽象。
流数据表示事件的持续流。一个例子可能是股票行情。每次股票价格发生变化时,都会创建一个新的事件。它被称为“流数据”,因为有成千上万这样的事件导致持续的数据流。
任何事件驱动系统的基础都是消息处理。连接到消息平台、路由消息、转换消息、处理消息。使用 Spring,您可以快速解决这些集成挑战。
Spring Cloud Stream 在使用 Apache Kafka、RabbitMQ、Azure Event Hub 等方面提高了您的生产力,提供了三个关键抽象来简化您的代码。“绑定器”与外部消息系统集成。“绑定”弥合了消息系统和您的代码之间的差距。“消息”提供了您的代码用于发送和接收数据的结构。
Spring Cloud Stream 还提供对配置管理、消费者组、分区、监控和健康检查的支持。
@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。