使用Spring integration将请求从服务器发送到客户机

Question

我试图实现一个tcp客户端，它将使用spring Integration连接到现有的服务器。对于这项技术还是新手，我已经在https://github.com/spring-projects/spring-integration-samples上学习了spring示例。

<int-ip:tcp-connection-factory id="client"
                               type="client"
                               host="localhost"
                               port="12345"
                               single-use="false"
                               so-timeout="10000"
                               deserializer="javaSerializerDeserializer"
                               serializer="javaSerializerDeserializer" />
<bean id="javaSerializerDeserializer"
      class="org.springframework.integration.ip.tcp.serializer.ByteArrayLfSerializer" />

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

<int:object-to-string-transformer id="clientBytes2String"
                                  input-channel="clientBytes2StringChannel" />

<int:service-activator input-channel="clientBytes2StringChannel" ref="thinclientService" />
<bean id="thinclientService" class="tcp.service.ThinClientService" />

@Component
public class ThinClientService {
    private static final Logger LOGGER = LoggerFactory.getLogger(ThinClientService.class);

    public String receive(String recv) {
        LOGGER.info("*****************Recv: {}", recv);
        return "echo";
    }
}

主要方法：

@SpringBootApplication
public class Application {
    public static void main(String args[]) throws Exception {
            GenericXmlApplicationContext context = new GenericXmlApplicationContext();
        context.load("classpath:META-INF/beans.xml");
        context.registerShutdownHook();
        context.refresh();

        System.out.println("Running test");

        SpringApplication.run(Application.class, args);
    }
}

如何强制此客户端连接到我的服务器，即使我不想发送数据？

Answer 1

我自己想办法弄明白了。我必须用client-mode=“true”将tcp-outbound-gateway更改为tcp-inbound-gateway。只有到那时，服务激活器才会接收从服务器发送的消息。

更新bean配置：

<int-ip:tcp-connection-factory id="client"
                               type="client"
                               host="localhost"
                               port="12345" single-use="false" so-timeout="10000" deserializer="javaSerializerDeserializer"
                               serializer="javaSerializerDeserializer" />
<bean id="javaSerializerDeserializer"
      class="org.springframework.integration.ip.tcp.serializer.ByteArrayLfSerializer" />

<int-ip:tcp-inbound-gateway id="outGateway"
                            request-channel="input"
                            connection-factory="client"
                            client-mode="true"
                            retry-interval="1000"
                            scheduler="reconnectScheduler" />

<bean id="reconnectScheduler" class="org.springframework.scheduling.concurrent.ThreadPoolTaskScheduler" />

<int:object-to-string-transformer id="clientBytes2String"
                                  input-channel="input" output-channel="responseString" />

<int:service-activator input-channel="responseString" ref="thinclientService" />
<bean id="thinclientService" class="tcp.service.ThinClientService" />