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

这些项目的工件可在Spring Milestone存储库中获取。

请参阅每个参考手册中的“新增功能”章节，以了解有关下面提到的每个项目的新的功能和显著更改的更多信息。

Spring AMQP

2.1.0.RC1发行说明。

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

适用于Apache Kafka的Spring

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)`的结果以及与`Mono.delay(duration)`的组合将所有轮询选项转换为基于`Flux.generate()`的响应式轮询功能。

• 其他Java DSL更改

我们还为Java DSL添加了一些其他方便的运算符，例如`nullChannel()`和`logAndReply()`。

最后，Java DSL已改进，可在不破坏常规Java配置的情况下改善Kotlin体验。

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

适用于Apache Kafka的Spring集成扩展

3.1.0.RC1发行说明。

基于上面提到的适用于Apache Kafka的Spring `2.2.0.RC1`和Spring Integration `5.1.0.RC1`，提供了一些兼容性修复（特别是与Kotlin相关的）和一些次要功能，例如`KafkaInboundGateway`和`KafkaMessageDrivenChannelAdapter`的`onPartitionsAssignedSeekCallback`。

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

欢迎反馈！

请尝试所有这些新功能，并通过任何可用渠道向我们提供反馈。在10月中旬发布Spring Boot `2.1 GA`之前，我们将非常感谢您的帮助！

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

SpringOne Platform 2018

现在，我们将开启Spring和Pivotal世界中的一场盛大活动——Spring One Platform！Gary Russell将与来自Confluent的Viktor Gamov一起讨论适用于Apache Kafka的Spring，而我将与来自Google Cloud Platform的Kir Titievsky一起讨论适用于Google Cloud Pub/Sub的Spring Cloud Stream Binder。如果您在这里，请加入我们；或者稍后观看视频！