我们很高兴地宣布 Spring Cloud Stream Fishtown 发布列车（Fishtown.M2/2.1.0.M2）的第二个里程碑版本。

Spring Cloud Stream Fishtown 2.1.0.M2 可以在 Spring Milestone 仓库中使用。 发行说明 包含有关与 Spring Boot、Spring Cloud、Spring AMQP 和 Spring for Apache Kafka 版本兼容性的相关信息。

以下部分简要概述了此版本中包含的功能和改进。

值得注意的依赖项升级

• Spring Boot 2.1.0.M2（现在与 Spring Initializr 完全兼容）
• Reactor Californium M2

Spring Cloud Function 支持

此版本的主题是引入一种新的编程模型，该模型使用 Spring Cloud Function 作为定义流处理程序和源的替代方案，这些处理程序和源现在可以表示为 java.util.function.[Supplier/Function/Consumer] 类型的 bean。

要指定将哪个功能 bean 绑定到绑定公开的外部目标，必须提供 spring.cloud.stream.function.definition 属性。

以下是将消息处理程序作为 java.util.function.Function 公开的 Processor 应用程序示例

@SpringBootApplication
@EnableBinding(Processor.class)
public class MyFunctionBootApp {

	public static void main(String[] args) {
		SpringApplication.run(MyFunctionBootApp.class, 
                  "--spring.cloud.stream.function.definition=toUpperCase");
	}

	@Bean
	public Function<String, String> toUpperCase() {
		return s -> s.toUpperCase();
	}
}

在上面，我们只是定义了一个名为 toUpperCase 的 java.util.function.Function 类型的 bean，并将其标识为用作消息处理程序的 bean，其输入和输出将绑定到 Processor 绑定公开的外部目标。

函数组合

使用此编程模型，您还可以从函数组合中受益，在函数组合中，您可以从一组简单函数动态组合复杂的处理程序。例如，将以下函数 bean 添加到上面定义的应用程序中

@Bean
public Function<String, String> wrapInQuotes() {
	return s -> "\"" + s + "\"";
}

并修改 spring.cloud.stream.function.definition 属性以反映您希望从 toUpperCase 和 wrapInQuotes 组合新函数的意图。为此，Spring Cloud Function 允许您使用 |（管道）符号。因此，为了完成我们的示例，我们的属性现在将如下所示

--spring.cloud.stream.function.definition=toUpperCase|wrapInQuotes

其他值得注意的功能、改进和增强功能

核心

• 围绕多绑定场景的改进和增强

Rabbit 绑定器

• 支持自定义 消费者标签

Kafka 绑定器

• 将 Kafka 客户端升级到 2.0

质量改进

作为持续改进代码质量并评估框架组件的契约正确性的工作的一部分，我们有一个新的 验收测试项目，用于在 Cloud Foundry 和 Kubernetes 上引导 Spring Cloud Stream 应用程序。这些测试每天在全新铺设的环境中运行多次。我们希望这为社区和客户在目标平台上构建更多自动化管道奠定基础。

Kinesis 绑定器

在此版本中，我们还希望重点介绍最近发布的 Kinesis 绑定器

各种其他增强功能和错误修复：核心 Rabbit 绑定器 Kafka 绑定器

注意

如果应用程序是从 Spring Initializr 创建的，则需要在 spring-cloud BOM 声明之前在 maven 依赖项管理中添加此 BOM 代码段，否则最终将使用最新的快照（这可能是可以的，因为它将包含来自 M2 的所有工作）

<dependency>
           <groupId>org.springframework.cloud</groupId>
           <artifactId>spring-cloud-stream-dependencies</artifactId>
           <version>Fishtown.M2</version>
           <type>pom</type>
           <scope>import</scope>
</dependency>

后续步骤

计划于 9 月底发布 M3，它将主要包含新的绑定功能以及更多围绕支持 Spring Cloud Function 作为编程模型的功能和改进。

与往常一样，我们欢迎您的反馈和贡献，请通过 Stackoverflow 或 GitHub 或通过 Gitter 与我们联系。