socket进行服务器和客户端通信

package com.music.mysongs.activity

import android.os.Build
import android.os.Bundle
import android.os.Handler
import android.os.Message
import androidx.annotation.RequiresApi
import kotlinx.android.synthetic.main.activity_lyric.*
import java.io.*
import java.net.Socket

class LyricActivity : Application, Runnable {
    private val mTag = "LyricActivity"

    //Comment model
    private var mSocket: Socket? = null
    private var mRead: BufferedReader? = null
    private var mWrite: PrintWriter? = null
    private val port: Int = 8080
    private val host: String = "192.168.43.164"//"10.20.19.99"
    private val sb = StringBuilder()

    private val myHandler: Handler = Handler {
        //socket model
        txtShowComment_lyric.text = it.obj.toString()
        editSendComment_lyric.setText("")
        false
    }

    @RequiresApi(Build.VERSION_CODES.M)
    override fun onCreate(savedInstanceState: Bundle?) {
        super.onCreate(savedInstanceState)
        setContentView(R.layout.activity_lyric) 
        //socket server
        object : Thread() {
            override fun run() {
                try {
                    mSocket = Socket(host, port)
                    mRead = BufferedReader(InputStreamReader(mSocket?.getInputStream(), "UTF-8"))
                    mWrite = PrintWriter(
                        BufferedWriter(
                            OutputStreamWriter(
                                mSocket?.getOutputStream()
                            )
                        ), true
                    )
                } catch (e: IOException) {
                    e.printStackTrace()
                }
            }
        }.start()
        btnSendComment_lyric.setOnClickListener {
            if (editSendComment_lyric.text != null && mSocket!!.isConnected && !mSocket!!.isOutputShutdown) {
                val mSend = editSendComment_lyric.text.toString()
                mWrite!!.println(mSend)
            }
        }
        Thread(this@LyricActivity).start()
    }

    override fun run() {
        try {
            while (true) {
                if (mSocket!!.isConnected && !mSocket!!.isInputShutdown) {
                    if (mRead?.readLine().also { sb.append(it + "\n") } != null) {
                        val msg = Message()
                        msg.obj = sb
                        myHandler.sendMessage(msg)
                    }
                }
            }
        } catch (e: Exception) {
            e.printStackTrace()
        }
    }
}
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76