Android Studio でソケット通信→画像の転送がしたい

Question

Android Studioでソケット通信のプログラムを組み、Android端末間で画像を転送するプログラムを作ろうとしています。手始めとしてクライアントから一回サーバーに送信するだけのプログラムです。
文章を送るプログラムを以前に自分で書いたので、そのコピーを改造して作っています。
しかし、実機デバッグがうまくいきません。

具体的には、サーバー側のonPostExecute()で、成功した時に表示する__"Succeeded! Sabrina Carpenter..."__がちゃんと画面に表示されますが、肝心の画像が表示されません。

パーミッションは問題ないはずです。
実機はそれぞれ Android 10, 9 の端末間での通信です。

考えられるのは
・クライアント側での ImageView -> byte[] の変換が間違っている
・サーバー側での byte[] -> Drawable の変換が間違っている
・byte[] 列が正しく送られていない
のどれかです。

以下問題のコードです。
#クライアントのプロジェクト

myClass.java

//AsyncTask doInBackgroundの引数になるオブジェクト
public class myClass{
    public String string;
    public byte[] bytes;

    public myClass(String s, byte[] b){
        this.string = s;
        this.bytes = b;
    }
}

MainActivity.java

public class MainActivity extends AppCompatActivity {
    ImageView image1;
    Button button1;
    String IPAddress;
    Activity activity;
    EditText editText;
    TextView tv;
    byte[] buff;

    @Override
    protected void onCreate(Bundle savedInstanceState) {
        super.onCreate(savedInstanceState);
        setContentView(R.layout.activity_main);

        //widget
        image1= (ImageView)this.findViewById(R.id.imageSabrina);
        button1 = (Button)this.findViewById(R.id.button1);
        activity = this;
        editText = (EditText)this.findViewById(R.id.textInput);
        tv = (TextView)activity.findViewById(R.id.tview1);

        buff = new byte[200000];

        button1.setOnClickListener(new View.OnClickListener() {
            @Override
            public void onClick(View v) {
                Drawable drawable = image1.getDrawable();

                //ImageViewをbyte[]に変換
                try {
                    ByteArrayOutputStream byteos = new ByteArrayOutputStream();
                    ObjectOutputStream objos = new ObjectOutputStream(byteos);
                    objos.writeObject(drawable);
                    objos.close();
                    buff = byteos.toByteArray();
                    byteos.close();
                } catch (IOException e) {
                    e.printStackTrace();
                    tv.setText(e.toString());
                }

                IPAddress = "";
                IPAddress += editText.getText().toString();

                myClass info = new myClass(IPAddress, buff);

                //ソケットの実行
                if(IPAddress != "") new ClientSock(activity).execute(info);
                else {
                    tv.setText("error : ↓SetIP here");
                }
            }
        });
    }
}

ClientSock.java

public class ClientSock extends AsyncTask<myClass, Void, String> {
    private Activity activity;
    DataOutputStream writer;

    public ClientSock(Activity activity1){ activity = activity1; }

    @Override
    protected String doInBackground(myClass... info){
        InetSocketAddress endpoint = new InetSocketAddress(info[0].string, 12345);

        //ソケットを生成しDataOutputStreamで送信処理
        try{
            Socket sock = new Socket();
            sock.connect(endpoint);
            writer = new DataOutputStream(sock.getOutputStream());
            writer.write(info[0].bytes, 0, info[0].bytes.length);
            sock.close();
            return "Succeeded in sending a message to " + info[0].string;
        }catch(IOException e){
            return e.toString() + "\nfailed to send a message to " + info[0].string;
        }
    }

    @Override
    protected void onPostExecute(String s){
        TextView tv = (TextView)activity.findViewById(R.id.tview1);
        tv.setText(s);
    }
}

サーバーのプロジェクト

MainActivity.java

public class MainActivity extends AppCompatActivity {
    Button button;
    Activity activity;
    ImageView imageView;
    Drawable drawable;

    @Override
    protected void onCreate(Bundle savedInstanceState) {
        super.onCreate(savedInstanceState);
        setContentView(R.layout.activity_main);

        //widget
        button = (Button)this.findViewById(R.id.button);
        activity = this;
        imageView = (ImageView)this.findViewById(R.id.receivedPicture);

        button.setOnClickListener(new View.OnClickListener() {
            @Override
            public void onClick(View v) {
                //ソケットの実行
                new ServerSock(activity).execute();
            }
        });
    }
}

######ServerSock

public class ServerSock extends AsyncTask<Void, Void, Drawable> {
    private Activity activity;
    InputStream input;
    ImageView imageView;
    TextView textView;

    public ServerSock(Activity activity1){ activity = activity1; }

    @Override
    protected Drawable doInBackground(Void... voids) {
        textView = (TextView) activity.findViewById(R.id.textview);
        try {
            //ソケットを生成し、InputStreamで通信処理
            ServerSocket SS = new ServerSocket(12345);
            Socket sock = SS.accept();
            input = new BufferedInputStream(sock.getInputStream());

            byte[] b = new byte[200000];
            byte[] tem = new byte[1024];
            int a;
            int count = 0;

            //byte配列を読み込む
            while((a = input.read(tem)) > -1){
                for(int i = 0; i < a; i++)  b[count + i] = tem[i];
                count += a;
            }
            input.close();
            sock.close();

            //byte[]を Drawableに変換
            ByteArrayInputStream byteis = new ByteArrayInputStream(b, 0, count);
            ObjectInputStream objis = new ObjectInputStream(byteis);
            Drawable drawable = (Drawable) objis.readObject();
            return drawable;
        } catch (IOException | ClassNotFoundException e) {
            e.printStackTrace();
            return null;
        }
    }

    @Override
    protected void onPostExecute(Drawable drawable) {
        //Drawableを imageviewにセット
        imageView = (ImageView) activity.findViewById(R.id.receivedPicture);
        imageView.setImageDrawable(drawable);
        textView.setText("Succeeded! Sabrina Carpenter...");
    }
}

ご返答お待ちしています。
よろしくお願いします。

Comments

[m.ts10806]

「Android Studio」をタグとして追加してください。

[XionCode]

ありがとうございます、修正しました。

[hoshi-takanori]

Drawable はたぶん送信できないので、画像データを送信する必要があると思います。

[XionCode]

そうでしたか…
Drawable から 画像データ を抽出・変換はできないでしょうか？

[hoshi-takanori]

どんな画像データを送りたいかにもよりますが、assets に画像ファイルを置いといて、それを送信するのが手っ取り早いのでは。

[XionCode]

あそっかassetsの画像を使えばいいんですね……
やってみます

[XionCode]

みなさんご回答ありがとうございました。
無事解決いたしました。

Answer 1

DrawableではなくBitmapで送ってみてはどうでしょうか。次のような修正で送信できるのではないかと思います。

• クライアントのMainActivity.java（一部）

        button1.setOnClickListener(new View.OnClickListener() {
            @Override
            public void onClick(View v) {
                Bitmap bitmap = ((BitmapDrawable) image1.getDrawable()).getBitmap();

                //Bitmapをbyte[]に変換
                try {
                    ByteArrayOutputStream byteos = new ByteArrayOutputStream();
                    bitmap.compress(Bitmap.CompressFormat.JPEG, 100, byteos);
                    buff = byteos.toByteArray();
                    byteos.close();
                } catch (IOException e) {
                    e.printStackTrace();
                    tv.setText(e.toString());
                }

• サーバーのServerSock.java（一部)

public class ServerSock extends AsyncTask<Void, Void, Bitmap> {

    （中略）

    @Override
    protected Bitmap doInBackground(Void... voids) {

    （中略）

            //byte[]を Bitmapに変換
            Bitmap bitmap = BitmapFactory.decodeByteArray(b, 0, count);
            return bitmap;
        } catch (IOException e) {
            e.printStackTrace();
            return null;
        }
    }

    @Override
    protected void onPostExecute(Bitmap bitmap) {
        //Bitmapを imageviewにセット
        imageView = (ImageView) activity.findViewById(R.id.receivedPicture);
        imageView.setImageBitmap(bitmap);
        textView.setText("Succeeded! Sabrina Carpenter...");
    }
}

---

（2020/07/09追記）
ServerSock.javaの受信部分、こんな感じでByteArrayOutputStreamを活用すれば、受信するデータサイズに依存しないようにできるんじゃないかと思います。

            ByteArrayOutputStream byteos = new ByteArrayOutputStream();
            byte[] tem = new byte[1024];
            int a;
            int count = 0;

            //byte配列を読み込む
            while ((a = input.read(tem)) > -1) {
                byteos.write(tem, 0, a);
                count += a;
            }
            input.close();
            sock.close();

            byte[] b = byteos.toByteArray();

Comments

[XionCode]

ありがとうございます。
bitmap.conpress()ですね。やってみます。

[XionCode]

報告遅くなりました。
bitmap.compress()を使ってみましたが、送信後にサーバーがおちてしまうようになりました。
bitmap.recycle()など、うまくいってないのでしょうか。

[keicha_hrs]

受信処理のバッファーが足りなくて、確保したbyte配列の領域外への書き込みをしようとしているのではありませんか？Android StudioでLogCatを確認すると、ArrayIndexOutOfBoundsExceptionが発生していませんか？

まずはClientSock.javaの「ソケットを生成しDataOutputStreamで送信処理」のところにブレークポイントを設定して、info[0].bytes.lengthがいくつになっているか（何バイト送信しようとしているか）確認してはどうでしょうか。

[XionCode]

お察しのとおりArrayIndexOutOfBoundsExceptionが発生していました。
　Bitmap bitmap = BitmapFactory.decodeByteArray(b, 0, count);
ここで発生していました。
また、いただいた追記の表現で試してみても発生しています。

[keicha_hrs]

なぜそこで発生するのか不思議です。送信したときのバイト数と、その処理を実行するときのcountの値が一致しているでしょうか？countを宣言したときに0を代入していますか？countが初期化されておらず、不適当な値がdecodeByteArray()に渡されているようなことはないでしょうか。

一応、私の手元で実験して問題なく画像転送できたコードを提示したつもりなのですが。

[XionCode]

ごめんなさい！
凡ミスでクライアントから送る側で大問題しでかしておりました。
すみません…
問題なくできましたので報告いたします。
ありがとうございました！