我是 Spring 集成和 tcp ip 模块的新手，我需要一些帮助。

我正在构建一个简单的项目，我应该从一个端口读取数据，一个外部源(嵌入式系统)将一些原始数据推送到指定的端口地址(在这个例子中端口是 4321)

数据样本是这样的: $1,101,16,10,14,01,32,05,343N,0987E,000.0,301,0,A#$1,101,16,10,14,01,32,05,343N,0987E,000.0,301,0, A#

设备有数据就推送，一次发送甚至超过600个字符，

我想访问 portService 类和测试方法中的数据，我有一个分隔符 #，因为每条消息都以 # 结尾，我无法控制客户端数据(我无法更改数据格式，或者我无法将 \r\n 附加到它)

tcp 客户端服务器配置:

<beans xmlns="http://www.springframework.org/schema/beans"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xmlns:int="http://www.springframework.org/schema/integration"
xmlns:int-ip="http://www.springframework.org/schema/integration/ip"
xmlns:context="http://www.springframework.org/schema/context"
xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd
    http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context.xsd
    http://www.springframework.org/schema/integration http://www.springframework.org/schema/integration/spring-integration.xsd
    http://www.springframework.org/schema/integration/ip http://www.springframework.org/schema/integration/ip/spring-integration-ip.xsd">

<bean id="customSerializer" class="com.gerrydevstory.service.CustomSerializer" />

<int-ip:tcp-connection-factory id="serverConnectionFactory" 
    type="server" 
    host="localhost" 
    port="4321" 
    single-use="false"
    so-timeout="100000"
    using-nio="true"
    serializer="customSerializer"
    deserializer="customSerializer"/>

<int-ip:tcp-inbound-gateway id="gatewayCrLf"
    connection-factory="serverConnectionFactory" request-channel="loop" />

<int:channel id="loop" />

<int:service-activator input-channel="loop"
    ref="portService" method="test">
</int:service-activator>

自定义序列化器:

public class CustomSerializer extends ByteArraySingleTerminatorSerializer {

    public CustomSerializer() {
        super((byte) 0x03);
        System.out.println("In Custom Serializer...");
    }
}

端口服务:

@Component
public class PortService {

    public String test(final String input) {
        System.out.println("PortService :" + input);
        if ("FAIL".equals(input)) {
            throw new RuntimeException("Failure Demonstration");
        }
        return input + ":echo";
    }
}

我启用了日志记录跟踪:

控件将转到 CustomSerializer 而不是 PortService，我们将不胜感激任何帮助。

TRACE: org.springframework.web.context.support.XmlWebApplicationContext - Publishing event in WebApplicationContext for namespace 'appServlet-servlet': TcpConnectionOpenEvent [source=org.springframework.integration.ip.tcp.connection.TcpNioConnection@13c2d58], [factory=serverConnectionFactory, connectionId=xxx.xxxx.xx.xx:9226:4321:e63ea33e-a9e7-416a-bfd6-dc53d5de00c6] OPENED

TRACE: org.springframework.web.context.support.XmlWebApplicationContext - Publishing event in WebApplicationContext for namespace 'appServlet-servlet': TcpConnectionCloseEvent [source=org.springframework.integration.ip.tcp.connection.TcpNioConnection@13c2d58], [factory=serverConnectionFactory, connectionId=xxx.xxxx.xx.xx:9226:4321:e63ea33e-a9e7-416a-bfd6-dc53d5de00c6] CLOSED

TRACE: org.springframework.web.context.support.XmlWebApplicationContext - Publishing event in WebApplicationContext for namespace 'appServlet-servlet': TcpDeserializationExceptionEvent [source=com.gerrydevstory.service.CustomSerializer@4833ff0b, cause=java.io.IOException: Socket closed during message assembly]

当我尝试使用以下代码片段测试相同的东西时，它起作用了:

server = new ServerSocket(port);
int index = 0;
while (true) {
    System.out.println("Waiting for client request");
    Socket socket = server.accept();
    InputStream ois = socket.getInputStream();
    byte[] buf = new byte[1024];
    ois.read(buf);
    System.out.write(buf);

    System.out.println("Message Received: " + buf);
    socket.close();
    if (index++ > 5) {
        break;
    }
}
server.close();

最佳答案

由于数据是从嵌入式系统推送的，流是原始格式(字节数组)

ByteArrayRawSerializer 可以处理这种用例。

我添加了以下代码片段配置文件:

<bean id="byteArrayRawSerializer" class="org.springframework.integration.ip.tcp.serializer.ByteArrayRawSerializer" />

<int-ip:tcp-connection-factory id="serverConnectionFactory" 
    type="server" 
    host="localhost" 
    port="4321" 
    single-use="false"
    using-nio="false"
    so-timeout="300000"
    serializer="byteArrayRawSerializer"
    deserializer="byteArrayRawSerializer"
    />

解决了问题。

谢谢。

关于spring 集成 tcp 套接字正在立即关闭，我们在Stack Overflow上找到一个类似的问题： https://stackoverflow.com/questions/26399587/