TCP Socket 连接 - 即使在通过 ByteArrayLengthHeaderSerializer 序列化后也无法读取从外部客户端发送的数据

Question

我已经实现了 TCP 套接字服务器，它接受来自客户端的传入 XML 消息。我可以通过 telnet 发送消息。

但是当我尝试通过 python 脚本建立连接并发送消息时，我得到 IOException:CRLF not found before max message length: 2048.所以我添加了 ByteArrayLengthHeaderSerializer 来序列化和反序列化，但现在我得到以下错误.

IOException：消息长度 1014132591 超过最大消息长度：2048

虽然我增加了最大消息长度，但我得到 IOException:Stream closed after 46 of 1014132591

谁能告诉我如何解决这个问题。

final AbstractServerConnectionFactory crLfServer = context.getBean(AbstractServerConnectionFactory.class);
 ByteArrayLengthHeaderSerializer serializer = new ByteArrayLengthHeaderSerializer();
    serializer.setMaxMessageSize(1000 * 1024);
    crLfServer.setSerializer(serializer);
    crLfServer.setDeserializer(serializer);
    
    

我已经使用 Spring Integration 实现了。下面是我的入站适配器的 sn-p

@Bean
public TcpReceivingChannelAdapter inboundAdapter(AbstractServerConnectionFactory connectionFactory) {
    System.out.println("Creating inbound adapter");
    TcpReceivingChannelAdapter inbound = new TcpReceivingChannelAdapter();

    inbound.setConnectionFactory(connectionFactory);
    //inbound.
    inbound.setOutputChannel(fromTcp());
  

    return inbound;
}

Answer 1

我认为在消息之后在您的脚本中准确发送该 CRLF 可能会更好。这将是要反序列化的消息的确切分隔符。这是上面提到的 Telnet 使用的一种。但是，您需要回到连接工厂配置中的默认解串器。