如何在 Spring 集成中实现此 TCP 流 reader？

Question

我想要一个 Spring 流 reader 的集成实现。另一个应用程序（在 java 之外）将数据流（由美元符号分隔）发送到端口 9999。此服务器 listens.

首先，我通过 telnet 127.0.0.1 9999.

连接到它来确保流正在流式传输

然后我使用以下方法创建了一个简单的 java 应用程序。目前正在运行。

public void readStream() throws IOException{
    Scanner s = null;
    try {
        Socket skt = new Socket("localhost", 9999);
        BufferedReader bufferedReader = new BufferedReader(
                new InputStreamReader(
                        skt.getInputStream()));
        s = new Scanner(bufferedReader);
        s.useDelimiter("[$]");
        System.out.println(s);
        while (s.hasNext()) {
            System.out.println("----------------------");
            System.out.println(s.next());
        }
    } finally {
        if (s != null) {
            s.close();
        }
    }
}

现在，我想在 Spring 集成框架中实现它。我看了https://github.com/spring-projects/spring-integration-samples/tree/master/basic/tcp-client-server and http://docs.spring.io/autorepo/docs/spring-integration/2.0.0.M3/spring-integration-reference/html/stream.html。但是我很困惑从哪里开始？连接到发送应用程序需要什么？（我真的是 Spring 框架的新手。）

对我来说困难在于术语。我应该创建一个 TCP 入站网关吗？还是接收通道适配器？还是出站是因为我在请求流？？

编辑在 Gary 的评论之后：

<bean class="org.springframework.integration.ip.tcp.serializer.ByteArraySingleTerminatorSerializer" id="deserializer1">
    <constructor-arg type="byte" value="$"/>
</bean>
<int-ip:tcp-connection-factory id="server" type="server" port="9999"
    deserializer="deserializer1"
/>
<int-ip:tcp-inbound-channel-adapter id="adapter" connection-factory="server" request-channel="channel1"/>
<int:channel id="channel1" />

Answer 1

当服务器发送对入站请求的回复时，使用入站网关。入站通道适配器 (<int-ip:tcp-inbound-channel-adapter) 仅用于单向集成 - 客户端仅发送数据，不接收回复。

您需要一个 server connection factory，配置为使用 ByteArraySingleTerminatorSerializer 配置了您的 $ 定界符，在 deserializer 属性.

请使用 latest documentation 而不是您问题中的旧版本。

如何在 Spring 集成中实现此 TCP 流 reader？

How to implement this TCP stream reader in Spring Integration?

java

streaming

spring

tcp

spring-integration