4

メソッドを使用InputStream.read( byte[] b, int off, int len )してデータを読み込んでいますが、タイムアウトの問題が発生しました。読み取りのタイムアウトが予想される場合があり、タイムアウト後にそれに応じてプログラムを調整する必要があります。スレッドを実装しようとしましたが、スレッドについて何も知らず、機能させることができません。また、このスレッドが別のスレッド内で初期化されていることも付け加えておきます。これが何を意味するのかはわかりませんが、問題が発生する可能性があります。

私の最初のコードは、読む必要があるほとんどの時間は機能していましたが、タイムアウトが予想されるときはいつでも、私のプログラムはread()呼び出しでフリーズし、タイムアウトすることはありません。この新しいコードを実装すると、最初のコードが機能していた時間がタイムアウトになりました。私は500ミリ秒と仮定して使用Thread.wait(500)していますが、関数を含むJavadocが見つかりませんwait()。こことここ。

これに関連する他の投稿: 1、2、3。

のタイムアウトの宣言も調べましたが、ドキュメントBluetoothSocketのどこにも見つかりません。

私の最初のコードは次のようになります。

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

4

1 に答える 1

4

Bluetooth チャットの例は、この点で非常に貧弱です。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;
}
于 2012-12-21T15:39:05.333 に答える