美文网首页
DatagramSocket不能断开的问题排查

DatagramSocket不能断开的问题排查

作者: 路过麦田 | 来源:发表于2019-10-17 16:18 被阅读0次

    最近在重构蓝牙配网的时候,发现了一个问题,在完成wifi账号密码传输后,设备连接wifi,并将自己的ipv4地址在局域网中广播出来,android手机在收到广播后,可以得到设备在局域网中的ip地址,从而进行下一步的操作

    但是在android手机接收局域网广播的过程中,代码出现了问题,一般来说,使用DatagramSocket是这样的:

        DatagramSocket datagramSocket;
        String boxIPV4 = null;
        int port = 3005;
        byte[] message = new byte[1024];
        try {
            // 建立Socket连接
            datagramSocket = new DatagramSocket(port);
            DatagramPacket dp = new DatagramPacket(message, message.length);
            // 准备接收数据
            // datagramSocket.setSoTimeout(165000);
            datagramSocket.receive(dp);
            boxIPV4 = new String(dp.getData(), 0, dp.getLength(), "UTF-8");
        } catch (Exception e) {
            e.printStackTrace();
        }
    

    如果不设置超时时间,那线程就会一直堵在datagramSocket.receive(datagramPacket)这行,但是如果设置了超时时间,那如果是用户自己取消呢,所以就需要手动取消接收广播,像下面代码一样:

        try {
            if (datagramSocket != null && !datagramSocket.isClosed()) {
                datagramSocket.disconnect();
                datagramSocket.close();
            }
        } catch (Exception e) {
            e.printStackTrace();
        }
    

    但是奇怪的是,即使执行了上述的代码,socket也没有从receive方法处跳出来,反而出现了anr,查看了disconnect()以及close()两个方法的代码后,才明白,原来disconnect()方法加了synchronized关键字,而receive()方法也同样加了一个大大的synchronized代码块

        // DatagramSocket.java
    
        public void disconnect() {
            synchronized (this) {
                if (isClosed())
                    return;
                if (connectState == ST_CONNECTED) {
                    impl.disconnect ();
                }
                connectedAddress = null;
                connectedPort = -1;
                connectState = ST_NOT_CONNECTED;
                explicitFilter = false;
            }
        }
    
        public synchronized void receive(DatagramPacket p) throws IOException {
            synchronized (p) {
                if (!isBound())
                    bind(new InetSocketAddress(0));
    
                // BEGIN Android-changed
                if (pendingConnectException != null) {
                    throw new SocketException("Pending connect failure", pendingConnectException);
                }
                // END Android-changed
    
                ...
            }
        }
    

    receive方法还在等待接收数据,而disconnect方法又要断开连接,导致死锁,所以出现了anr,所以这里需要先close,然后再disconnect才行

        try {
            if (datagramSocket != null && !datagramSocket.isClosed()) {
                datagramSocket.close();
                datagramSocket.disconnect();
            }
        } catch (Exception e) {
            e.printStackTrace();
        }
    

    调整了close和disconnect的顺序后,就可以顺利跳出receive方法了

    网上也搜到了一篇类似的文章:
    https://blog.csdn.net/qq_35522272/article/details/54314289

    相关文章

      网友评论

          本文标题:DatagramSocket不能断开的问题排查

          本文链接:https://www.haomeiwen.com/subject/sihvmctx.html