ソケット通信の受信で、InputStreamの終了が認識出来ません。

質問

ソケット通信の受信で、InputStreamの終了が認識出来ません。

(1)下記のネット上で見つけたチャットクライアントのソース"ChatClient.java"を流用しました。
　http://www.saturn.dti.ne.jp/~npaka/android/SocketEx/index.html
(2000文字を超えるので掲載出来ません)
　チャットサーバもこのサイトのソースを実装しました。この組み合わせで送受信は確認しました。

(2)これに下記のjavaのオープンソースを実装して、バイト読み出しに変更します。
　【"java\io\InputStream.java"より】
　　public int read(byte b[]) throws IOException {　　//※１
　　　　return read(b, 0, b.length);　　　　　　//※２
　　}

　　public int read(byte b[], int off, int len) throws IOException {//※３
　　　　if (b == null) {
　　　　　　throw new NullPointerException();
　　　　} else if ((off < 0) || (off > b.length) || (len < 0) ||
　　　　　　　 ((off + len) > b.length) || ((off + len) < 0)) {
　　　　　　throw new IndexOutOfBoundsException();
　　　　} else if (len == 0) {
　　　　　　return 0;
　　　　}

　　　　int c = read();　　　　//※４
　　　　if (c == -1) {
　　　　　　return -1;
　　　　}
　　　　b[off] = (byte)c;

　　　　int i = 1;
　　　　try {
　　　　　　for (; i < len ; i++) {
　　　　　　c = in.read();
　　　　　　if (c == -1) {
　　　　　　　　break;
　　　　　　}
　　　　　　if (b != null) {
　　　　　　　　b[off + i] = (byte)c;
　　　　　　}
　　　　　　}
　　　　} catch (IOException ee) {
　　　　}
　　　　return i;
　　}

　・リンク先のソース中の入力ストリーム読み出し部の名前の付け替え
　size=in.read(w);　→　size=readsocket(w);

　・javaのオープンソース"java\io\InputStream.java"中の名前の付け替え
　　※１：public int readsocket(byte b[]) throws IOException {
　　※２：return readsocket2(b, 0, b.length);
　　※３：public int readsocket2(byte b[], int off, int len) throws IOException {
　　※４：int c = in.read();

(3)この変更を行うと、※４の“in.read()”で入力ストリームの終了の"-1"が入って来ず、forループから抜けなくなってしまいました。帰って来るのは送信したコードのみです。どこが悪いのでしょうか？

回答No.2

crossgate · ベストアンサー

crossgateです。
レスが遅くなりました。

>1byte以上データがあると、for文の中の※５の箇所で取り込むのですが、
>入力ストリームが無くなっても、終了コード(-1)を返して来ないので、
>次の入力ストリームを待ってしまいfor文から抜けません。

なるほど。
何でバイト読み込みを自分で実装しようとしているかは良くわかりませんが。。。

単にブロックされたくないだけなら、

c = in.read();
if (c == -1) {
　　break;
}

ではなくて、

if (in.available() == 0) {
　　break;
}
c = in.read();

ならどうでしょう？

お礼

>crossgateさん

ありがとうごさいます。こちらの意図通り動いてくれました。

>何でバイト読み込みを自分で実装しようとしているかは良くわかりませんが。。。

実は、このクライアント側のソケット通信プログラムをandroidに組み込んでいるのですが、その際に、
別のメニュー画面から起動するアクティビティとして実装しています。

このソケット通信画面を抜けてメニュー画面に戻る際に、スレッド起動された受信部はストリーム待ち
なので、そのスレッドが残ったままになってしまい、再度メニューから通信アクティビティを起動すると、
受信スレッドが重なって起動されてしまいました。

そこで100ms程度のタイムアウトで入力待ちを抜けて、スレッドの終了確認をする様に変更したのですが、
元のストリーム入力処理"in.read(w)"だと、データ受信中にタイムアウトとぶつかると、受信データの
配列への展開漏れが起きる恐れが有ったので、バイト単位の読込みに変更しようとして、この問題に
ぶつかりました。

ですが、"in.available()"を使うことで、タイムアウト処理が不必要になったので、元の形に戻して
シンプルなプログラムにする事が出来ました。

"-1"のチェックが使えない理由は何処に有るのか分かれば教えてください。それとも、そもそも
“public int read(byte b[], int off, int len) throws IOException{…}”を使う事が間違っていたのでしょうか？

回答No.3

crossgate

>"-1"のチェックが使えない理由は何処に有るのか分かれば教えてください。それとも、そもそも
>“public int read(byte b[], int off, int len) throws IOException{…}”を使う事が間違っていたのでしょうか？

理由は良く分かりません。

想像ですが、InputStream（もしくはそのサブクラス）のサブクラスをSocket用に作っていて、read()もそこでオーバーライドしているのかと。

つまり、元のソースはInputStream.read()を呼んでいる訳ではなくて、別のXXXXX.read()を呼んでいるんだとすると、read()が「-1」を返すための判定方法も違うだろうし、今回の話しは説明できると思います。

kn0100005さんは java\io\InputStream.java から取って来たんですよね？
java\net 辺りにそんな感じのものが無いかチェックしてみてください。

お礼

>crossgateさん

ありがとうごさいます。

探してみたところ“java\net\SocketInputStream.java”の中に、下記のメソッドが存在しました。

public int read(byte b[]) throws IOException {
return read(b, 0, b.length);
}

public int read(byte b[], int off, int length) throws IOException {
int n;

// EOF already encountered
if (eof) {
return -1;
}
・
・
略
・
}

ご指摘通り、実装するソースを間違えていた様です。

どうもありがとうございました。

回答No.1

crossgate

※４のread()は入力ストリームの先頭のバイトデータしか読み込んでいないからでは？
1byte以上データがあるとfor文の中にある「if (c == -1) { break; }」でブレークして「i」をreturnするだけのように見えますが。

補足

質問が間違っていたので訂正します。

===============================================================
※４の下のfor文の中の下記の一行ですが、

　c = in.read();　　　　　　// ※５（←コメント追記）

元々は“c = read(); ”で、実装の際に“c = in.read(); ”と修正した物です。

（３）の文中の"※４"は、"※５"になります。
===============================================================

＞crossgateさん

　回答ありがとうございます。

1byte以上データがあると、for文の中の※５の箇所で取り込むのですが、
入力ストリームが無くなっても、終了コード(-1)を返して来ないので、
次の入力ストリームを待ってしまいfor文から抜けません。

宜しくお願いします。