使用OkHttpClient实现WebSocket时多响应合并问题求助

这种情况是否常见？ #

很常见，核心原因分为两类：

• 服务端开启了TCP Nagle算法，会把小批量数据合并成单个TCP包发送，以此降低网络开销；
• 服务端未按WebSocket规范拆分帧，直接将多条业务消息打包进同一个文本帧返回。

解决方案 #

1. 客户端侧拆分合并消息（推荐，无需修改服务端） #

和服务端约定统一的消息分隔符（比如\n、\r\n或自定义标识），客户端收到文本后缓存内容，再按分隔符拆分出单条完整消息：

private val messageBuffer = StringBuilder()
// 和服务端预先约定的消息分隔符
private const val MESSAGE_DELIMITER = "\n"

override fun onMessage(webSocket: WebSocket, text: String) {
    messageBuffer.append(text)
    var delimiterPos: Int
    // 循环拆分所有已接收的完整消息
    while (messageBuffer.indexOf(MESSAGE_DELIMITER).also { delimiterPos = it } != -1) {
        val singleMsg = messageBuffer.substring(0, delimiterPos)
        // 执行单条消息的业务处理逻辑
        processSingleMessage(singleMsg)
        // 移除已处理的消息及分隔符
        messageBuffer.delete(0, delimiterPos + MESSAGE_DELIMITER.length)
    }
}

private fun processSingleMessage(msg: String) {
    // 替换为你原本的消息处理代码
}

如果业务消息可能包含分隔符，需要改用更严谨的协议（比如带消息长度的头部），避免拆分出错。

2. 服务端侧调整发送策略 #

若有权限修改服务端：

• 关闭TCP Nagle算法（针对基于TCP的WebSocket连接）；
• 确保每条业务消息单独封装成一个WebSocket文本帧发送，避免批量打包。

3. 修正客户端断开连接的逻辑 #

你的代码中disconnect()直接关闭OkHttpClient的线程池，会影响该客户端实例的其他请求（若client为单例复用），正确的关闭方式应为：

override fun disconnect() {
    connected = false
    if (::webSocket.isInitialized) {
        webSocket.close(1000, "Normal closure")
    }
    // 除非确定不再复用该client实例，否则不要关闭executorService
}

其他推荐的WebSocket库 #

• Java-WebSocket：轻量级纯Java实现，API简洁，默认处理帧拆分，支持自定义协议；
• Jetty WebSocket Client：成熟的企业级库，对WebSocket规范支持全面，适合复杂业务场景；
• Ktor WebSocket：Kotlin生态专属，支持协程，与Ktor框架集成流畅，消息拆分处理友好。

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