使用 asynctask 从套接字返回一个对象

Question

我正在尝试保存通过套接字连接获得的集合。我使用AsyncTask 从具有集合的套接字读取消息。我的问题是我无法保存此消息。在OnpostExecute() 中没有显示 Log.d() 消息。如果我这样做ReceiveMsgAsyncTask().execute().get()，用户界面就会冻结。我已经阅读了许多类似的问题，但我找不到解决方案。如何保存从我的套接字收到的消息？提前谢谢..

private class ReceiveMsgAsyncTask extends AsyncTask<Object, Void, Object> {
    final Collection <String> col = new ArrayList<String>();
    Socket socket = null ;
    ObjectInputStream in = null;
    @Override
    protected Object doInBackground(Object... arg0) {
        // TODO Auto-generated method stub;
        Object msg = null;
         try {
                socket = new Socket(host,50000);
                in = new ObjectInputStream(socket.getInputStream());
                msg = in.readObject();
            } catch (UnknownHostException e) {
                // TODO Auto-generated catch block
                e.printStackTrace();
            } catch (IOException e) {
                // TODO Auto-generated catch block
                e.printStackTrace();
            } catch (ClassNotFoundException e) {
                // TODO Auto-generated catch block
                e.printStackTrace();
            }finally {
                try {
                    in.close();
                    socket.close();
                } catch (IOException e) {
                    // TODO Auto-generated catch block
                    e.printStackTrace();
                }
            }
        return msg;
    }

    protected void onPostExecute(Object result) {
        // TODO Auto-generated method stub
        Log.d("mesg","success");
        super.onPostExecute(result);
        col.addAll((Collection<?extends String>)result);
    }

这是服务器向客户端发送集合的方法

public void splitData(Master master,String client){
        int chunk=0;
        int chunckStart=0;
            BufferedReader br = null;
            ObjectOutputStream out = null;
            try {
                String sCurrentLine;
                br = new BufferedReader(new FileReader("input"));
                int numberOflines=0;
                while ((sCurrentLine = br.readLine()) != null) {
                    numberOflines++;
                }
                br.close();
                br = new BufferedReader(new FileReader("input"));
                for (int i=1;i<=master.numberOfWorkers;i++){
                    out = new ObjectOutputStream(incoming.getOutputStream());
                    Worker Mworker = new Worker(clientsList.get(i-1));
                    if (i==master.numberOfWorkers){
                        if (numberOflines%master.numberOfWorkers!=0)
                            chunk = ((numberOflines/master.numberOfWorkers)*i)+numberOflines%master.numberOfWorkers;
                        else chunk = ((numberOflines/master.numberOfWorkers)*i);
                    }
                    else chunk = ((numberOflines/master.numberOfWorkers)*i);
                    int counter = chunk;
                    while (counter>chunckStart) {
                        sCurrentLine = br.readLine();
                        System.out.println(sCurrentLine);
                        //Mworker.reduce(sCurrentLine, 1);
                        Mworker.getCollection().add(sCurrentLine);
                        counter--;
                    }
                    System.out.println("----------------------------------");
                    chunckStart = chunckStart +(numberOflines/master.numberOfWorkers);
                    System.out.println(Mworker.getWorkerName()+" has the list:");
                    //System.out.println(Mworker.getHashReduce());
                    System.out.println(Mworker.getCollection());
                    out.writeObject(Mworker.getCollection());//send chunk to the worker/client
                    //out.flush();
                    //out.close();
                }

            } catch (IOException e) {
                e.printStackTrace();
            } finally {
                try {
                    if (br != null) br.close();
                } catch (IOException ex) {
                    ex.printStackTrace();
                }
            }
            //Mworker.hashReduce
        //}
    }

Answer 1

请查看AsyncTask.get()的文档，其中明确说明

Waits if necessary for the computation to complete, and then retrieves its result.

因此，调用 'get' 否定了使用 asynctask 的全部理由。

你需要做的是：

1. 使用回调方法创建接口。
2. 让您的活动或片段实现该接口。
3. 让您的 ReceiveMsgAsyncTask 采用在其构造函数上实现该接口的对象。
4. 在 ReceiveMsgAsyncTask 的 onPostExecute 中调用回调方法，将结果传递给它。

现在常见的陷阱是，如果 Activity 关闭或以其他方式失效，会发生什么情况。这可能会导致崩溃和其他各种奇怪现象。

解决该问题的最简单方法是保留任何未完成的异步任务的副本，然后在您的活动或片段的 onPause 方法中取消。

Answer 2

我猜你的 Worker 类没有实现 Serializable

见Javadoc

只有支持 java.io.Serializable 接口的对象才能写入流。