Kotlin Socket连接耗时久的原因及优化方案咨询

可能的原因 #

1. 未设置Socket超时：Java原生Socket默认无连接超时和读取超时，若服务器响应不及时或网络异常，会一直阻塞等待，这是导致长时间耗时的核心原因。Python的Socket通常有默认超时或底层处理更严格，不会无限等待。
2. 字符编码不匹配：InputStreamReader和PrintWriter默认使用系统编码，若与服务器编码不一致，可能导致数据解析异常，readLine()会因无法识别行结束符而持续阻塞。
3. 不必要的协程包裹：当前代码用runBlocking+launch包裹同步阻塞的Socket操作，不仅没有异步优势，反而可能增加线程调度的额外开销。

优化后的代码 #

package com.example.myapplication

import java.io.BufferedReader
import java.io.InputStreamReader
import java.io.PrintWriter
import java.net.InetSocketAddress
import java.net.Socket
import java.nio.charset.StandardCharsets
import java.text.SimpleDateFormat
import java.util.Date

fun main() {
    val server = "commdev.grizzy.com"
    val port = 3000
    val timeout = 5000 // 5秒超时，可根据需求调整
    val dateFormat = SimpleDateFormat("yyyy-MM-dd HH:mm:ss.SSS")
    val soEvent = "[SO|${dateFormat.format(Date())}]"

    // 创建Socket并设置超时
    Socket().use { socket ->
        socket.connect(InetSocketAddress(server, port), timeout)
        socket.soTimeout = timeout // 设置读取超时

        println("Connected to the server at $server on port $port")

        // 指定UTF-8编码，避免编码不匹配问题
        PrintWriter(socket.getOutputStream(), true, StandardCharsets.UTF_8).use { out ->
            BufferedReader(InputStreamReader(socket.getInputStream(), StandardCharsets.UTF_8)).use { `in` ->
                out.println(soEvent)
                println("Sent SO event: $soEvent")

                // 读取响应，若超时会抛出SocketTimeoutException
                val responseSO = `in`.readLine()
                println("Received response to SO event: $responseSO")
            }
        }
    }
}

额外排查点 #

• 确认服务器返回的响应是否以**换行符（\n或\r\n）**结尾：readLine()依赖行结束符判断读取结束，若服务器未发送换行，会一直阻塞。这种情况下可改用read()读取字节流，或提前约定响应长度。
• 检查网络环境：确保Kotlin程序运行的网络与Python程序一致，排除网络路由、防火墙等差异导致的延迟。

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