Spring 用于 HTTP request/response 交换的 Cloud DataFlow
Spring Cloud DataFlow for HTTP request/response exchange
我想使用流来处理 HTTP request/response 交换。我没有看到任何具有 HTTP 接收器功能的 Spring Cloud Stream App Starters。我是否需要构建自定义接收器来处理响应？如果是这样，我是否通过我的处理管道传递请求，然后使用我的接收器中的请求来形成响应？我认为我没有误解 Spring Cloud DataFlow 和 Spring Cloud Stream 的用例。也许有适用于此模式的应用启动器。
Spring Cloud Stream/Dataflow 用于单向（流）处理；它不适用于 request/reply 处理。
但是，您可以使用来自 Spring 集成应用程序的流；例如，使用 rabbitmq 活页夹...
http-inbound-gateway -> amqp-outbound-gateway
出站网关配置为期望来自特定队列的回复，然后您的流可能...
:requestQueue > processor1 | ... | processorn > :replyQueue
Spring 集成目前没有 Kafka 的出站网关。我打开了 an issue.
我想使用流来处理 HTTP request/response 交换。我没有看到任何具有 HTTP 接收器功能的 Spring Cloud Stream App Starters。我是否需要构建自定义接收器来处理响应？如果是这样，我是否通过我的处理管道传递请求，然后使用我的接收器中的请求来形成响应？我认为我没有误解 Spring Cloud DataFlow 和 Spring Cloud Stream 的用例。也许有适用于此模式的应用启动器。
Spring Cloud Stream/Dataflow 用于单向（流）处理；它不适用于 request/reply 处理。
但是，您可以使用来自 Spring 集成应用程序的流；例如，使用 rabbitmq 活页夹...
http-inbound-gateway -> amqp-outbound-gateway
出站网关配置为期望来自特定队列的回复，然后您的流可能...
:requestQueue > processor1 | ... | processorn > :replyQueue
Spring 集成目前没有 Kafka 的出站网关。我打开了 an issue.