PCF部署Spring Cloud DataFlow HTTP请求响应方案轮询仅半数时间收到响应

核心诱因 #

你遇到的交替超时问题是PCF环境默认配置与RabbitMQ消息分发规则共同作用的结果：

• PCF平台默认给SCDF流的每个组件启动2个实例实现高可用，你部署的POC流中rabbitSource组件存在2个消费者实例同时监听rabbitSource队列
• RabbitMQ队列默认采用轮询分发策略，会将收到的请求消息依次分配给两个实例处理
• 你基于Spring Integration实现的HTTP请求/响应逻辑，仅能匹配其中一个实例处理的请求对应的响应消息，另一个实例处理的请求无法找到对应等待的请求上下文，因此触发超时，最终呈现成功-超时-成功-超时的交替现象
  本地运行时SCDF默认每个组件仅启动1个实例，所有消息都由同一个实例处理，因此不会触发该问题。

验证方法 #

1. 登录SCDF Shell执行命令查看流实例配置：
   stream info <你的POC流名称>
   确认rabbitSource组件的实例数是否为2。
2. 临时将rabbitSource组件实例数缩容为1：
   stream scale <你的POC流名称> --instance=1 --app=rabbitSource
   验证交替超时现象是否消失。

解决方案 #

如果仅做POC验证，保持rabbitSource单实例部署即可解决问题。如果需要保留多实例高可用能力，可选择以下任意一种方案：

• 修改Spring Integration请求/响应实现，将correlation ID的存储改为分布式缓存（如Redis），支持跨实例匹配请求与响应
• 调整RabbitMQ sink的路由规则，将响应消息路由回处理对应请求的源实例
• 给rabbitSource监听的队列配置排他属性，确保同一时间只有一个实例能消费队列消息

内容的提问来源于stack exchange，提问作者Wally Liu