Android BluetoothSocket-超时

Question

我已经编写了用于连接外部附件的蓝牙API。该API的设计方式是，有一帮阻塞调用如getTime，setTime，getVolume，setVolume，等方式，这些工作是他们创造一个有效载荷发送，并调用一个名为方法sendAndReceive()，做一些准备工作，并最终做的以下：

byte[] retVal = null;
BluetoothSocket socket = getSocket();
// write
socket.getOutputStream().write(payload);
// read response
if(responseExpected){
    byte[] buffer = new byte[1024]; // buffer store for the stream
    int readbytes = socket.getInputStream().read(buffer);
    retVal = new byte[readbytes];
    System.arraycopy(buffer, 0, retVal, 0, readbytes);
}
return retVal;

问题在于，有时此设备会变慢或无法响应，因此我想在此呼叫上设置超时。我尝试了几种方法将此代码放入thread \ future任务并使其超时运行，例如：

FutureTask<byte[]> theTask = null;
// create new task
theTask = new FutureTask<byte[]>(
        new Callable<byte[]>() {

            @Override
            public byte[] call() {
                byte[] retVal = null;
                BluetoothSocket socket = getSocket();
                // write
                socket.getOutputStream().write(payload);
                // read response
                if(responseExpected){
                    byte[] buffer = new byte[1024]; // buffer store for the stream
                    int readbytes = socket.getInputStream().read(buffer);
                    retVal = new byte[readbytes];
                    System.arraycopy(buffer, 0, retVal, 0, readbytes);
                }
                return retVal;
            }
        });

// start task in a new thread
new Thread(theTask).start();

// wait for the execution to finish, timeout after 6 secs
byte[] response;
try {
    response = theTask.get(6L, TimeUnit.SECONDS);
} catch (InterruptedException e) {
    throw new CbtException(e);
} catch (ExecutionException e) {
    throw new CbtException(e);
} catch (TimeoutException e) {
    throw new CbtCallTimedOutException(e);
}
    return response;
}

这种方法的问题在于我无法在调用方法中重新抛出异常，并且由于某些方法抛出了异常，因此我想转发回API客户端，因此我无法使用此方法。

您可以推荐其他替代方法吗？谢谢！

Answer 1

为什么不尝试类似的东西

public class ReadTask extends Thread {
  private byte[] mResultBuffer;
  private Exception mCaught;
  private Thread mWatcher;
  public ReadTask(Thread watcher) {
    mWatcher = watcher;
  }

  public void run() {
    try {
      mResultBuffer = sendAndReceive();
    } catch (Exception e) {
      mCaught = e;
    }
    mWatcher.interrupt();
  }
  public Exception getCaughtException() {
    return mCaught;
  }
  public byte[] getResults() {
    return mResultBuffer;
  }
}

public byte[] wrappedSendAndReceive() {
  byte[] data = new byte[1024];
  ReadTask worker = new ReadTask(data, Thread.currentThread());

  try {
    worker.start();
    Thread.sleep(6000);
  } catch (InterruptedException e) {
    // either the read completed, or we were interrupted for another reason
    if (worker.getCaughtException() != null) {
      throw worker.getCaughtException();
    }
  }

  // try to interrupt the reader
  worker.interrupt();
  return worker.getResults;
}

这里有一个wrappedSendAndReceive()极端的情况，即线程调用可能由于某种原因而不是ReadTask的中断而被中断。我想可以在ReadTask中添加完成的位，以允许另一个线程测试读取是否完成或中断是由其他原因引起的，但是我不确定这样做的必要性。

还要注意的是，此代码确实包含数据丢失的可能性。如果6秒钟到期并且已读取了一些数据，则最终将被丢弃。如果要解决此问题，则需要一次在ReadTask.run（）中读取一个字节，然后适当地捕获InterruptedException。显然，这需要对现有代码进行一些重做以保持计数器并在接收到中断时适当调整读取缓冲区的大小。