套接字
必需依赖项：io.ktor:ktor-network, io.ktor:ktor-network-tls
代码示例： sockets-server, sockets-client, sockets-client-tls
除了服务器和客户端的 HTTP/WebSocket 处理外，Ktor 还支持 TCP 和 UDP 原始套接字。 它公开了一个在底层使用 java.nio 的挂起 API。
Sockets 使用实验性 API，预计在后续更新中会不断演进，且可能包含破坏性更改。
添加依赖项
要使用 Sockets，您需要在构建脚本中包含 ktor-network 构件：
要在客户端中使用安全套接字，您还需要添加 io.ktor:ktor-network-tls。
服务器
创建服务器套接字
要构建服务器套接字，请创建 SelectorManager 实例，对其调用 SocketBuilder.tcp() 函数，然后使用 bind 将服务器套接字绑定到特定端口：
val selectorManager = SelectorManager(Dispatchers.IO)
val serverSocket = aSocket(selectorManager).tcp().bind("127.0.0.1", 9002)上述代码片段创建了一个 TCP 套接字，即 ServerSocket 实例。 要创建 UDP 套接字，请使用 SocketBuilder.udp()。
接受传入连接
创建服务器套接字后，您需要调用 ServerSocket.accept 函数，该函数接受套接字连接并返回一个已连接的套接字（Socket 实例）：
val socket = serverSocket.accept()拥有已连接的套接字后，您可以通过从套接字读取或向其写入来接收/发送数据。
接收数据
要从客户端接收数据，您需要调用 Socket.openReadChannel 函数，该函数返回 ByteReadChannel：
val receiveChannel = socket.openReadChannel()ByteReadChannel 提供了用于异步读取数据的 API。 例如，您可以使用 ByteReadChannel.readUTF8Line 读取一行 UTF-8 字符：
val name = receiveChannel.readUTF8Line()发送数据
要向客户端发送数据，请调用 Socket.openWriteChannel 函数，该函数返回 ByteWriteChannel：
val sendChannel = socket.openWriteChannel(autoFlush = true)ByteWriteChannel 提供了用于异步写入字节序列的 API。 例如，您可以使用 ByteWriteChannel.writeStringUtf8 写入一行 UTF-8 字符：
val name = receiveChannel.readUTF8Line()
sendChannel.writeStringUtf8("Hello, $name!
")关闭套接字
要释放与已连接套接字关联的资源，请调用 Socket.close：
socket.close()示例
以下代码示例演示了如何在服务器端使用套接字：
package com.example
import io.ktor.network.selector.*
import io.ktor.network.sockets.*
import io.ktor.utils.io.*
import kotlinx.coroutines.*
fun main(args: Array<String>) {
runBlocking {
val selectorManager = SelectorManager(Dispatchers.IO)
val serverSocket = aSocket(selectorManager).tcp().bind("127.0.0.1", 9002)
println("Server is listening at ${serverSocket.localAddress}")
while (true) {
val socket = serverSocket.accept()
println("Accepted ${socket.remoteAddress}")
launch {
val receiveChannel = socket.openReadChannel()
val sendChannel = socket.openWriteChannel(autoFlush = true)
sendChannel.writeStringUtf8("Please enter your name
")
try {
while (true) {
val name = receiveChannel.readUTF8Line()
sendChannel.writeStringUtf8("Hello, $name!
")
}
} catch (e: Throwable) {
socket.close()
}
}
}
}
}您可以在此处找到完整的示例：sockets-server。
客户端
创建套接字
要构建客户端套接字，请创建 SelectorManager 实例，对其调用 SocketBuilder.tcp() 函数，然后使用 connect 建立连接并获取已连接的套接字（Socket 实例）：
val selectorManager = SelectorManager(Dispatchers.IO)
val socket = aSocket(selectorManager).tcp().connect("127.0.0.1", 9002)拥有已连接的套接字后，您可以通过从套接字读取或向其写入来接收/发送数据。
创建安全套接字 (SSL/TLS)
安全套接字允许您建立 TLS 连接。 要使用安全套接字，您需要添加 ktor-network-tls 依赖项。 然后，在已连接的套接字上调用 Socket.tls 函数：
val selectorManager = SelectorManager(Dispatchers.IO)
val socket = aSocket(selectorManager).tcp().connect("127.0.0.1", 8443).tls()tls 函数允许您调整由 TLSConfigBuilder 提供的 TLS 参数：
val selectorManager = SelectorManager(Dispatchers.IO)
val socket = aSocket(selectorManager).tcp().connect("youtrack.jetbrains.com", port = 443).tls(coroutineContext = coroutineContext) {
trustManager = object : X509TrustManager {
override fun getAcceptedIssuers(): Array<X509Certificate?> = arrayOf()
override fun checkClientTrusted(certs: Array<X509Certificate?>?, authType: String?) {}
override fun checkServerTrusted(certs: Array<X509Certificate?>?, authType: String?) {}
}
}您可以在此处找到完整的示例：sockets-client-tls。
接收数据
要从服务器接收数据，您需要调用 Socket.openReadChannel 函数，该函数返回 ByteReadChannel：
val receiveChannel = socket.openReadChannel()ByteReadChannel 提供了用于异步读取数据的 API。 例如，您可以使用 ByteReadChannel.readUTF8Line 读取一行 UTF-8 字符：
val greeting = receiveChannel.readUTF8Line()发送数据
要向服务器发送数据，请调用 Socket.openWriteChannel 函数，该函数返回 ByteWriteChannel：
val sendChannel = socket.openWriteChannel(autoFlush = true)ByteWriteChannel 提供了用于异步写入字节序列的 API。 例如，您可以使用 ByteWriteChannel.writeStringUtf8 写入一行 UTF-8 字符：
val myMessage = readln()
sendChannel.writeStringUtf8("$myMessage
")关闭连接
要释放与已连接套接字关联的资源，请调用 Socket.close 和 SelectorManager.close：
socket.close()
selectorManager.close()示例
以下代码示例演示了如何在客户端使用套接字：
package com.example
import io.ktor.network.selector.*
import io.ktor.network.sockets.*
import io.ktor.utils.io.*
import kotlinx.coroutines.*
import kotlin.system.*
fun main(args: Array<String>) {
runBlocking {
val selectorManager = SelectorManager(Dispatchers.IO)
val socket = aSocket(selectorManager).tcp().connect("127.0.0.1", 9002)
val receiveChannel = socket.openReadChannel()
val sendChannel = socket.openWriteChannel(autoFlush = true)
launch(Dispatchers.IO) {
while (true) {
val greeting = receiveChannel.readUTF8Line()
if (greeting != null) {
println(greeting)
} else {
println("Server closed a connection")
socket.close()
selectorManager.close()
exitProcess(0)
}
}
}
while (true) {
val myMessage = readln()
sendChannel.writeStringUtf8("$myMessage
")
}
}
}您可以在此处找到完整的示例：sockets-client。