我代表 Spring Integration 团队高兴地宣布 Spring Messaging 项目的发布候选版本。每个版本都基于最近发布的 Spring Framework 5.1 GA，升级了依赖项，并将成为即将到来的 Spring Boot 2.1 M4 的一部分——正好赶上 Spring One Platform！

这些项目的构件可在 Spring Milestone 仓库中获取。

请参阅每个参考手册中的 What’s New 章节，了解以下提到的每个项目的新功能和重要变更。

Spring AMQP

2.1.0.RC1 发布说明。

项目页面 | GitHub | JIRA | 文档 | Stack Overflow | Gitter

Spring for Apache Kafka

2.2.0.RC1 发布说明。

项目页面 | GitHub | 问题 | 文档 | Stack Overflow | Gitter

Spring Integration

5.1.0.RC1 发布说明。

这里我想提及几个特性，因为它们尚未完全文档化（我们会在 GA 版本发布时完成）。

• Java DSL 的 fluxTransform() 操作符

为了将消息处理交给 Reactive Streams，Spring Integration 的 Java DSL 引入了一个中间操作符 fluxTransform()，例如：

IntegrationFlow integrationFlow = f -> f
    .split()
    .<String, String>fluxTransform(flux -> flux
                                .map(Message::getPayload
                                .map(String::toUpperCase))
    .aggregate();

这个操作符接受一个类型为 Function<? super Flux<Message<I>>, ? extends Publisher<O>> 的参数。框架会在调用此函数之前和之后注入 FluxMessageChannel。它会构建一个 Flux 来将请求消息存储到订阅者上下文中，使用提供的函数调用 Flux.transform()，如果函数的结果不是 Message<?> 类型，则会从请求消息复制消息头。

• 响应式轮询

另一个新特性是针对 SourcePollingChannelAdapter 的响应式轮询。如果输出通道是 FluxMessageChannel 的实例，框架会将所有轮询选项转换为基于 trigger.nextExecutionTime(triggerContext) 结果的 Flux.generate()，并结合 Mono.delay(duration) 来实现响应式轮询功能。

• 其他 Java DSL 变更

此外，我们还为 Java DSL 添加了其他几个方便的操作符，例如 nullChannel() 和 logAndReply()。

最后，改进了 Java DSL 以提供更好的 Kotlin 体验，同时不会对常规 Java 配置造成破坏性变更。

项目页面 | GitHub | JIRA | 文档 | Stack Overflow | Gitter

Spring for Apache Kafka 的 Spring Integration 扩展

3.1.0.RC1 发布说明。

基于上述提到的 Spring for Apache Kafka 2.2.0.RC1 和 Spring Integration 5.1.0.RC1，提供了一些兼容性修复（特别是与 Kotlin 的兼容性）和一些小功能，例如为 KafkaInboundGateway 和 KafkaMessageDrivenChannelAdapter 添加了 onPartitionsAssignedSeekCallback。

有关此扩展的更多信息，请参阅 Spring for Apache Kafka 的 参考手册。

欢迎反馈！

请试用这些新的版本，并通过任何可用渠道向我们反馈。我们非常感谢在 10 月中旬 GA 版本发布之前（正好赶上 Spring Boot 2.1 GA！）您提供的帮助！

感谢所有以各种方式为这些项目做出贡献的人！

SpringOne Platform 2018

现在我们即将迎来 Spring 和 Pivotal 世界的一项重要活动——Spring One Platform！Gary Russell 将与 Confluent 的 Viktor Gamov 一起探讨 Spring for Apache Kafka，而我将与 Google Cloud Platform 的 Kir Titievsky 一起分享 Spring Cloud Stream Binder for Google Cloud Pub/Sub。如果您在现场，请加入我们；如果不在，请稍后观看视频！