Kotlin BufferReader没有得到服务器响应

如何解决Kotlin BufferReader没有得到服务器响应

我真的很陌生。 我有两个应用程序，一个是Android仿真器中的Client，另一个是Windows Form Application Server（我的服务器在C＃中使用SimpleTCP库）。

这是服务器代码：

    private void Form1_Load(object sender,EventArgs e)
    {
        server = new SimpleTcpServer();
        server.Delimiter = 0x13;
        server.StringEncoder = Encoding.UTF8;
        server.DataReceived += Server_DataReceived;
        
        messageList.Text += "Server starting...";
        server.Start("192.168.1.7",5000);
        messageList.Text += "\r\n Server started...";
    }
    private void Server_DataReceived(object sender,SimpleTCP.Message e)
    {
                messageList.Invoke((MethodInvoker)delegate ()
                {
                     messageList.Text += string.Format("\r\n Client Message: {0} \n ",e.MessageString);
                });
                e.ReplyLine("Hello from Server");
    }

我正在通过本地主机进行通信。我可以发送请求，服务器可以毫无问题地获得此请求，但是不幸的是，当我尝试从服务器获取响应时，无法收到响应。 val message = input!!.readLine()始终返回null

您能帮我为什么我不能这样做吗？

这是我的代码

var thread: Thread? = null
var etIP: EditText? = null
var etPort: EditText? = null
var tvMessages: TextView? = null
var etMessage: EditText? = null
var btnSend: Button? = null
var SERVER_IP: String? = null
var SERVER_PORT = 0
override fun onCreate(savedInstanceState: Bundle?) {
    super.onCreate(savedInstanceState)
    setContentView(R.layout.activity_main)
    etIP = findViewById(R.id.etIP)
    etPort = findViewById(R.id.etPort)
    tvMessages = findViewById(R.id.tvMessages)
    etMessage = findViewById(R.id.etMessage)
    btnSend = findViewById(R.id.btnSend)
    val btnConnect: Button = findViewById(R.id.btnConnect)
    btnConnect.setOnClickListener {
        tvMessages!!.text = ""
        SERVER_IP = etIP!!.text.toString().trim { it <= ' ' }
        SERVER_PORT = etPort!!.text.toString().trim { it <= ' ' }.toInt()
        thread = Thread(Thread1())
        thread!!.start()
    }
    btnSend!!.setOnClickListener {
        val message = "Android!"+etMessage!!.text.toString().trim { it <= ' ' }
        if (!message.isEmpty()) {
            Thread(Thread3(message)).start()
        }
    }
}

private var output: PrintWriter? = null
private var input: BufferedReader? = null

internal inner class Thread1 : Runnable {
    override fun run() {
        val socket: Socket
        try {
            socket = Socket(SERVER_IP,SERVER_PORT)
            output = PrintWriter(socket.getOutputStream())
            input = BufferedReader(InputStreamReader(socket.getInputStream()))
            runOnUiThread(Runnable { tvMessages!!.text = "Connected\n" })
            Thread(Thread2()).start()
        } catch (e: Exception) {
            e.printStackTrace()
        }
    }
}

internal inner class Thread2 : Runnable {
    override fun run() {
        while (true) {
            try {
                val message = input!!.readLine().toString()
                run {
                    runOnUiThread(Runnable { tvMessages!!.append("server: $message\n") })
                }
                run {
                    thread = Thread(Thread1())
                    thread!!.start()
                    return
                }
            } catch (e: Exception) {
                tvMessages!!.text = e.toString()
            }
        }
    }
}

internal inner class Thread3(private val message: String) : Runnable {
    override fun run() {
        output!!.write(message)
        output!!.flush()
        runOnUiThread(Runnable {
            tvMessages!!.append("client: $message\n")
            tvMessages!!.setMovementMethod(ScrollingMovementMethod())
            etMessage!!.setText("")
        })
    }
}
fun clearAll(view: View){
   tvMessages!!.text = ""
}