使用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();