转载

Spring Cloud Stream 2.0发布，专注于性能、灵活性和一致性

看新闻很累？看技术新闻更累？试试下载InfoQ手机客户端，每天上下班路上听新闻，有趣还有料！

Pivotal正式发布 Spring Cloud Stream 2.0 ，用于构建高度可扩展的基于事件驱动的微服务。此版本包含对content-type协商功能（允许用户定义消息转换器）的全面改进，减小资源占用，支持轮询式消费者，支持Micrometer度量指标，增强对Apache Kafka Streams的支持等。

Spring Cloud Stream是一个用于构建“基于事件驱动的、与共享消息系统相连接的高度可扩展微服务”的框架，并提供了许多抽象和原语，以简化Spring生态系统消息驱动应用程序的开发。 Spring Cloud Stream应用程序由一个“与中间件无关的核心”组成，应用程序通过由框架注入的输入和输出通道与外部进行通信。通道通过中间件特定的“Binder实现”连接到外部代理，目前支持RabbitMQ和Apache Kafka。

Spring Cloud Stream的核心构件是：

目标绑定器——提供与外部邮件系统集成的组件。
目标绑定——外部消息传递系统和应用程序之间的桥梁，提供消息的“生产者”和“消费者”（由目标绑定器创建）。
消息——一种规范化的数据结构，生产者和消费者基于这个数据结构通过外部消息系统与目标绑定器和其他应用程序通信。

Spring Cloud Stream 2.0发布，专注于性能、灵活性和一致性

Spring Cloud Stream 2.0体系结构和消息流处理（图片由Spring博客提供）

Spring Cloud Stream 2.0包含对 content-type协商功能的全面改进，以解决性能、灵活性和一致性问题。最近发布的博客提供了更多细节概述，更多信息可以在参考指南的“content-type协商”部分找到。这一版本还支持最新的用户自定义消息转换器，值得一提的是，Spring Cloud Stream还支持基于Avro的转换器，这也为模式演进提供了一条清晰的路径。

其他值得注意的新功能和增强功能包括：

轮询消费者——此版本引入了轮询消费者，它允许应用程序控制消息处理速率。
Micrometer 支持——度量支持使用最新发布的Micrometer。
新的Actuator绑定控件——新的执行器绑定控件允许显示和控制绑定生命周期。
Actuator和Web现在是可选的——在选择Web框架时，为了“减少资源占用并提供更大的灵活性”，Spring Boot Actuator和Web都是可选的，默认不包含在框架当中。
增强对Apache Kafka Streams的支持——此版本包括增强对Kafka Streams和Kafka基于信道的绑定的支持，将多种Kafka Streams类型（如KStream和KTable）作为绑定组件，以及对交互式查询的支持。

有关Spring Cloud Stream 2.0正式版的更多信息可以在Spring工程博客文章“ Announcing General Availability of Spring Cloud Stream - Elmhurst.RELEASE (2.0.0.RELEASE) ”、 Spring Cloud Stream GitHub仓库和“快速入门指南”中看到。

查看英文原文： Spring Cloud Stream 2.0 Released with Focus on Performance, Flexibility and Consistency

原文 http://www.infoq.com/cn/news/2018/04/spring-cloud-stream-2.0

正文到此结束