socket通信による画像の複数回送信(android)

Question

socketで画像を転送するプログラムを作成しています。
以前の質問にて実装できたと思っていたのですが、一度きりの送受信しかできないことが発覚しました。複数回送受信するにはどうすればよいのでしょうか...以下に作成したプログラムの一部を示します。

public class ChatManager implements Runnable{
    private Socket socket = null;
    private Handler handler;
    byte[] pvbyte = null;//受信したプレビュー画像

    public ChatManager(Socket socket, Handler handler) {
        this.socket = socket;
        this.handler = handler;
    }

    private InputStream iStream;
    private OutputStream oStream;
    ByteArrayOutputStream bospv;
    InputStream is;
    private static final String TAG = "ChatHandler";

    @Override
    public void run() {
        try {

            iStream = socket.getInputStream();
            oStream = socket.getOutputStream();

            handler.obtainMessage(WiFiServiceDiscoveryActivity.MY_HANDLE, this).sendToTarget();

            bospv = new ByteArrayOutputStream();
            copyFile(iStream, bospv);//受信データをbospvにコピー
            pvbyte = bospv.toByteArray();
            handler.obtainMessage(WiFiServiceDiscoveryActivity.MESSAGE_READ, pvbyte).sendToTarget();//結果をアクティビティへ

        } catch (IOException e) {
            e.printStackTrace();
        } finally {
            try {
                socket.close();
            } catch (IOException e) {
                e.printStackTrace();
            }
        }
    }

    public void write(byte[] buffer) {
        is =  new ByteArrayInputStream(buffer);
        copyFile(is,oStream);
    }
    public static boolean copyFile(InputStream inputStream, OutputStream out) {
        byte buf[] = new byte[1024];
        int len;
        try {
            while ((len = inputStream.read(buf)) != -1) {
                out.write(buf, 0, len);

            }
            out.flush();
            out.close();
           inputStream.close();
        } catch (IOException e) {
            Log.d("debug", e.toString());
            return false;
        }
        return true;
    }
}

また、参考にした公式サンプルのソースは下記の通りです。

public class ChatManager implements Runnable {

    private Socket socket = null;
    private Handler handler;

    public ChatManager(Socket socket, Handler handler) {
        this.socket = socket;
        this.handler = handler;
    }

    private InputStream iStream;
    private OutputStream oStream;
    private static final String TAG = "ChatHandler";

    @Override
    public void run() {
        try {

            iStream = socket.getInputStream();
            oStream = socket.getOutputStream();
            byte[] buffer = new byte[1024];
            int bytes;
            handler.obtainMessage(WiFiServiceDiscoveryActivity.MY_HANDLE, this)
                    .sendToTarget();

            while (true) {
                try {
                    // Read from the InputStream
                    bytes = iStream.read(buffer);
                    if (bytes == -1) {
                        break;
                    }

                    // Send the obtained bytes to the UI Activity
                    Log.d(TAG, "Rec:" + String.valueOf(buffer));
                    handler.obtainMessage(WiFiServiceDiscoveryActivity.MESSAGE_READ,
                            bytes, -1, buffer).sendToTarget();
                } catch (IOException e) {
                    Log.e(TAG, "disconnected", e);
                }
            }
        } catch (IOException e) {
            e.printStackTrace();
        } finally {
            try {
                socket.close();
            } catch (IOException e) {
                e.printStackTrace();
            }
        }
    }

    public void write(byte[] buffer) {
        try {
            oStream.write(buffer);
        } catch (IOException e) {
            Log.e(TAG, "Exception during write", e);
        }
    }

}

原因はもともとのプログラムではwhile(true)で無限ループとなっていた受信待ち部分が書き換えたことにより消えてしまったことだと思うのですが、

whle(true){
 copyFile(iStream, bospv);//受信データをbospvにコピー
 pvbyte = bospv.toByteArray();
 handler.obtainMessage(WiFiServiceDiscoveryActivity.MESSAGE_READ, pvbyte).sendToTarget();//結果をアクティビティへ
}

とすると同じ画像を無限に取得し続けすぐにアプリが落ちます。また、

 while (true) {
                try {
                    // Read from the InputStream
                    bytes = iStream.read(buffer);
                    if (bytes == -1) {
                        Log.d(TAG, "loop end");
                        break;
                    }
                    bospv.write(buffer,0,bytes);
                } catch (IOException e) {
                    Log.e(TAG, "disconnected", e);
                }
            }
            pvbyte=bospv.toByteArray();
            handler.obtainMessage(WiFiServiceDiscoveryActivity.MESSAGE_READ, pvbyte).sendToTarget();

とするとbytesが-1になることがなくいつまでもobtainMessageが呼ばれません。
修正方法や構造の間違いなどご指摘お願いいたします。

(追記)
1回は送信できることを確認しているためsocket.close()後にまた新たにsocketやChatManagerを作成することで対応できないかと考えたのですがどうでしょうか。

Comments

[keicha_hrs]

Socket.IOタグはこの質問には関係ないので外しましょう。

Answer 1

Streamと名のつくものは、一連なりのデータと考えましょう。
順番にデータを読み込み、あるいは、順番にデータを書き込みます

順番にデータを読み込んでいって、データが尽きると、そこからはデータが読めなくなります
も一度最初からデータを読みたい場合は、
・ファイル位置のポインタを最初に設定し直す
・そのStreamを作成し直す
のいずれかの操作を行う必要があります

Comments

[Mustard]

おっしゃる通りでした。
socket.close後にクライアント側が
nHandler =new ClientSocketHandler(this.handler,groupOwnerAddress);
nHandler.start();
を呼び出すことで解決いたしました。
迅速な回答にお礼申し上げます。