Android 在蓝牙套接字上设置超时

Android set timeout on a bluetooth socket

在使用 device.createRfcommSocketToServiceRecord(MY_UUID) 创建的蓝牙套接字上,我希望在没有任何消息到达一定时间后,到 运行 一些代码,但仍然能够尽快处理字节到达。

.setSoTimeoutdescription说明了我愿意做的事情:

With this option set to a non-zero timeout, a read() call on the InputStream associated with this Socket will block for only this amount of time. If the timeout expires, a java.net.SocketTimeoutException is raised, though the Socket is still valid.

看来这是将我的代码放在 catch 语句中的绝好机会。

但不幸的是,根据我的 Android Studio,.setSoTimeout 不适用于蓝牙插座。如果没有这种方法,我如何实现这样的功能?

Thread.sleep 显然也不是一个选项,因为我无法锁定线程。

无论如何,我用 Thread.sleep 解决了这个问题,方法是使用较小的睡眠间隔,因此尝试模仿 .setSoTimeout 操作:

  • 短暂休眠,检查传入数据,循环直到达到超时,然后执行超时代码。

我想有更好的解决方案,但目前有效。

当没有字节到达输入流时,给出的代码将每秒执行一次 "timeout code"(由 int timeOut 设置)。如果一个字节到达,则它会重置计时器。

// this belongs to my "ConnectedThread" as in the Android Bluetooth-Chat example
public void run() {
    byte[] buffer = new byte[1024];
    int bytes = 0;
    int timeOut = 1000;
    int currTime = 0;
    int interval = 50;
    boolean letsSleep = false;
    // Keep listening to the InputStream
    while (true) {
        try {
            if (mmInStream.available() > 0) {               // something just arrived?
                buffer[bytes] = (byte) mmInStream.read();
                currTime = 0;                               // resets the timeout

                // .....
                // do something with the data
                // ...

            } else if (currTime < timeOut) {               // do we have to wait some more?
                try {
                    Thread.sleep(interval);
                    } catch (InterruptedException e) {
                        // ...
                        // exception handling code
                    }
                currTime += interval;
                } else {                                   // timeout detected
                // ....
                // timeout code
                // ...
                currTime = 0;                              // resets the timeout
            }
        } catch (IOException e) {
            // ...
            // exception handling code
        }
    }
}