Kotlin TCP Socket调用阻塞及超时设置未生效的解决求助

问题背景 #

我是Android/Kotlin初学者，应用需要连接TCP服务器，原代码如下可正常运行：

client1 = Socket(SERVER_IP_ADDRESS, SERVER_IP_PORT)
output1 = DataOutputStream(client1.getOutputStream())
input1 = DataInputStream(client1.getInputStream())

但服务器宕机时，第一行代码会永久阻塞。修改为带超时的连接代码后：

try {
  client1 = Socket()
  client1.connect(InetSocketAddress(SERVER_IP_ADDRESS, SERVER_IP_PORT), 3000)
  output1 = DataOutputStream(client1.getOutputStream())
  input1 = DataInputStream(client1.getInputStream())
} catch (ex : Exception) {
  // do something
} finally {
  // do something
}

发现3秒超时未生效：DNS错误会立即抛出java.net.UnknownHostException，但服务器宕机时要等20秒才触发异常。

核心原因 #

Socket.connect()的超时参数仅控制TCP握手阶段的时长，但如果传入的是域名，InetSocketAddress会先执行DNS解析，这一步的超时不受该参数控制；另外系统默认的TCP SYN重传机制（多次重试连接）也会让实际耗时远超设置的3秒。

可行解决方案 #

1. 拆分DNS解析与连接，分别控制超时 #

手动提前做DNS解析，用协程超时控制这一步，再用解析出的IP建立连接：

import java.net.InetAddress
import java.net.Socket
import java.io.DataOutputStream
import java.io.DataInputStream
import kotlinx.coroutines.Dispatchers
import kotlinx.coroutines.withTimeout
import kotlinx.coroutines.launch
import androidx.lifecycle.lifecycleScope // 假设在Activity/Fragment中使用

// 在生命周期协程中执行（避免内存泄漏）
lifecycleScope.launch(Dispatchers.IO) {
    var client1: Socket? = null
    try {
        // 3秒超时内完成DNS解析
        val inetAddresses = withTimeout(3000) {
            InetAddress.getAllByName(SERVER_IP_ADDRESS)
        }
        // 用解析出的IP建立连接，再次设置3秒超时
        client1 = Socket()
        client1.connect(InetSocketAddress(inetAddresses[0], SERVER_IP_PORT), 3000)
        
        output1 = DataOutputStream(client1.getOutputStream())
        input1 = DataInputStream(client1.getInputStream())
        // 连接成功后的业务操作
    } catch (ex: Exception) {
        // 处理超时、DNS失败、连接失败等异常
        ex.printStackTrace()
    } finally {
        // 及时关闭Socket释放资源
        client1?.close()
    }
}

注意：Android禁止在主线程执行网络操作，必须用协程、线程池等方式切换到子线程。

2. 调整TCP SYN重传策略（API 24+） #

Android 7.0及以上，可以通过反射修改TCP参数，减少SYN重传次数，缩短连接失败的等待时间：

client1 = Socket()
client1.tcpNoDelay = true
try {
    // 反射获取SocketImpl，修改TCP连接超时参数
    val implField = Socket::class.java.getDeclaredField("impl")
    implField.isAccessible = true
    val socketImpl = implField.get(client1)
    
    val setOptionMethod = socketImpl.javaClass.getDeclaredMethod(
        "setOption", Int::class.java, Int::class.java
    )
    setOptionMethod.isAccessible = true
    // 设置SYN重传次数为0（不同系统参数值可能有差异，需测试）
    setOptionMethod.invoke(socketImpl, 1, 0)
} catch (e: Exception) {
    // 反射失败不影响后续流程，忽略即可
}
client1.connect(InetSocketAddress(SERVER_IP_ADDRESS, SERVER_IP_PORT), 3000)

该方法兼容性较差，不同厂商的系统可能不支持，仅作为备选方案。

3. 用OkHttp替代原生Socket #

OkHttp对网络超时的控制更全面，内置了DNS解析超时、连接超时的统一处理，适合Android开发：

import okhttp3.OkHttpClient
import okhttp3.Request
import okhttp3.Call
import okhttp3.Callback
import java.io.IOException

val okHttpClient = OkHttpClient.Builder()
    .connectTimeout(3, java.util.concurrent.TimeUnit.SECONDS) // 统一设置连接超时（包含DNS）
    .build()

val request = Request.Builder()
    .url("tcp://$SERVER_IP_ADDRESS:$SERVER_IP_PORT")
    .build()

okHttpClient.newCall(request).enqueue(object : Callback {
    override fun onFailure(call: Call, e: IOException) {
        // 连接失败处理
        e.printStackTrace()
    }

    override fun onResponse(call: Call, response: okhttp3.Response) {
        // 连接成功，获取底层Socket（纯TCP场景）
        val socket = call.connection()?.socket()
        socket?.let {
            output1 = DataOutputStream(it.getOutputStream())
            input1 = DataInputStream(it.getInputStream())
            // 后续业务操作
        }
        response.close()
    }
})

如果是HTTP协议，直接使用OkHttp的响应处理即可；纯TCP场景可以通过connection()获取底层Socket。

注意事项 #

• 所有网络操作必须在子线程执行，Android 9.0及以上主线程网络请求会直接抛出异常。
• 超时时间不要设置过短，避免正常网络环境下的误判。
• 异常处理要覆盖协程超时的TimeoutCancellationException、网络相关的IOException等类型。

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