//設(shè)置socket
val socket = DatagramSocket()
val serverPort = 9000
val address = InetAddress.getByName("ip地址")
//發(fā)送
val bytes = message.toByteArray(Charsets.UTF_8)
val len = bytes.size
val sendPacket = DatagramPacket(bytes, len, address, serverPort)
socket.send(sendPacket)
//接收
socket.receive(receivePacket)
val data = String(receivePacket.data, Charsets.UTF_8)
//處理接收到的數(shù)據(jù)
//關(guān)閉連接
socket.close()

//設(shè)置socket
val serverPort = 9000
val address = InetAddress.getByName("ip地址")
val socket = Socket(address, serverPort)
val input = socket.getInputStream()
val output = socket.getOutputStream()
//發(fā)送
output.write(message.toByteArray(Charsets.UTF_8))
//接收
val len = input.read(receive)
val data = String(receive, 0, len, Charsets.UTF_8)
//處理接收到的數(shù)據(jù)
//關(guān)閉連接
socket.close()

interface Communicate {
    /**
     * 通信端口
     */
    var serverPort: Int
    /**
     * 通信地址
     */
    var address: String
    /**
     * 輸入編碼
     */
    var inCharset: Charset
    /**
     * 輸出編碼
     */
    var outCharset: Charset
    /**
     * 發(fā)送數(shù)據(jù)
     * @param message 數(shù)據(jù)內(nèi)容
     */
    fun send(message: String)
    /**
     * 開始接收數(shù)據(jù)
     * @param onReceive 處理接收到的數(shù)據(jù)的函數(shù)，函數(shù)返回值為是否繼續(xù)接收消息.
     * 請不要在函數(shù)中使用stopReceive()函數(shù)停止接收數(shù)據(jù)，這不會起作用。
     * @return 是否開啟成功
     */
    fun startReceive(onReceive: OnReceiveFunc): Boolean
    /**
     * 停止接收數(shù)據(jù)
     */
    fun stopReceive()
    /**
     * 開啟通信，用于TCP建立連接
     * @return 是否開啟成功
     */
    fun open(): Boolean
    /**
     * 關(guān)閉通信
     */
    fun close()
}

typealias OnReceiveFunc = (String) -> Boolean

communicate.startReceive {
    binding.textView.text = it
    return@startReceive false
}

communicate.startReceive(result -> {
    binding.textView.setText(result);
    return false;
});

interface Communicate {
 companion object {
     @JvmStatic
     val TCPClient: Communicate
         get() = TCP()
     @JvmStatic
     val UDP: Communicate
         get() = UDP()
 }
 //其他代碼
}

private val communicate = Communicate.UDP.apply {
    address = "ip地址"
    serverPort = 9000
    inCharset = Charset.forName("gb2312")
    outCharset = Charset.forName("gb2312")
    open()
}

private val communicate = Communicate.TCPClient.apply {
    //與UDP完全一樣
}