Kotlin原生多平台应用中UDP Socket的实现方案咨询

一、KTor Network 使用指南 #

KTor Network是JetBrains官方的多平台网络库，原生支持UDP，基于协程设计，API简洁易维护，能很好适配多平台场景。

1. 添加依赖 #

在多平台项目的build.gradle.kts中引入依赖（替换为最新稳定版本）：

kotlin {
    sourceSets {
        commonMain.dependencies {
            implementation("io.ktor:ktor-network:2.3.10")
            implementation("org.jetbrains.kotlinx:kotlinx-coroutines-core:1.7.3")
        }
    }
}

2. UDP服务端实现 #

通过协程作用域绑定端口，循环接收UDP数据包：

import io.ktor.network.sockets.*
import io.ktor.utils.io.core.*
import kotlinx.coroutines.Dispatchers
import kotlinx.coroutines.launch
import kotlinx.coroutines.runBlocking

fun main() = runBlocking(Dispatchers.IO) {
    val serverSocket = aSocket(ActorSelectorManager(Dispatchers.IO)).udp().bind(InetSocketAddress("0.0.0.0", 8080))
    println("UDP服务端已启动，监听端口8080")

    launch {
        while (true) {
            val packet = serverSocket.receive()
            val message = packet.readText()
            println("收到客户端消息: $message")
            
            // 可选：回复客户端
            serverSocket.send(Datagram(ByteReadPacket("已收到: $message"), packet.address))
        }
    }
}

3. UDP客户端实现 #

连接指定服务端并发送UDP数据包：

import io.ktor.network.sockets.*
import io.ktor.utils.io.core.*
import kotlinx.coroutines.Dispatchers
import kotlinx.coroutines.runBlocking

fun main() = runBlocking(Dispatchers.IO) {
    val clientSocket = aSocket(ActorSelectorManager(Dispatchers.IO)).udp().connect(InetSocketAddress("127.0.0.1", 8080))
    clientSocket.send(Datagram(ByteReadPacket("Hello UDP Server"), clientSocket.remoteAddress))
    
    // 可选：接收服务端回复
    val response = clientSocket.receive()
    println("服务端回复: ${response.readText()}")
    
    clientSocket.close()
}

二、替代方案 #

1. 自定义Expect/Actual封装 #

针对不同平台封装UDP API，解决posix包易用性差的问题：

• Common层：定义通用接口

expect class UdpSocket {
    fun bind(port: Int)
    fun send(data: String, host: String, port: Int)
    fun receive(): String
    fun close()
}

• JVM层：基于Java原生DatagramSocket实现

actual class UdpSocket {
    private val socket = DatagramSocket()
    private val buffer = ByteArray(1024)
    
    actual fun bind(port: Int) {
        socket.bind(InetSocketAddress(port))
    }
    
    actual fun send(data: String, host: String, port: Int) {
        val packet = DatagramPacket(data.toByteArray(), data.length, InetAddress.getByName(host), port)
        socket.send(packet)
    }
    
    actual fun receive(): String {
        val packet = DatagramPacket(buffer, buffer.size)
        socket.receive(packet)
        return String(packet.data, 0, packet.length)
    }
    
    actual fun close() {
        socket.close()
    }
}

• Native层：封装posix的UDP API（优化调用逻辑）

actual class UdpSocket {
    private var fd: Int = -1
    
    actual fun bind(port: Int) {
        fd = socket(AF_INET, SOCK_DGRAM, 0)
        val addr = sockaddr_in().apply {
            sin_family = AF_INET.convert()
            sin_port = htons(port.toUShort())
            sin_addr.s_addr = htonl(INADDR_ANY.convert())
        }
        bind(fd, addr.ptr, sockaddr_in.size.convert())
    }
    
    actual fun send(data: String, host: String, port: Int) {
        // 调用posix的sendto函数实现数据发送
    }
    
    actual fun receive(): String {
        // 调用posix的recvfrom函数实现数据接收
    }
    
    actual fun close() {
        close(fd)
    }
}

2. 第三方KMP Socket库 #

比如kmp-sockets，专为Kotlin多平台设计，支持UDP/TCP，API简洁，无需自行处理平台差异，依赖引入后可直接使用。

3. Java DatagramSocket（仅JVM平台） #

若应用仅需支持JVM，直接使用Java原生java.net.DatagramSocket即可，无需额外依赖，API成熟稳定。

三、选择建议 #

• 优先选KTor Network：官方维护，协程友好，多平台支持完善，无需手动处理平台适配。
• 需高度定制化时选自定义Expect/Actual封装：完全掌控实现细节，优化posix API的易用性。
• 追求轻量方案选第三方KMP库：减少自研工作量，快速实现UDP功能。

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