CODEWITHSUNDEEP
socketsspring-boottcpspring-integration
merla
merla

Reputation: 679

TCP Socket connection- Unable to read data sent from external client even after serializing through ByteArrayLengthHeaderSerializer

I have implemented TCP socket server which accepts incoming XML messages from client. I could send messages through telnet.

But when I am trying to establish connection and send message through python script, I was getting IOException:CRLF not found before max message length: 2048.So I have added ByteArrayLengthHeaderSerializer to serialize and deserialize, but now I am getting below error.

IOException:Message length 1014132591 exceeds max message length: 2048

Though I am increasing the max message length I am getting IOException:Stream closed after 46 of 1014132591

Could someone let me know how to fix the issue.

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

I have implemented using Spring Integration.Below is the snippet for my inbound adapter

@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;
}

Upvotes: 0

Views: 658

Answers (1)

Artem Bilan
Artem Bilan

Reputation: 121550

I think might be better to send exactly that CRLF in your script after the message. That will be exactly delimiter for the messages to deserialize. This is one what is used by the mentioned Telnet. However you need to come back to the default deserializer in the connection factory configuration.

Upvotes: 1

Related Questions