Spring集成TCP服务器推送到客户端

Question

我需要实现一个TCP服务器，它基本上应该在与客户端握手时打开一个套接字。

套接字打开后服务器需要保持套接字打开，并且能够通过打开的套接字将消息从服务器推送到客户端

我查看了一些spring集成示例，但不确定我所看到的示例是否确实参考了我的需求。

1. Spring集成tcp是否有这种能力来保持打开套接字并将消息从服务器发送到客户端？

服务器还应支持传入请求

客户端实现是作为简单Tcp java客户端编写的模拟

谢谢！尼尔

此处上下文配置

<int-ip:tcp-connection-factory id="server"
                               type="server"
                               port="5679"
                               host="localhost"
                               single-use="false"
                               deserializer="javaDeserializer"
                               serializer="javaSerializer" />



<int-ip:tcp-inbound-channel-adapter id="inboundServer"
                                    channel="inloop"
                                    connection-factory="server" client-mode="false"/>

<int-ip:tcp-outbound-channel-adapter id="outboundServer"
                                     channel="outloop"
                                     connection-factory="server" client-mode="false"/>


<channel id="inloop"/>
<channel id="outloop"/>

在我使用的服务器端

outputchanel.send(new GenericMessage<String>("HI World from server16\n",header));

并在客户端读取推送消息

 BufferedReader stdIn = new BufferedReader(new InputStreamReader(socketClient.getInputStream()));
    while ((serverResponse = stdIn.readLine()) != null) {
      _logger.info("RESPONSE FROM SERVER::"+serverResponse);
    }

客户端是一个基于java的tcp客户端，未配置spring集成，这是一个用于将来集成的模拟客户端

为了支持echo服务器对字节数组不以“\n”终止的请求，我扩展了AbstractByteArraySerializer，并重写了反序列化

 public byte[] deserialize(InputStream inputStream) throws IOException {
    _Logger.trace("start deserialize");
    byte[] result;
    try {
        byte[] buffer = new byte[getMaxMessageSize()];
        int numOfBytes = inputStream.read(buffer, 0, buffer.length);

        result = copyToSizedArray(buffer, numOfBytes);
    } catch (IOException e) {
        _Logger.error("Exception on deserialize tcp inbound stream ", e);
        //publishEvent(e, , n);
        throw e;
    }
    return result;

}

Answer 1

您可以使用协作通道适配器在对等方之间进行完全任意的消息传递。

请参阅TCP事件。

当客户端连接时，tcp入站通道适配器（实际上是连接工厂）将发布TcpConnectionOpenEvent。

您可以使用Application ationListener来接收这些事件。

事件包含连接ID。然后，您可以开始向tcp出站通道适配器发送消息，消息头中名为ip\U connectionId（IpHeaders.CONNECTION\U ID）。

入站适配器从客户端接收的入站消息（如果有）在标头中具有相同的值。

只需配置服务器连接工厂并配置两个适配器即可使用它。

如果服务器必须打开套接字，请使用client-mode="true"并注入客户端连接工厂。