本文是探讨基于 Java 函数重新设计的 Spring Cloud Stream 应用程序的系列博客文章的一部分。本集分为两部分，探讨了用于实现流应用程序的函数的测试策略。我们将特别关注与外部资源集成的函数，这会带来额外的测试挑战。大多数预打包的源和接收器应用程序都属于这种情况。为了说明这一点，我们将详细介绍一个示例 couchbase-sink 应用程序。在第 1 部分中，我们将重点介绍接收器所基于的核心函数……

这是测试流应用程序的第 2 部分。在第 1 部分中，我们实现了并测试了示例 couchbase-sink 应用程序所需的核心功能。函数级别的测试涵盖了预期的成功和错误场景，并依赖 Testcontainers 来配置 Couchbase 集群。本文假设您已阅读第 1 部分，并从第 1 部分结束的地方继续。

Couchbase 接收器

在第 1 部分中，我们验证了为将数据插入 Couchbase 而编写的函数按预期工作。我们现在可以使用该函数（作为 java.util.Consumer 公开）来实现一个接收器，用于构建数据管道……

本文是探讨基于 Java 函数重新设计的 Spring Cloud Stream 应用程序的系列博客文章的一部分。在本章中，我们将探讨如何使用 Spring Cloud Stream 应用程序 和 Spring Cloud Data Flow 来实现一个非常常见的 ETL 用例：从远程服务摄取文件。具体来说，我们将研究如何从 S3、SFTP 和 FTP 摄取文件。

到目前为止，博客系列中包含的内容如下：

• 介绍基于函数的流应用程序

• 流应用程序中的函数组合

• 如何构建供应商和源应用程序

• 如何构建消费者和接收器应用程序

• 构建并运行一个简单的流应用程序

• 案例研究：HTTP 请求函数和处理器

• 案例研究：文件源和 MongoDB 接收器

• 案例研究：关系数据库源和文件接收器

…

简介

我们以介绍基于 Java 函数的新流应用程序和函数组合来开始本系列。之前的文章提供了一个构建简单流应用程序并在 Spring Cloud Data Flow 中运行的教程。今天，我们将探讨 HTTP 请求函数，并提供如何使用它的示例。

如果您错过了，本系列之前的文章有：

• 介绍基于函数的流应用程序

• 流应用程序中的函数组合

• 如何构建供应商和源应用程序

• 如何构建消费者和接收器应用程序

• 构建并运行一个简单的流应用程序

…

简介

到目前为止，在本系列中，我们已经介绍了基于 Java 函数的新流应用程序以及函数组合。我们还提供了如何从供应商构建源以及从消费者构建接收器的详细示例。在这里，我们继续接下来的几个案例研究中的第一个。每个案例研究都演示了如何在各种场景中使用一个或多个可用的预打包 Spring Boot 流应用程序来构建数据流管道。

今天，我们将展示两个最常用的应用程序，HTTP 源和 JDBC 接收器。我们将使用它们来构建一个简单的服务，该服务接受 HTTP POST 请求并将内容保存到数据库表中。我们首先将它们作为独立的 Spring Cloud Stream 应用程序运行，然后展示如何使用 Spring Cloud Data Flow 协调相同的管道……

介绍 Spring Cloud Stream 应用程序的 Java 函数 - 第 1 部分

上周我们发布了介绍 Spring Cloud Stream 应用程序的 Java 函数 - 第 0 部分
以宣布 Spring Cloud Stream 应用程序 2020.0.0-M2 的发布。
在这里，我们探讨了函数组合，这是第 0 部分中介绍的面向函数架构所启用的更强大功能之一。如果您还没有机会阅读第 0 部分，现在正是时候！

函数组合

函数组合在数学和计算机科学中拥有坚实的理论基础。
实际上，它是一种……

我们很高兴地宣布 Spring Cloud Stream 应用程序 2020.0.0-M2 发布。此版本是对旧版 Spring Cloud Stream App Starters 的全面改版。从这个版本开始，我们放弃了以主题为导向的版本列车名称（按字母顺序排列的著名科学家），转而采用基于日历的版本控制。当前的 GA 版本称为 Einstein，我们很高兴推出 2020.0.0-M2。我们也在摆脱应用程序启动器。在重组、重新打包并（在某些情况下）重写了底层代码之后，我们现在有了一个新的 Git 仓库：spring-cloud/stream…

本文旨在向 Java 开发人员介绍 Groovy Bean Builder，作为 Java @Configuration 和 XML 配置的强大替代或补充。Spring Framework 4.0 版本包含 Grails Bean Builder 移植到核心 Spring Framework 的内容，为配置 Spring 应用程序提供了 Groovy DSL。Groovy 和 Grails 开发人员无疑熟悉这种配置 Spring 应用程序的方式，我预计其他人已经开始想“这有多酷？”

如果您不是 Groovy 专家，请不要担心。就像许多 Java 程序员使用另一个流行的 Groovy DSL Gradle 来构建应用程序一样，您只需要了解一些基本语法即可开始。示例代码可在 github 上找到……

我很高兴地宣布 Spring Data GemFire 1.3.0 的 GA 版本发布。除了许多小的错误修复和增强之外，此版本还包含一些值得注意的新功能，使使用 GemFire 编写 Java 应用程序变得更加容易

函数注解支持

简化与 GemFire 数据源的连接

 <gfe-data:datasource>
        <gfe-data:locator host="${host}" port="${port}"/>
 </gfe-data:datasource>

上述配置将创建一个客户端缓存、池以及服务器上所有可用区域的代理客户端区域，并提供合理的默认值，并将它们注册为 Spring bean。

JSON 支持

Spring Integration 使用 Spring 编程模型实现企业集成模式，以在基于 Spring 的应用程序中启用消息传递。Spring Integration 还通过支持 jms、http、amqp、tcp、ftp(s)、smtp 等的声明式适配器提供与外部系统的集成。目前，消息流的配置主要通过 Spring XML 完成，Spring Integration 支持多个命名空间以使其尽可能简洁。今年早些时候，SpringSource 发布了 Spring Integration 的 Scala DSL。现在，我们很高兴地宣布第一个里程碑版本……