在 TCP 网关中发送响应后，在 Spring Integration 中向 serviceActivator 发送消息

Question

我基于 TCP 网关构建的 Spring Integration 应用程序运行良好。它接收到 TCP 网关的请求消息并将消息转发给 serviceActivator 以准备响应，并将响应发送给客户端。

我想在发送给客户端后将消息保存到数据库。我只是想知道在将响应发送给客户端后是否可以将消息转发给另一个 serviceActivator。

如果是，应该如何设置弹簧配置？ 我将不胜感激这方面的任何帮助。

这里是spring上下文文件：

<beans>
    <int-ip:tcp-connection-factory id="crLfServer"
            type="server"
            port="${availableServerSocket}"
            single-use="true"
            so-timeout="10000"
            using-nio="false" 
            serializer="connectionSerializeDeserialize"
            deserializer="connectionSerializeDeserialize"
            />

        <bean id="connectionSerializeDeserialize" class="org.springframework.integration.ip.tcp.serializer.ByteArrayStxEtxSerializer"/>

        <int-ip:tcp-inbound-gateway id="gatewayCrLf"
            connection-factory="crLfServer"
            request-channel="serverBytes2StringChannel"
            error-channel="errorChannel"
            reply-timeout="10000"/> <!-- reply-timeout works on inbound-gateway -->

        <int:channel id="toSA" />

        <int:service-activator input-channel="toSA"
            ref="myService"
            method="prepare"/>

        <int:object-to-string-transformer id="serverBytes2String"
            input-channel="serverBytes2StringChannel"
            output-channel="toSA"/>

        <int:transformer id="errorHandler"
            input-channel="errorChannel"
            expression="payload.failedMessage.payload + ':' + payload.cause.message"/>
</beans>

谢谢

Answer 1

您可以为该<service-activator> 添加<publish-subscribe-channel> 作为output-channel。其中一位订阅者是<int-jdbc:outbound-channel-adapter>，用于存储对数据库的回复。另一个订阅者应该是<bridge>，没有output-channel，假设回复<int-ip:tcp-inbound-gateway>。

但是，是的，它是在发送给客户之前...

为此，您可以扩展Serializer 并在执行super.serialize() 之后使用byte[] 执行所需的逻辑。