Android使用AsyncTask中Socket通讯与CallBack回调发现的问题

Vaccae

发布于 2019-07-25 14:41:09

1.2K0

发布于 2019-07-25 14:41:09

文章被收录于专栏：微卡智享微卡智享

前言

最近自己的程序在利用AsyncTask通过Socket获取实时数据，然后通过CallBack函数通知主进程更新UI中，发现了一个奇怪的问题，后来通过变通的方式修改了解决，不过问题的原因现在还没全搞明白，这一篇主要就是记录一下。

问题描述

这里我只写出AsyncTask的这些代码，讲述一下

   @Override
    protected String doInBackground(String... strings) {
        String tranname=strings[0];
        String transdata=strings[1];
        String recvData="";
        try {
            //连接SOCKET客户端
            socketinfo=dataTransSocket.SocketConnect(msyscfg);
            if (socketinfo.retno != -1) {
                clientData=new CSocketClientData();
                clientData.transName=tranname;
                clientData.data=transdata;
                //获取数据
                recvData=dataTransSocket.SocketSenduntilRecvStr(clientData);
                dataTransSocket.SocketDisconnect();
            } else {
                recvData=socketinfo.retmsg;
            }

        } catch (Exception e) {
            e.printStackTrace();
            Log.i("socket", e.getMessage());
            recvData=e.getMessage();
        }
        return recvData;
    }

    @Override
    protected void onPostExecute(String recvdata) {
        super.onPostExecute(recvdata);

        mnetinfocallback.onNetinfoCallBackOver(clientData.transName, recvdata);

    }

主程序界面的回调方法

上面代码中，Socket在正常情况下获取到数据后都可以直接调用下面的回调方法把数据传递回去，在后面测试过程中，我们把Socket的服务端关闭后，让其Socket的连接失败，照上图的话应该直接在回调函数中用Toast提示出返回的信息了。

结果我们在测试中发现，Socket连接失败后程序直接崩溃了，如下图

调试中我们打开了LogCat看了一下，上面写着onPostExecute的问题

然后我们加入断点进行跟踪，发现启用回调函数后并没有在主进程中进来，然后就崩溃了，这里我就直接在网上找找相关的资料后也没查出来什么东西，不过在一篇文章里看到了下图说

解决方法

按上面的理解，那我们把输出的参数做一个中间转换再试试，改后的代码为

    @Override
    protected String doInBackground(String... strings) {
        String tranname=strings[0];
        String transdata=strings[1];
        String recvData="";
        try {
            //连接SOCKET客户端
            socketinfo=dataTransSocket.SocketConnect(msyscfg);
            if (socketinfo.retno != -1) {
                clientData=new CSocketClientData();
                clientData.transName=tranname;
                clientData.data=transdata;
                //获取数据
                recvData=dataTransSocket.SocketSenduntilRecvStr(clientData);
                recvData=mnetinfocallback.Success + "|" + recvData;
                dataTransSocket.SocketDisconnect();
            } else {
                recvData=mnetinfocallback.Fail + "|" + socketinfo.retmsg;
            }

        } catch (Exception e) {
            e.printStackTrace();
            Log.i("socket", e.getMessage());
            recvData=mnetinfocallback.Fail + "|" + e.getMessage();
        }
        return recvData;
    }


    @Override
    protected void onPostExecute(String recvdata) {
        super.onPostExecute(recvdata);

        String[] strings=recvdata.split("\\|");
        if (strings[0].equals(mnetinfocallback.Success)) {
            if (!strings[1].equals("")) {
                Log.i("post", strings[1]);
                mnetinfocallback.onNetinfoCallBackOver(clientData.transName, strings[1]);
            }
        } else {
            mnetinfocallback.onNetinfoCallBackOver(mnetinfocallback.Fail, strings[1]);
        }
    }

我们重新运行后，发现正常弹出问题了