SpringBoot IntegrationFlow Tcp.inboundGateway如何在客户端连接时发送消息

在Spring Integration TCP 5.5.14版本中，Tcp.inboundGateway属于请求响应模式，默认需等待客户端发起请求才会交互。要实现客户端一连接就主动推送消息，可通过以下两种方式实现：

方法一：基于连接事件监听实现 #

通过TcpConnectionListener监听连接建立事件，在事件触发时主动发送消息，搭配Tcp.inboundAdapter处理连接生命周期：

@Bean
public IntegrationFlow tcpServerFlow() {
    return IntegrationFlows.from(Tcp.inboundAdapter(Tcp.nioServer(socketPort)
                    .deserializer(SERIALIZER)
                    .serializer(SERIALIZER)
                    .connectionListener(connectionListener())))
            .channel("tcpInbound")
            .get();
}

@Bean
public TcpConnectionListener connectionListener() {
    return new TcpConnectionListener() {
        @Override
        public void onOpen(TcpConnection connection) {
            // 连接建立时发送欢迎消息
            String welcomeMsg = "欢迎连接到TCP服务器！";
            connection.send(MessageBuilder.withPayload(welcomeMsg).build());
        }

        @Override
        public void onClose(TcpConnection connection) {
            // 连接关闭时的自定义处理（可选）
        }

        @Override
        public void onException(TcpConnection connection, Exception ex) {
            // 连接异常时的自定义处理（可选）
        }
    };
}

方法二：自定义TcpSocketSupport（适配原InboundGateway配置） #

如果需要保留Tcp.inboundGateway的请求响应能力，可自定义TcpSocketSupport，在连接建立后直接通过Socket输出流发送消息：

@Bean
public IntegrationFlow server() {
    return IntegrationFlows.from(
            Tcp.inboundGateway(
                    Tcp.nioServer(socketPort)
                            .deserializer(SERIALIZER)
                            .serializer(SERIALIZER)
                            .tcpSocketSupport(new CustomTcpSocketSupport())
            )
    )
            .channel("tcpInbound")
            .get();
}

class CustomTcpSocketSupport extends DefaultTcpSocketSupport {
    @Override
    public void postProcessSocket(Socket socket, boolean server) {
        super.postProcessSocket(socket, server);
        if (server) {
            try {
                OutputStream outputStream = socket.getOutputStream();
                String welcomeMsg = "已成功连接服务器！";
                // 用配置好的序列化器处理消息，保证和客户端格式兼容
                SERIALIZER.serialize(MessageBuilder.withPayload(welcomeMsg).build(), outputStream);
                outputStream.flush();
            } catch (IOException e) {
                e.printStackTrace();
            }
        }
    }
}

关键注意点 #

• 确保你的SERIALIZER序列化器和客户端的反序列化器格式完全匹配，否则消息无法被正确解析。
• 使用TcpConnection.send()方法会自动复用配置的序列化器，比直接操作Socket输出流更安全、更符合框架规范。
• 基于Tcp.inboundGateway的方案中，主动推送的消息不会触发网关的请求响应逻辑，后续客户端发送的请求仍会正常处理。

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