bluetoothSocketを使ったinputStream でタイムアウトを検出したい

Question

前提・実現したいこと

初心者なので、変な質問をしているかもしれませんが、ご容赦ください
Androidを使って、デジタル秤からblueoothで、通信させて計量データを加工表示するプログラムを作りましたが、通信が切れた場合の再接続処理を追加したいのですが、やり方が判りません
ご教授お願いします

以下ソースコード　inputStream.read(incomingBuff)　でデータの入力を待ち受けており、何も入力がないと、そのままになって処理が停止状態になります

発生している問題・エラーメッセージ

エラーメッセージ

該当のソースコード

Threadで動作
以下抜粋
                        inputStream = bluetoothSocket.getInputStream();
                        outputStrem = bluetoothSocket.getOutputStream();

                        while (true) {

                            if (Thread.interrupted()) {
                                break;
                            }

                            // Send Command
                           String command = "Q\r\n";
                           outputStrem.write(command.getBytes());
                            Thread.sleep(1000);
                            // Read Response
                            int incomingBytes = inputStream.read(incomingBuff);
                            byte[] buff = new byte[incomingBytes];
                            System.arraycopy(incomingBuff, 0, buff, 0,incomingBytes);
                            String s = new String(buff, "US-ASCII");

                            計算処理して、表示処理に渡す


                            }

試したこと

ググってみましたが、わかりませんでした・・・・・。

補足情報（FW/ツールのバージョンなど）

ここにより詳細な情報を記載してください。

Comments

[jimbe]

Bluetooth が切れても inputStream.read は(incomingBytes == -1で)終了しないのでしょうか?

[eigyou]

すいません　説明の仕方が悪かったです
Bluetoothの接続が切れた場合は、終了して再接続します
例　秤は、RS232Cで接続されており、秤の電源が切れていて、Bluetoothの接続はされている
要求コマンドを出すが、秤が切れているので、RESがありません
この後、秤の電源を入れる　秤には、要求コマンドがきていないので、何も返さないです
結果、Android側待ち受けのまま　固まった状態になります

[eigyou]

んん　すいません　bluetoothSocketの動きが良くわかっていないのですが、入力データが無い場合は、-1を返すのでしょうか？（int incomingBytes = inputStream.read(incomingBuff);）
（以降の処理に問題がある）

[jimbe]

いえ, Bluetooth 接続した後に read 待ち状態で相手が切断すると返値 -1 で read が終了するのでは...と思ったためです.

[jimbe]

bluetoothSocket がどんなクラスなのか抜粋から分かりませんが, ソケットにタイムアウト設定が無いのでしたら, 別スレッドで時間を計って割り込みすればよいのではないでしょうか.

[eigyou]

setSoTimeout なさそうです
小生では、スレッドの処理難しいです　
割り込みで、ループ処理を停止できても、起動中未応答のSocketの停止って
？　別スレッドで、inputStream　処理させて、タイムアウトかなあ？
もう少し上達してから考えてみます

[jimbe]

read の直前でタイマースレッドを起動し, 時間が立ったら read で待っているスレッドに割り込み(interrupt)をかければ, read で InterruptedException が発生すると思いますので, それを catch してソケットを close 後, 再度openからリトライすればよいのかと思います.

[jimbe]

すいません, 検索してみましたが, InputStream.read は interrupt では InterruptedException は発生しないようです.
タイマースレッド側で直接ストリームやソケットを close する等して止める形になるようです.

[eigyou]

スレッド処理は、難しい。スレッド別処理からstopさせると、例外が発生
ソケットのcloseでも例外出るし　ちょっと無理っぽいです
色々コメントありがとうございます。
　取り合えず、固まったときは、人力で、アプリを再起動してもらいます

[jimbe]

「例外」はきちんと仕様として定義された"機能"です. 決して想定外の事象を言うものではありません.
必要な場合には故意に発生させたり, 処理の中止・継続・修正の判断に使用できます.

[dodox86]

閉じてしまった質問ですけど、read前にInputStreamのavailableメソッドであらかじめ読み出し可能かチェックできないかな、と思いました。

[eigyou]

実のところ、以下のコードで試したのですが、うまくいきませんでした
タイムアウトしなくても、単純チェックで、もう一度試してみます

int timeout = 0;
int maxTimeout = 8; // leads to a timeout of 2 seconds
int available = 0;
while((available = inputStream.available()) == 0 && timeout < maxTimeout) {
timeout++;
// throws interrupted exception
Thread.sleep(250);
}
byte[] incomingBuff = new byte[available];
int incomingBytes = inputStream.read(incomingBuff);
byte[] buff = new byte[incomingBytes];
System.arraycopy(incomingBuff, 0, buff, 0, incomingBytes);

[dodox86]

やはりそうですか（＜うまくいかない）　Bluetooth絡みはプロファイルや状態とか考える要素がたくさんあってハードにも依存しそうでしたので実は質問を注視していたものの、回答を避けていました。お役に立てずすみません。

[eigyou]

dodox86様
ありがとうございます。
コメントいただきました単純確認で、以下で、うまくいきました
かっこ悪く、再起動してもらわなくてもよくなりました
// Send Command
String command = "Q\r\n";
outputStrem.write(command.getBytes());
Thread.sleep(1000);
// Read Response
String s="1234";
if (inputStream.available() != 0) {
int incomingBytes = inputStream.read(incomingBuff);
byte[] buff = new byte[incomingBytes];
System.arraycopy(incomingBuff, 0, buff, 0, incomingBytes);
s = new String(buff, "US-ASCII");
}

[dodox86]

あれ、そうですか。availableが有効にセットされないようなBluetoothスタック関連の問題かな、なんて思ってました。ともあれ良かったです。回答をその旨編集いただけますとよろしいかと思います。

Answer 1

締めきってからの、dodox86様のコメントいただきました　読み出し前に、InputStream　availableメソッドを確認することで解決しました