DatagramSocket不能断开的问题排查

最近在重构蓝牙配网的时候,发现了一个问题,在完成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

©著作权归作者所有,转载或内容合作请联系作者
平台声明:文章内容(如有图片或视频亦包括在内)由作者上传并发布,文章内容仅代表作者本人观点,简书系信息发布平台,仅提供信息存储服务。

推荐阅读更多精彩内容

  • 一、简历准备 1、个人技能 (1)自定义控件、UI设计、常用动画特效 自定义控件 ①为什么要自定义控件? Andr...
    lucas777阅读 10,620评论 2 54
  • 本文是对个人笔记中内容的整理,部分代码及图片来自互联网,由于不好找到原始出处,所以未加注明。如有痛感,联系删除。 ...
    yhthu阅读 17,511评论 5 33
  • DatagramPacket UDP在Socket网络中都是通过DatagramPacket的数据格式进行传输的,...
    Samuel_Tom阅读 8,762评论 0 1
  • 0.Android手机操作系统的四层架构? Applications , Application Framewor...
    lucas777阅读 12,376评论 0 16
  • LRU分析 一种缓存策略。根据最近使用频率,最近最少使用的也认为将来不怎么使用,所以缓存也就越容易清除。一般Lin...
    enjoycc97阅读 1,534评论 0 2