47 lines
1.2 KiB
Plaintext
47 lines
1.2 KiB
Plaintext
import lyng.io.net
|
|
|
|
val host = "127.0.0.1"
|
|
val clientCount = 1000
|
|
val server = Net.tcpListen(0, host, clientCount, true)
|
|
val port = server.localAddress().port
|
|
|
|
fun payloadFor(index: Int) = "$index:${Random.nextInt()}:${Random.nextInt()}"
|
|
|
|
launch {
|
|
try {
|
|
while(true) {
|
|
val client = server.accept()
|
|
launch {
|
|
try {
|
|
client.readLine()?.let { source ->
|
|
client.writeUtf8("pong: $source\n")
|
|
client.flush()
|
|
}
|
|
} finally {
|
|
client.close()
|
|
}
|
|
}
|
|
}
|
|
} finally {
|
|
server.close()
|
|
}
|
|
}
|
|
|
|
val replies = (0..<clientCount).map { index ->
|
|
val payload = payloadFor(index)
|
|
launch {
|
|
val socket = Net.tcpConnect(host, port) as TcpSocket
|
|
try {
|
|
socket.writeUtf8(payload + "\n")
|
|
socket.flush()
|
|
val reply = socket.readLine()
|
|
assertEquals("pong: $payload", reply)
|
|
} finally {
|
|
socket.close()
|
|
}
|
|
}
|
|
}.joinAll()
|
|
|
|
assertEquals(clientCount, replies.size)
|
|
println("OK: $clientCount concurrent tcp clients")
|