如何在Spring Integration中将TCP出站网关扩展为只接收消息

Question

我正在开发一个web应用程序，通过Spring Integration支持TCP连接。它有两个功能。

null

null

因此，我认为协作TCP出站和入站通道适配器是困难的。然后，对TCP出站网关进行扩展，增加只接收消息的功能。我应该怎么延长？（还是你有其他想法？）

提前谢了。

Answer 1

如果您可以确定消息类型，类似这样的方法应该会起作用...

public class ExtendedTcpOutpboundGateway extends TcpOutboundGateway {

    private final MessageChannel unsolicitedMessageChannel;


    public ExtendedTcpOutpboundGateway(MessageChannel unsolicitedMessageChannel) {
        this.unsolicitedMessageChannel = unsolicitedMessageChannel;
    }

    @Override
    public boolean onMessage(Message<?> message) {
        if (isUnsolicitedMessage(message)) {
            this.messagingTemplate.send(this.unsolicitedMessageChannel, message);
            return false;
        }
        else {
            return super.onMessage(message);
        }
    }

    private boolean isUnsolicitedMessage(Message<?> message) {
        // TODO Add logic here to determine message type
        return false;
    }

}

如果不能区分，就不清楚如何实现您的需求。