使用Java DSL的Spring Integration动态TCP Server

使用Java DSL的Spring Integration动态TCP Server

您正在混合责任。在

Tcp.inboundAdapter()

必须在第一

IntegrationFlow

链。考虑改用此方法：

IntegrationFlow flow =     IntegrationFlows.from(Tcp.inboundAdapter(Tcp.netServer(2221)     .serializer(TcpCodecs.crlf())     .deserializer(TcpCodecs.lengthHeader1())     .id("server")))        .transform(Transformers.objectToString())        .get();