線程捕獲BluetoothSocket InputStream.read（）超時

Question

我一直在使用InputStream.read(byte[] b, int off, int len)方法讀取數據，但現在已經遇到超時問題。我有時會期望讀取超時，並且應該讓程序在超時後進行相應的調整。我試圖實現一個線程，但我真的對線程一無所知，無法讓它工作。我還想補充說，這個線程正在被初始化在另一個線程。我不確定這是什麼意思，但它可能會導致問題。

我的初始代碼在我需要閱讀的大多數時間裏都有效，但是每當我期待暫停時，我的程序就會在read()的通話中凍結並永不超時。當我實現這個新代碼時，我最初的代碼工作的時間現在超時。我使用Thread.wait(500)，我假設它是500毫秒，但我找不到包括wait()函數的任何Javadoc。 Here和Here。

與此相關的其他帖子：1，2，3。

我也研究過聲明BluetoothSocket超時，但我在documentation的任何地方找不到它。

這是我最初的代碼如下所示：

public void run(int length) throws IOException { 
     buffer = new byte[1024]; 
     try { 
       bytes = mmInStream.read(buffer, 0, length); 
       mHandler.obtainMessage(MainMenu.MESSAGE_READ, bytes, -1, buffer) 
         .sendToTarget(); 
     } catch (IOException e) { 
       Message msg = mHandler.obtainMessage(MainMenu.MESSAGE_TOAST); 
       Bundle bundle = new Bundle(); 
       bundle.putString(TOAST, "Device has disconnected from the Bluetooth Module."); 
       msg.setData(bundle); 
       mHandler.sendMessage(msg); 
       connectionLost(); 
       BluetoothService.this.start(); 
     } 

這是我試圖實現：

public void run(int length) throws IOException { 
     buffer = new byte[1024]; 
     length1 = length; 
     Thread myThread = new Thread(new Runnable() { 
      public void run() { 
       try { 
        bytes = mmInStream.read(buffer, 0, length1); 
       } catch (IOException e) { 
        // TODO Auto-generated catch block 
        e.printStackTrace(); 
       } 
      } 
     }); 

     synchronized (myThread) { 
      myThread.start(); 
      try { 
       myThread.wait(500); 
       if(myThread.isAlive()) { 
        mmInStream.close(); 
        Log.i("InStream", "Timeout exceeded!"); 
       } 
      } catch (InterruptedException e) { 
       // TODO Auto-generated catch block 
       e.printStackTrace(); 
      } 

     } 
     try { 
      myThread.run(); 
      mHandler.obtainMessage(MainMenu.MESSAGE_READ, bytes, -1, buffer) 
         .sendToTarget(); 
     } catch (IOException e) { 
       Message msg = mHandler.obtainMessage(MainMenu.MESSAGE_TOAST); 
       Bundle bundle = new Bundle(); 
       bundle.putString(TOAST, "Device has disconnected from the Bluetooth Module."); 
       msg.setData(bundle); 
       mHandler.sendMessage(msg); 
       connectionLost(); 
       BluetoothService.this.start(); 
     } 

編輯：

所以我試圖重新

buffer = new byte[1024]; 
bytes = mmInStream.read(buffer, 0, length); 

我也做了以下內容：

Scanner scan = new Scanner(new InputStreamReader(mmInStream)); 
String readIn; 
try { 
    readIn = scan.next(); 
    bytes = 5; // I tried with or without this, since I do not think it matters... 
    buffer = readIn.getBytes(Charset.forName("US-ASCII")); 
} 

在我的代碼後來我撥打這個電話....對不起編輯一遍，buf=read(5)呼叫轉到上面顯示。

byte[] buf = buffer; 
write(a); 
buf = read(5); 
Log.i(TAG, "Before buf[5]"); 
try { 
    buf[5] = '\0'; 
} catch(NullPointerException e) { 
    return false; 
} 

當我使用原來的方法，它通過這個buf[5]調用罰款。但是當我使用新方法時，它在那個位置給了我一個IndexOutOfBoundsException。我錯過了什麼嗎？預期的輸入應該是CMD\r\n

Answer 1

藍牙聊天的例子在這方面真的很差，您應該使用輸入掃描器而不是mmInStream.read。這是我使用的，它工作得相當好...

爲您的使用情況，你跳過整個緩衝區和字節，並寫和讀（當你使用掃描儀和inputstreamreader作爲那些手柄時不需要使用任何這些那些東西給你）......換句話說，下面的代碼會照顧你所有的東西。我將您的分隔符更改爲CRLF。下面的代碼做的是你發送一個字符串，然後寫入並讀取。如果你不需要發送任何東西到遠程設備，只需從scan = new Scanner開始。每次讀取一行並以\ r \ n結尾時，它都會將其存儲在字符串instring中。

所以，如果你想送「一」，你會寫

String readIn = beginListenForData("a"); 

的一個將在mmOutStream下發，然後掃描儀將讀取mmInStream並收集所有的字符，那麼一旦它看到一個CRLF它將返回它讀取的字符並將它們返回到readIn字符串中。合理？

private String beginListenForData(String msg0) { 
    msg0 += "\r"; //this adds a return character to the string, you can omit this if you just send an a and the remote device understands what that means. 
    String instring = ""; 
    try { 
     mmOutStream.write(msg0.getBytes()); 
    } catch (IOException ex) {    
     stop(); 
    } 
    scan = new Scanner(new InputStreamReader(mmInStream)); 
    scan.useDelimiter(Pattern.compile("[\\r\\n]+")); 
    instring = scan.next(); 
    scan = null; 
    return instring; 
}