如何使用Spring IP Integration TCP创建可接收超2048字符的客户端/服务端

Spring Integration TCP栈默认配置存在两个2048的长度限制，是长报文接收失败的核心原因：

• 内置的ByteArrayLfSerializer、ByteArrayLengthHeaderSerializer等默认序列化/解串器，默认最大允许报文长度为2048字节，超过阈值会直接抛出MaxMessageSizeExceededException
• 底层TCP连接工厂默认设置的Socket收发缓冲区大小为2048字节，内核层面就会对超过长度的报文做截断处理

1. 自定义大报文兼容的序列化/解串器 #

不管是客户端还是服务端，首先要替换默认的序列化/解串器，根据业务使用的报文边界规则（长度头、分隔符等）调整最大报文长度阈值，示例配置如下：

// 场景1：使用4字节长度头标识报文边界（生产环境最常用，无粘包拆包问题）
@Bean
public ByteArrayLengthHeaderSerializer largePayloadSerializer() {
    ByteArrayLengthHeaderSerializer serializer = new ByteArrayLengthHeaderSerializer();
    // 按业务实际需求设置最大报文长度，单位为字节，示例设置为10MB
    serializer.setMaxMessageSize(10 * 1024 * 1024);
    return serializer;
}

// 场景2：使用换行符作为报文结束标识
// @Bean
// public ByteArrayLfSerializer largePayloadLfSerializer() {
//     ByteArrayLfSerializer serializer = new ByteArrayLfSerializer();
//     serializer.setMaxMessageSize(10 * 1024 * 1024);
//     return serializer;
// }

2. 调整TCP连接工厂配置 #

服务端、客户端的连接工厂都需要绑定自定义序列化器，同时同步调整底层Socket缓冲区参数，和序列化器的最大长度匹配。

服务端连接工厂示例 #

@Bean
public TcpNetServerConnectionFactory tcpServerConnectionFactory() {
    TcpNetServerConnectionFactory factory = new TcpNetServerConnectionFactory(9876);
    // 绑定大报文序列化/解串器
    factory.setSerializer(largePayloadSerializer());
    factory.setDeserializer(largePayloadSerializer());
    // 调整Socket收发缓冲区大小，和序列化器最大报文长度保持一致
    factory.setSoReceiveBufferSize(10 * 1024 * 1024);
    factory.setSoSendBufferSize(10 * 1024 * 1024);
    // 长报文场景建议关闭Nagle算法，减少分片传输延迟
    factory.setSoTcpNoDelay(true);
    // 如果使用NIO模式的连接工厂，必须额外加这行配置，同步调整NIO缓冲区大小
    // factory.setNioBufferSize(10 * 1024 * 1024);
    return factory;
}

客户端连接工厂示例 #

@Bean
public TcpNetClientConnectionFactory tcpClientConnectionFactory() {
    TcpNetClientConnectionFactory factory = new TcpNetClientConnectionFactory("127.0.0.1", 9876);
    // 绑定大报文序列化/解串器
    factory.setSerializer(largePayloadSerializer());
    factory.setDeserializer(largePayloadSerializer());
    // 同步调整Socket缓冲区大小
    factory.setSoReceiveBufferSize(10 * 1024 * 1024);
    factory.setSoSendBufferSize(10 * 1024 * 1024);
    factory.setSoTcpNoDelay(true);
    // NIO模式同样需要设置nioBufferSize参数
    // factory.setNioBufferSize(10 * 1024 * 1024);
    return factory;
}

3. 消息通道适配（可选建议） #

如果长报文场景下消息生产速度大于消费速度，建议调整入站消息通道的队列容量，避免默认配置下的消息丢失：

@Bean
public MessageChannel tcpInboundChannel() {
    // 根据业务并发量调整队列容量即可，不建议使用无界队列避免OOM
    return new QueueChannel(200);
}

• 不建议用ByteArrayRawSerializer处理跨网络传输的长报文，该序列化器需要等到Socket连接关闭才会判定报文结束，长报文分片场景下会出现严重的粘包问题。
• maxMessageSize参数不要盲目设置过大，需要结合服务端堆内存容量评估，避免超大报文直接打满服务内存。

常见踩坑：只修改序列化器的maxMessageSize参数，没有同步调整Socket的soReceiveBufferSize和NIO缓冲区大小，会出现偶发的大报文截断、报文解析失败问题，三个缓冲区参数必须保持匹配。

内容的提问来源于stack exchange，提问作者kasse kasse