Android asynctask 从套接字读取

Question

我在读取/写入 TCP 服务器时遇到一些问题，我正在为其构建应用程序。在最近的一个帖子中，有人建议我使用服务，但这是一个学校项目，建议使用 asyncTask，所以我也可以这样做。

所以我得到的类是我的活动类和异步类，活动中没有发生任何有趣的事情，只是发送一个正在工作的字符串，所以我无法继续使用异步类。

    class ServerTask extends AsyncTask<Void, Void, Void>{

        public static String ip = "10.0.2.2";
        public static int port = 2002;
        Socket socket;
        public DataInputStream dis;
        public DataOutputStream dos;
        public String message;

        @Override
        protected Void doInBackground(Void... params) {

            try {
                socket = new Socket(ip, port);
                dis = new DataInputStream(socket.getInputStream());
                dos = new DataOutputStream(socket.getOutputStream());

            } catch (Exception e) {
                Log.i("AsyncTank", "Cannot create Socket");
            }
            while(socket.isConnected()){
                read();                     
                    }
                }

            }
            return null;
        }

        public void write(String message) {
            try {
                if (socket.isConnected()){
                    dos.writeUTF(message);
                    dos.flush();
                } else {
                    Log.i("AsynkTask", "Socket appears to be closed");
                }
            } catch (Exception e) {
                Log.i("AsynkTask", "Writing failed");
            }
        }

        public String read() {
            try {
                if (socket.isConnected()) {
                    message = dis.readLine();
                } else {
                    Log.i("AsyncTask", "Cannot read");
                }
            } catch (Exception e) {
                Log.i("AsyncTask", "Cannot read from stream");
            }
            return message;
        }
    }

我所知道的事情是，服务器确实收到了消息，但直到我重新启动服务器后它才会更新，这让我相信我没有推送新行或使其在关闭后全部显示为一行的东西。然而，这也可能是我不负责的服务器，所以我必须阅读其中的内容。

然而，读取部分不想工作，我不确定如何调用该方法以使其不断侦听服务器套接字并对服务器作出反应？我尝试在 doInBackGround 返回之前创建一个线程，但随后应用程序开始工作几秒钟，由于内存不足而强制关闭？我需要一个线程来持续监听吗？

正如您可能猜到的那样，整个要点是进行聊天，因此 read 方法最终应该更新我的活动类中的 textView。发送方法正在“工作”，但并不像它应该的那样，尽管这可能就像我之前所说的服务器在做一些时髦的业务。

另一个问题是，是否可以像我一样将读取作为一种方法，或者当服务器发送数据然后调用该方法时是否必须做出反应？

编辑 我现在已经将读取部分或至少其中一些移动到了 doInBackGround，所以现在

    dis = new BufferedReader(new InputStreamReader(socket.getInputStream()));

    message = dis.readLine();
    Log.i("AsynkTask", "Read : "+message+" this is doInBackGround!");

这加上在服务器中简单地硬编码打印行的更改使我在客户端中读取了该行，所以我猜它现在工作得很好。

看起来怎么样？这段代码完全是垃圾吗？应该以其他方式完成吗？得到了我的功能，但可以这么说，学习做得更好也不错:)。

Answer 1

您应该在 AsyncTask 的 doInBackground() 方法中对 Socket 进行写入和读取操作，因为两者都需要时间并且可能会阻塞主 (UI) 线程。我不知道你如何调用上面的 write() 方法，但你可能还想看看这个 可能相关的问题。