Spring 集成 - 需要来自 Web 服务网关的即时响应，并在后端进行异步处理

Question

我们有一个要求，外部客户端正在调用我们的 Spring 集成入站 Web 服务网关之一，我们需要立即以一般的 OK 状态确认它们。同时，payload会被提交到一个channel进行异步处理，我们不需要response（根据一些业务验证发送email）。

我们尝试使用异步网关和执行器通道（带有任务执行器），但无法弄清楚如何使网关立即响应。在这两种情况下，它都作为单向 Web 服务运行，没有响​​应。

配置：

<context:component-scan base-package="com.myapp.springintegration" />



<channel id="helloWorldRequestChannel">
    <dispatcher task-executor="taskExecutor"/>
</channel>
<channel id="helloWorldReplyChannel"/>

<task:executor id="taskExecutor" pool-size="2"/>

<gateway id="helloServiceGateway" 
 service-interface="com.myapp.springintegration.HelloService"
 default-request-channel="helloWorldRequestChannel" default-reply-channel="helloWorldReplyChannel"/>

 <service-activator input-channel="helloWorldRequestChannel" ref="helloServiceImpl" method="hello" />

Answer 1

我没有看到任何<int-ws:inbound-gateway>，但要求可以这样实现：

<int-ws:inbound-gateway request-channel="requestChannel"/>

<int:recipient-list-router input-channel="requestChannel">
    <int:recipient channel="response" />
    <int:recipient channel="process" />
</int:recipient-list-router>

<int:transformer input-channel="response" expression="'OK'"/>

<int:channel id="process">
   <int:dispatcher task-executor="testExecutor"/>
</int:channel>

您向recipient-list-router 发送请求，该recipient-list-router 将您的消息分发到另外两个渠道。第一个（response）只是立即向 WS 返回简单的回复。第二个 (process) 将消息转移到单独的 Thread，因此该频道的订阅者将在不阻塞 WS Thread 的情况下完成其工作。

希望我清楚。