我代表 Spring Integration 团队，很高兴地宣布 第二个 Spring Integration 5.3 的里程碑版本。

此版本包含一些错误修复、大量新功能和改进，并且将在不久的将来被 Spring Boot 2.3 M2 采用。

可以从我们的 里程碑版本仓库 下载。

compile "org.springframework.integration:spring-integration-core:5.3.0.M2"

最重要的新功能包括

• 通过 IntegrationFlowExtension 实现，我们现在可以为 Spring Integration 编写自己的 Java DSL。它允许引入自定义或组合的 EIP 运算符。现有的 IntegrationComponentSpec 实现现在可以扩展以提供其他（缺失的？）选项。因此，现在可以在目标项目中实现任何自定义且可重用的 Java DSL 解决方案。

  public class CustomIntegrationFlowDefinition extends IntegrationFlowExtension {

  public CustomIntegrationFlowDefinition upperCaseAfterSplit() {
      return split()
              .transform("payload.toUpperCase()");
  }
  
  public CustomIntegrationFlowDefinition customAggregate(
                  Consumer<CustomAggregatorSpec> aggregator) {
      return register(new CustomAggregatorSpec(), aggregator);
  }
  

  }

  public class CustomAggregatorSpec extends AggregatorSpec {

  CustomAggregatorSpec() {
      outputProcessor(group ->
              group.getMessages()
                      .stream()
                      .map(Message::getPayload)
                      .map(String.class::cast)
                      .collect(Collectors.joining(", ")));
  }
  

  }

  @Bean public IntegrationFlow customFlowDefinition() { return new CustomIntegrationFlowDefinition() .log() .upperCaseAfterSplit() .channel("innerChannel") .customAggregate(customAggregatorSpec -> customAggregatorSpec.expireGroupsUponCompletion(true)) .logAndReply(); }

• HTTP 和 WebFlux 出站通道适配器现在支持 UriBuilderFactory.EncodingMode 选项，而不是以前的 encodeUri 布尔标志。

• AMQP 出站通道适配器具有一个新属性 multiSend，允许在一次 RabbitTemplate 调用范围内发送多条消息。

• AMQP 入站通道适配器现在支持带有 consumerBatchEnabled 属性设置为 true 的侦听器容器。

有关更多信息，请参阅 参考手册 中的“新增功能”。

下一个也是最后一个 M3 里程碑版本计划于 3 月发布，然后在 4 月进入 RC 阶段。预计将升级到最新的里程碑版本：Spring Data Neumann、Spring Security 5.3 等。

期待您的反馈！

项目页面 | GitHub 问题 | 贡献 | 帮助 | 聊天