下面是一个处理多个客户端的Socket服务器的Kotlin代码示例:
import java.io.BufferedReader
import java.io.InputStreamReader
import java.io.PrintWriter
import java.net.ServerSocket
import java.net.Socket
import java.util.concurrent.Executors
class SocketServer {
private val executor = Executors.newFixedThreadPool(10)
fun startServer() {
val serverSocket = ServerSocket(8080)
while (true) {
val clientSocket = serverSocket.accept()
executor.execute(ClientHandler(clientSocket))
}
}
inner class ClientHandler(private val socket: Socket) : Runnable {
override fun run() {
try {
val reader = BufferedReader(InputStreamReader(socket.getInputStream()))
val writer = PrintWriter(socket.getOutputStream(), true)
val inputLine = reader.readLine()
val outputLine = processInput(inputLine)
writer.println(outputLine)
} catch (e: Exception) {
e.printStackTrace()
} finally {
socket.close()
}
}
private fun processInput(inputLine: String): String {
// Add your custom logic here to process the input and return the output
return "Processed: $inputLine"
}
}
}
fun main() {
val server = SocketServer()
server.startServer()
}
这个示例代码创建了一个Socket服务器,监听在端口8080上。当有客户端连接时,会使用线程池中的线程来处理客户端请求。每个客户端的处理逻辑在ClientHandler
类中的run
方法中定义。在这个示例中,processInput
方法用于处理客户端输入,并返回处理结果。
你可以根据实际需求修改processInput
方法中的逻辑,以实现你的自定义处理逻辑。