领先一步
VMware 提供培训和认证,助您加速进步。
了解更多我们很高兴地宣布发布 Spring Cloud Stream Horsham (3.0.0.RELEASE) 版本系列,该系列是 Spring Cloud Hoxton.RELEASE(即将发布)的一部分,并基于 Spring Boot 2.2.x 和 Spring Cloud Function 3.0.0.RELEASE 构建,后者也 刚刚发布。
Spring Cloud Stream Horsham.RELEASE 模块可在 Maven Central 仓库中使用。
正如在此公告之前的这些帖子(揭秘与简化、函数式与响应式、流与 Spring Integration 和 事件路由)中所提到的,本次发布的核心主题是函数!.
历史上,Spring Cloud Stream 暴露了一个基于注解的配置模型,它要求用户了解并提供大量的样板信息,而这些信息本可以轻松推断出来。您可以在 这里 阅读更多关于它的细节,但通过本次发布和随后的 Spring Cloud Functions 的发布,情况已经不再如此。
Stream 应用就是一个 Boot 应用!
@SpringBootApplication
public class SampleApplication {
@Bean
public Function<String, String> uppercase() {
return value -> value.toUpperCase();
}
}
是的,上面就是一个功能齐全的 Spring Cloud Stream 应用程序。
最显著的功能和增强在于我们对函数式编程模型的承诺;
路由函数 - 它有效地对应于 `@StreamListener` 注解的 `condition` 属性提供的功能(甚至更多)。有关更多详细信息,请参阅 事件路由。
函数的多重绑定(多个消息处理器)- 有关更多详细信息,请参阅 单个应用程序中的多个函数。
函数的元数(具有多个输入/输出的函数 - 可以订阅或指向多个目标的单个函数)- 有关更多详细信息,请参阅 具有多个输入和输出参数的函数。
对响应式编程的原生支持 - 自 v3.0.0 起,我们不再分发 spring-cloud-stream-reactive 模块,而是依赖 Spring Cloud Function 提供的原生响应式支持。为了向后兼容,您仍然可以引入先前版本的 spring-cloud-stream-reactive。
Schema Registry 模块已迁移到一个 独立项目。
有关更多信息,您还应该查看更新的 用户指南。
Kafka Streams 绑定器现在支持一流的基于函数的编程模型,您可以使用它基于 java.util.function 支持来编写 Kafka Streams 应用程序。这进一步减少了应用程序需要编写的样板代码,并允许开发人员专注于手头的业务逻辑。有关更多详细信息,请访问 函数式风格 部分了解更多信息。Soby Chako(Spring Cloud Stream Kafka 绑定器的负责人)正计划撰写一系列专门的文章来介绍所有新功能。
一如既往,我们欢迎反馈和贡献,请通过 Stackoverflow 或 GitHub 以及 Gitter 与我们联系。