Spring Integration-动态TCP工厂和通道连接

Answer 1

请参见为ftp出站适配器执行此操作的dynamic-ftp示例。

本质上，它使用自定义路由器按需为适配器创建新的应用程序上下文。

另外，请参阅这个答案，其中有关于在邮件适配器的入站端执行类似操作的其他答案的链接，这一次使用Java配置。

对于正常的请求/应答处理，使用入站网关，框架将负责将服务激活器应答路由到正确的套接字。它通过使用连接id标头来实现这一点。

如果您需要提供任意的答复（例如，对一条消息进行多个答复，则必须使用入站和出站通道适配器，并且您的应用程序负责设置连接id标头。

有两种方法可以访问由服务激活器调用的POJO中所需的标头：

public void foo(byte[] payload, @Header(IpHeaders.CONNECTION_ID) String connectionId) {
    ...
}

public void foo(Message<byte[]> message) {
    String connectionId = message.getHeaders().get(...);
}