基于Spring Integration实现后台轮询HTTP请求状态的方案咨询

我正尝试构建基于Spring Integration的架构，系统需通过多种协议与其他系统交互。其中一个系统提供REST端点处理长运行任务，我希望使用Spring Integration HTTP outbound组件提交任务（如调用POST /api/job/submit并携带requestId），随后从另一个端点（如GET /api/job/{request-id}/result）轮询任务结果。

注：任务为长运行类型，结果不会立即返回

我希望将从提交任务到获取结果的功能封装为单个函数，返回包含JobResult的Future对象。我的实现思路如下：

public Future<JobResult> executeJob(JobInput input) {
    // call the job submission endpoint using Http Outbound component or RestTemplate
    // get the result of this submission and confirm it is Http 200 
    // using the request id, kick off the task of checking the job result to an executor service. (instance of JobChecker)
    // return the future from the submitted callable.

}

class JobChecker implements Callable<JobResult> { 
      @Override
      public JobResult call() throws Exception {
        while(true) {
           // using rest template or another HTTP outbound channel check if the result of requestId is available 
        }
      }
}

请问应使用Spring Integration的哪些组件组合来实现该需求？在打造生产级健壮方案时，我是否遗漏了错误处理、路由、可靠交付及操作幂等性相关的要点？

• HTTP Outbound Gateway：替代RestTemplate完成任务提交和结果轮询的HTTP调用，它天然适配Spring Integration的消息通道模型，能更好地融入整体架构，无需手动管理HTTP连接细节。
• Message Channel：用DirectChannel处理任务提交的同步流程，用QueueChannel配合ThreadPoolTaskExecutor实现轮询任务的异步执行，避免阻塞主线程。
• Poller：用Spring Integration原生的Poller组件替代手动while(true)循环，可灵活配置轮询间隔、最大重试次数、超时时间等参数，比自定义循环更可控、更易维护。
• Service Activator：将任务提交、结果校验逻辑封装为服务激活器，作为消息流的处理节点，降低代码耦合度，便于后续扩展。
• Async Gateway：如果需要对外暴露返回Future的接口，可使用Spring Integration的异步网关，它能自动将同步消息流转为异步Future返回，无需手动管理ExecutorService和Callable。

错误处理 #

• HTTP调用异常兜底：为HTTP Outbound Gateway配置ExpressionEvaluatingRequestHandlerAdvice，针对不同HTTP状态码做差异化处理：比如5xx服务异常触发重试，4xx非法请求直接抛出业务异常，连接超时则触发降级逻辑。
• 轮询终止机制：必须为轮询逻辑设置最大超时时间和重试次数，避免无限循环；轮询过程中遇到服务宕机等致命异常时，需主动终止任务并将错误传递到Future，确保调用方能感知到失败。
• 异常链路追踪：确保异步轮询中的异常能完整传递，通过MDC将requestId绑定到线程上下文，实现提交到轮询的全链路日志追踪。

可靠交付与幂等性 #

• 任务提交幂等：提交任务时确保requestId全局唯一，同时要求目标服务支持基于requestId的幂等校验，防止因网络波动重试导致重复创建任务。
• 轮询任务持久化：将待轮询的requestId暂存到数据库或Redis，若系统重启或服务中断，可自动恢复未完成的轮询任务，避免任务丢失。
• 结果去重处理：获取到任务结果后，通过requestId记录处理状态，防止因重复轮询导致的结果重复消费。

其他优化点 #

• 负载均衡：若目标服务有多实例，为HTTP Outbound Gateway配置Spring Cloud LoadBalancer，实现请求的负载分发，避免单点压力过大。
• 动态轮询间隔：设置轮询间隔的动态调整策略，比如初始间隔10秒，每轮无结果则延长至20秒、30秒，减少对目标服务的无效请求压力。
• 资源管控：限制异步轮询的线程池大小，结合队列容量控制并发任务数，避免系统资源耗尽；同时监控线程池状态，及时调整配置。

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