Spring Integration - IP -接收多个响应

@Configuration
@EnableIntegration
public class IntegrationConfig {

    @Bean
    public TcpNetClientConnectionFactory clientConnectionFactory() {
        TcpNetClientConnectionFactory factory = new TcpNetClientConnectionFactory("localhost", 1234);
        factory.setSingleUse(true);
        return factory;
    }

    @Bean
    public MessageChannel outputChannel() {
        return new DirectChannel();
    }

    @Bean
    public IntegrationFlow clientFlow() {
        return IntegrationFlows.from(outputChannel())
                .handle(Tcp.outboundGateway(clientConnectionFactory()))
                .get();
    }

    @Bean
    public TcpNetServerConnectionFactory serverConnectionFactory() {
        TcpNetServerConnectionFactory factory = new TcpNetServerConnectionFactory(1234);
        return factory;
    }

    @Bean
    public IntegrationFlow serverFlow() {
        return IntegrationFlows.from(Tcp.inboundGateway(serverConnectionFactory()))
                .handle(message -> {
                    String response = "Response for: " + message.getPayload();
                    return response;
                })
                .get();
    }
}