當(dāng)然！如果需要持續(xù)接受服務(wù)端的消息，確實(shí)可以使用死循環(huán)來(lái)不斷讀取數(shù)據(jù)，但需要注意線程管理和性能問(wèn)題。在 Android 開(kāi)發(fā)中，常見(jiàn)的做法是使用后臺(tái)線程或服務(wù)來(lái)處理網(wǎng)絡(luò)通信。

下面，我將分別給出 Java 和 Kotlin 的 Socket 客戶端和服務(wù)端實(shí)現(xiàn)代碼，并說(shuō)明如何持續(xù)接受服務(wù)端消息的實(shí)現(xiàn)方法。

1.1 服務(wù)端實(shí)現(xiàn)

服務(wù)端代碼示例：

// ServerThread.java
package com.example.myapp;

import java.io.BufferedReader;
import java.io.InputStreamReader;
import java.io.OutputStream;
import java.net.ServerSocket;
import java.net.Socket;

public class ServerThread extends Thread {

    private static final int PORT = 12345;

    @Override
    public void run() {
        try {
            ServerSocket serverSocket = new ServerSocket(PORT);
            System.out.println("Server started, waiting for client connection...");

            while (true) {
                Socket clientSocket = serverSocket.accept();
                System.out.println("Client connected");

                new ClientHandler(clientSocket).start();
            }
        } catch (Exception e) {
            e.printStackTrace();
        }
    }

    private static class ClientHandler extends Thread {
        private Socket socket;

        public ClientHandler(Socket socket) {
            this.socket = socket;
        }

        @Override
        public void run() {
            try {
                BufferedReader input = new BufferedReader(new InputStreamReader(socket.getInputStream()));
                OutputStream output = socket.getOutputStream();

                String clientMessage;
                while ((clientMessage = input.readLine()) != null) {
                    System.out.println("Received from client: " + clientMessage);
                    output.write(("Message received: " + clientMessage).getBytes());
                    output.flush();
                }

                input.close();
                output.close();
                socket.close();
            } catch (Exception e) {
                e.printStackTrace();
            }
        }
    }
}

解析：

1.ServerSocket 用于監(jiān)聽(tīng)指定端口。
2.在 while (true) 循環(huán)中，接受客戶端連接，并為每個(gè)連接創(chuàng)建一個(gè)新的線程（ClientHandler）以處理客戶端消息。
3.在 ClientHandler 中，使用 while 循環(huán)持續(xù)讀取客戶端發(fā)來(lái)的數(shù)據(jù)，并回應(yīng)客戶端。

1.2 客戶端實(shí)現(xiàn)

客戶端代碼示例：

// ClientActivity.java
package com.example.myapp;

import android.os.Bundle;
import android.os.StrictMode;
import androidx.appcompat.app.AppCompatActivity;

import java.io.BufferedReader;
import java.io.InputStreamReader;
import java.io.OutputStream;
import java.net.Socket;

public class ClientActivity extends AppCompatActivity {

    private static final String SERVER_IP = "127.0.0.1";
    private static final int SERVER_PORT = 12345;

    @Override
    protected void onCreate(Bundle savedInstanceState) {
        super.onCreate(savedInstanceState);
        setContentView(R.layout.activity_client);

        new Thread(() -> {
            try {
                Socket socket = new Socket(SERVER_IP, SERVER_PORT);
                OutputStream output = socket.getOutputStream();
                BufferedReader input = new BufferedReader(new InputStreamReader(socket.getInputStream()));

                // 發(fā)送數(shù)據(jù)到服務(wù)端
                output.write("Hello, server!".getBytes());
                output.flush();

                // 持續(xù)接收服務(wù)端消息
                String serverResponse;
                while ((serverResponse = input.readLine()) != null) {
                    System.out.println("Response from server: " + serverResponse);
                }

                output.close();
                input.close();
                socket.close();
            } catch (Exception e) {
                e.printStackTrace();
            }
        }).start();
    }
}

解析：

1.在客戶端線程中，創(chuàng)建 Socket 連接到服務(wù)端，并使用 OutputStream 發(fā)送數(shù)據(jù)。
2.使用 BufferedReader 讀取服務(wù)端的消息，并使用 while 循環(huán)持續(xù)接收消息。