我有使用 Spring Integration 构建的 TCP 网关。我的服务器能够处理来自客户端的请求并发送响应。但是客户端给出了 SocketException

java.net.SocketException: Connection reset
    at java.net.SocketInputStream.read(SocketInputStream.java:168)
    at sun.nio.cs.StreamDecoder.readBytes(StreamDecoder.java:264)
    at sun.nio.cs.StreamDecoder.implRead(StreamDecoder.java:306)
    at sun.nio.cs.StreamDecoder.read(StreamDecoder.java:158)
    at sun.nio.cs.StreamDecoder.read0(StreamDecoder.java:107)
    at sun.nio.cs.StreamDecoder.read(StreamDecoder.java:93)
    at java.io.InputStreamReader.read(InputStreamReader.java:151)

似乎服务器在客户端读取所有数据之前关闭了连接。因此我想使用 so-linger。

setSoLinger 应该在延迟时间内保持服务器套接字打开。 setSoLinger 的 javadoc 表示启用/禁用 SO_LINGER 并指定延迟时间(以秒为单位)。

参见 https://docs.oracle.com/javase/6/docs/api/java/net/Socket.html#setSoLinger%28boolean,%20int%29

参见 Spring Integration document用于设置 SoLinger。

我的 spring context.xml :

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

        <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"/>

我不确定 Spring 集成是否需要以秒或毫秒为单位的延迟时间。是否有任何其他标志要设置，以便服务器套接字保持打开状态，直到客户端读取数据。

我几乎立即看到 Socket 连接关闭事件从服务 bean 发送响应。服务器似乎没有等待。请帮助如何设置逗留时间或建议替代方案。谢谢。

这是日志:

2016-06-01 15:43:46,276 MyService response:                 ACCEPT:E211001:

2016-06-01 15:43:46.293 DEBUG [pool-1-thread-2][org.springframework.context.support.GenericXmlApplicationContext] Publishing event in org.springframework.context.support.GenericXmlApplicationContext@7a187814: TcpConnectionCloseEvent [source=org.springframework.integration.ip.tcp.connection.TcpNetConnection@4c4b11e9], [factory=crLfServer, connectionId=22.220.220.222:1034:5678:77483643-2156-427f-96dd-a513670a75a3] **CLOSED**

2016-06-01 15:43:46.294 DEBUG [pool-1-thread-2][org.springframework.context.support.GenericXmlApplicationContext] Publishing event in org.springframework.context.support.GenericXmlApplicationContext@7a187814: TcpConnectionExceptionEvent [source=org.springframework.integration.ip.tcp.connection.TcpNetConnection@4c4b11e9, cause=java.net.SocketException: Socket is closed], [factory=crLfServer, connectionId=22.220.220.222:1034:5678:77483643-2156-427f-96dd-a513670a75a3]

最佳答案

Spring 集成不对值执行任何转换，因此它是秒。

您描述的行为听起来像 so-linger 是 0(立即为 close() 发送 RST)。

你真的不需要为了这个目的而流连忘返；未设置时，TCP 堆栈应优雅地关闭套接字。

您可能需要运行网络监视器来弄清楚发生了什么。

如果您信任您的客户端关闭套接字，您可以删除

single-use="true"

或将其设置为 false，以便服务器在发送回复后不会关闭套接字。

关于java - 如何使用so-linger保持服务器连接一段时间，我们在Stack Overflow上找到一个类似的问题： https://stackoverflow.com/questions/37577969/