我是否正确使用了这个处理程序和执行程序（Android）？

Question

我有一个执行器，它运行一个 while true 循环，它只是用数据 ping 一个服务器。现在我需要用这些数据更新 UI，所以我使用了一个处理程序。

在我的主要活动中，我有：

private void createGeneralHandler() {
    generalHandler = new Handler(Looper.getMainLooper()){
        @Override


    public void handleMessage(Message msg){

                switch (msg.what){
                    case SERVER_RESPONSE:

                        serverTextView.append("\n"+msg.obj);
                        break;

                    default:
                        super.handleMessage(msg);
                }
            }
        };
    }

这会在名为generalHandler 的主活动中创建一个字段。

现在NetworkTask runnable 需要知道这个处理程序才能将消息发送到正确的位置？

所以我的主要活动中有这个：

networkExecutor = Executors.newSingleThreadExecutor();
networkTask = new NetworkTask(serverIPAddress, serverPort);
networkTask.setRequest("I WANT DATA");
networkTask.setHandler(generalHandler); //IS THIS WRONG ???
networkExecutor.execute(networkTask);  

networkTask 只是一个单独文件中的 Runnable，定义如下：

public class NetworkTask implements Runnable {

    private int port;
    private String ipAddress;
    private int pollInterval;
    private Socket socket = null;
    private PrintWriter out = null;
    private BufferedReader br = null;
    private String request = null;
    private String response = null;
    private static final int SERVER_RESPONSE = 1;
    private Handler handler = null;

    public NetworkTask(String ipAddress, int port){
        this.port = port;
        this.ipAddress = ipAddress;
        this.pollInterval = 50;
    }

    @Override
    public void run() {

        try {
            socket = new Socket(ipAddress, port);
            out = new PrintWriter(socket.getOutputStream(), true);
            br = new BufferedReader(new InputStreamReader(socket.getInputStream()));
        } catch (IOException e) {
            e.printStackTrace();
        }

        try {
            while (!Thread.currentThread().isInterrupted()) {

                Thread.sleep(pollInterval);

                out.println(request);
                try {
                    response = br.readLine();
                } catch (IOException e) {
                    e.printStackTrace();
                }
                if(!response.equals("doNothing")){
                    Message message = new Message();
                    message.what = SERVER_RESPONSE;
                    message.obj = response;
                    handler.sendMessage(message);
                }else if(response.equals("Nothing Connected to Server!")){
                    Message message = new Message();
                    message.what = SERVER_RESPONSE;
                    message.obj = response;
                    handler.sendMessage(message);
                }
            }
        } catch (InterruptedException threadE) {
            try {
                br.close();
                out.close();
                socket.close();
            } catch (IOException socketE) {
                socketE.printStackTrace();
            }
            Log.i("NETWORK_TASK_THREAD", "NETWORK TASK closed gracefully!");
        }

    }

    public void setRequest(String request) {
        this.request = request;
    }

    public void setHandler(Handler handler) {
        this.handler = handler;
    }
}

Answer 1

对您的问题的回答会有点武断。由于实现只是一种设计选择，没有对错之分，而是好与不好。

以下是我想强调的几点：

• 如果您只是担心networkTask.setHandler(generalHandler);，那么只要您不在主线程上调用任何网络调用或繁重的处理就可以了。
• 您还需要确保您的 Runnable 在应用程序onStop() 或onDestroy() 中被适当地中断，以避免潜在的内存泄漏。
• 您不断尝试 ping 服务器，这不是一个好主意，因为它会消耗资源并耗尽电池。您可以定期执行这些任务或使用 FCM 推送。
• 对于关闭 InputStreams 或 OutputStreams，它被认为是在 finally {..} 块中进行清理的良好做法，这样可以确保在执行期间发生一些其他异常时进行清理。

另一种方法是实现ViewModel 和MutableLiveData 并执行操作。这不会因不必要的处理而使您的 Activity 膨胀。