捕获 BluetoothSocket InputStream.read() 超时的线程

Posted 2023-02-25

【中文标题】捕获 BluetoothSocket InputStream.read() 超时的线程

【英文标题】：Thread to catch a BluetoothSocket InputStream.read() timeout

【发布时间】：2012-12-09 03:46:41

【问题描述】：

我一直使用InputStream.read( byte[] b, int off, int len ) 方法读取数据，但现在遇到了超时问题。我有时会期望读取超时，并且应该让程序在超时后进行相应的调整。我试图实现一个线程，但我对线程一无所知，无法让它工作。我还想补充一点，这个线程正在在另一个线程中初始化。我不确定这意味着什么，但它可能会导致问题。

我的初始代码在我需要阅读的大部分时间都有效，但每当我期待超时时，我的程序就会在read() 调用时冻结并且永远不会超时。当我实现这个新代码时，我的初始代码工作的时间现在超时了。我使用Thread.wait(500)，我假设它是500 毫秒，但是我找不到任何Javadocs，包括wait() 函数。 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

【参考方案1】：

蓝牙聊天示例在这方面确实很差，您应该使用输入扫描器而不是 mmInStream.read。这是我使用的，它工作得相当好......

对于您的用例，您跳过整个缓冲区和字节并写入和读取（当您使用扫描仪和 inputstreamreader 为您处理这些内容时，无需使用其中任何一个）...换句话说，如下代码会为您处理所有这些。我将您的分隔符更改为 CRLF。下面的代码所做的是您发送一个字符串，它会写入然后读取。如果您不需要向远程设备发送任何内容，只需从 scan = new Scanner 开始。每次读取一行并以 \r\n 结尾时，它会将其存储在字符串 instring 中。

所以如果你想发送“a”，你会写

String readIn = beginListenForData("a");

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;

【讨论】：

谢谢，还没有让它工作，但这似乎是要走的路。

@JuiCe 确实 NP，使用扫描仪和输入流阅读器确实比尝试实现自己的缓冲阅读器容易得多，这看起来就像你正在尝试做的事情（相信我，已经做到了） ...

似乎无法正常工作，如果您可以花一些时间检查一下，我编辑了我的帖子。谢谢

仍然无法正常工作，但不要担心我会破解它。感谢您的宝贵时间