spring - 集成 TCP 网关，连接和接收来自 Socket 的数据

Question

我正在尝试在 Spring 集成中实现 TCP 客户端。我有一个远程 TCP 服务器，它将数据泵入一个套接字。我的基于 Spring 的 TCP 客户端必须从该套接字接收数据。

作为客户端，我不会从我这边向服务器发送任何数据，只是连接和接收数据。看着这个http://forum.spring.io/forum/spring-projects/integration/94696-want-to-configure-simple-tcp-client-to-receive-data-from-java-based-tcp-server?view=thread，我明白这是不可能的。但是，收到的答案已经很老了，现在有什么可用的配置吗？

如果您还有其他问题，请告诉我。

@更新配置

<bean id="javaSerializer" class="org.springframework.core.serializer.DefaultSerializer" />
<bean id="javaDeserializer" class="org.springframework.core.serializer.DefaultDeserializer" />

<context:property-placeholder />

<!-- Client side -->

<int:gateway id="gw"
    service-interface="com.my.client.SimpleGateway"
    default-request-channel="input" default-reply-channel="replies" />

<int-ip:tcp-connection-factory id="client"
    type="client" host="localhost" port="5678"
    single-use="false" so-timeout="10000" serializer="javaSerializer"
    deserializer="javaDeserializer" so-keep-alive="true"/>

<int:channel id="input" />

<int:channel id="replies">
    <int:queue />
</int:channel>

<!-- <int-ip:tcp-outbound-gateway id="outGateway" request-channel="input" 
    reply-channel="reply" connection-factory="client" request-timeout="10000" 
    reply-timeout="10000" /> -->

<int-ip:tcp-outbound-channel-adapter
    id="outboundClient" channel="input" connection-factory="client" />

<int-ip:tcp-inbound-channel-adapter
    id="inboundClient" channel="replies" connection-factory="client"
    client-mode="true" retry-interval="10000" auto-startup="true" />

这是我的远程 TCP 客户端：

    final GenericXmlApplicationContext context = new GenericXmlApplicationContext();
    context.load("classpath:config.xml");

    context.registerShutdownHook();
    context.refresh();

    final SimpleGateway gateway = context.getBean(SimpleGateway.class);
    int i=0;
    while(i++<10){
    String h = gateway.receive();
    System.out.println(System.currentTimeMillis()+h);

我的 TCP 模拟服务器：

while(true) {
     try {
        System.out.println("Waiting for client on port " +
        serverSocket.getLocalPort() + "...");

        Socket server = serverSocket.accept();
        System.out.println("Just connected to "
              + server.getRemoteSocketAddress());

        DataOutputStream out =
             new DataOutputStream(server.getOutputStream());
        out.write("ACK\r\n".getBytes());

        out.flush();

       //server.close();

     } catch(SocketTimeoutException s) {
        System.out.println("Socket timed out!");
        break;
     } catch(IOException e) {
        e.printStackTrace();
        break;
     } 
  }

我的网关类：

public interface SimpleGateway {    
    public String receive();
}

Answer 1

TcpReceivingChannelAdapter (<ip:tcp-inbound-channel-adapter/>) 通常在服务器模式下运行 - 它在套接字上侦听到客户端的传入连接。

然而，为这个用例添加了一个 clientMode (client-mode) 布尔值。它将连接到服务器并接收来自它的传入数据。如果连接丢失，它将重试连接（根据配置计划）。

见the documentation:

通常，入站适配器使用 type="server" 连接工厂，它侦听传入的连接请求。在某些情况下，需要反向建立连接，即入站适配器连接到外部服务器，然后等待该连接上的入站消息。

在入站适配器上使用 client-mode="true" 支持此拓扑。在这种情况下，连接工厂的类型必须为 client，并且必须将 single-use 设置为 false。

两个附加属性用于支持此机制：retry-interval 指定（以毫秒为单位）框架在连接失败后尝试重新连接的频率。 scheduler 用于提供一个 TaskScheduler，用于安排连接尝试，并测试连接是否仍处于活动状态。

如果未提供调度程序，则使用默认的taskScheduler bean。