Spring云数据流内部通信
Spring cloud data flow internal communication
尝试将 spring 云数据流用于数据管道，其中源从剩余流读取数据，接收器会将其保存到 Database.Currently 我使用 Spring 进行了 POC Webflux 获取流数据并保存到数据库，效果很好。尝试对 Spring 云数据流做同样的事情，并试图了解源/处理器/接收器究竟如何相互通信。在我的场景中，它是一个批处理/短期应用程序，它 运行 定期使用来自其余端点的数据。我查看了文档以了解源和接收器如何通信，但我找不到 any.So 在短期应用程序的情况下，源和接收器如何传输数据？我的理解是它们中的每一个 运行 在单独的 JVM 中，因此它们需要一种方法来 communicate/transfer 数据。
1）我的理解正确吗？
2) 是通过消息传递吗？
您的问题更笼统，因为它导致我们为什么要使用消息传递系统来进行流式传输应用程序。所以，请搜索为什么我们需要消息系统。
Spring Cloud Data Flow 利用 Spring Cloud Stream 用于 运行 流应用程序。 Spring Cloud Stream 提供活页夹实现以将您的事件 driven/streaming 应用程序绑定到消息传递系统（RabbitMQ、Apache Kafka 等）。
考虑到所有这些，它还取决于您在应用程序中需要什么。特别是，如果您没有分布式流应用程序，并且不一定需要生产者和消费者之间的松散耦合，则可以在不使用消息系统的情况下构建应用程序。
尝试将 spring 云数据流用于数据管道，其中源从剩余流读取数据，接收器会将其保存到 Database.Currently 我使用 Spring 进行了 POC Webflux 获取流数据并保存到数据库，效果很好。尝试对 Spring 云数据流做同样的事情，并试图了解源/处理器/接收器究竟如何相互通信。在我的场景中，它是一个批处理/短期应用程序，它 运行 定期使用来自其余端点的数据。我查看了文档以了解源和接收器如何通信，但我找不到 any.So 在短期应用程序的情况下，源和接收器如何传输数据？我的理解是它们中的每一个 运行 在单独的 JVM 中，因此它们需要一种方法来 communicate/transfer 数据。 1）我的理解正确吗？ 2) 是通过消息传递吗？
您的问题更笼统，因为它导致我们为什么要使用消息传递系统来进行流式传输应用程序。所以，请搜索为什么我们需要消息系统。
Spring Cloud Data Flow 利用 Spring Cloud Stream 用于 运行 流应用程序。 Spring Cloud Stream 提供活页夹实现以将您的事件 driven/streaming 应用程序绑定到消息传递系统（RabbitMQ、Apache Kafka 等）。
考虑到所有这些，它还取决于您在应用程序中需要什么。特别是，如果您没有分布式流应用程序，并且不一定需要生产者和消费者之间的松散耦合，则可以在不使用消息系统的情况下构建应用程序。