具有spring集成的双向消息传递

Question

我对Spring集成相对较新，但我的任务是实现一个tcp网关，该网关需要：

• 在套接字上侦听消息

在我的Spring集成经验中，消息流不是双向的。我只将路由器配置为侦听、处理消息和输出到队列/主题。但是，在这种情况下，我需要接受消息并返回响应，同时将某些消息转发到队列。建议？

这是到目前为止我的集成xml。

<int:chain input-channel="tcpChannel">
    <int:service-activator ref="tcpHandler" method="handleInput" />
</int:chain>

<int-ip:tcp-inbound-gateway 
             id="tcpGateway"
             connection-factory="tcpServer" 
             request-channel="tcpChannel" />

如何将handleInput的输出转发到队列，同时从网关返回一些响应？

编辑：在与Gary进行以下对话后，这似乎是我们想要遵循的模式：

<int-ip:tcp-inbound-gateway id="tcpGateway"
                            connection-factory="tcpServer"
                            request-channel="tcpChannel"
                            reply-channel="tcpReplyChannel"/>

<int:publish-subscribe-channel id="tcpChannel" />

<int:chain input-channel="tcpChannel">
    <!-- int:json-to-object-transformer type="com.heb.revo.events.RxPosCredit" /-->
    <int:service-activator ref="tcpHandler" method="handleInputToQueue" />
    <jms:outbound-channel-adapter destination-name="${queue.response}" />
</int:chain>

<int:service-activator id="tcpResponseHandler"
                       ref="tcpHandler" method="replyToSocket"
                       input-channel="tcpChannel"
                       output-channel="tcpReplyChannel" />

<int:publish-subscribe-channel id="tcpReplyChannel" />

Answer 1

由于链没有输出通道，框架将把handleInput方法的返回值自动路由回网关。

如果要捕获结果并将其发送到其他地方（以及回复），请创建一个<代码>