WPF → AndroidのTCP通信で巨大なファイルを送るとデータが壊れる

Question

発生している問題

WPFアプリ(Windows)からAndroidアプリに向けてTCP通信を実装しています。
具体的には、
0. テキストかファイルか
0. ファイル名
0. 0xFF
0. ファイルサイズ
0. 0xFF
0. ファイルの中身

という構造で転送をしています。その逆も実装していて、AndroidアプリからWPFアプリへの送信はうまくいくのですが、WPFからAndroidへの送信がうまくいきません。小さいファイルなら正常に転送できますが、大きなファイル(大体5MB以上)になると壊れてしまいます。

試したこと

受信側で読み取るたびにスレッドを1ミリ秒くらい止めると少し大きめのファイルでも転送できるようになります。しかし、それだと転送速度が遅くなるので、他の方法を探しています。
他に、バッファーサイズを変えたりしましたが、だめでした。

ソースコード

送信側(WPF)

                    var client = new TcpClient(ipAddress, 60001);
                    client.SendTimeout = 10000;

                    var ous = client.GetStream();
                    var ins = new FileStream(FilePaths[0], FileMode.Open);

                    var bytes = new byte[8192];
                    var nameBytes = Encoding.UTF8.GetBytes(System.IO.Path.GetFileName(FilePaths[0]));
                    var sizeBytes = BitConverter.GetBytes(ins.Length);
                    var firstBytes = new byte[bytes.Length - 1 - nameBytes.Length - 1 - sizeBytes.Length - 1];

                    ins.Read(firstBytes, 0, firstBytes.Length);

                    bytes[0] = SendWindow.TYPE_FILE;
                    Array.Copy(nameBytes, 0, bytes, 1, nameBytes.Length);
                    bytes[nameBytes.Length + 1] = 255;
                    Array.Copy(sizeBytes, 0, bytes, nameBytes.Length + 2, sizeBytes.Length);
                    bytes[nameBytes.Length + 1 + sizeBytes.Length + 1] = 255;
                    Array.Copy(firstBytes, 0, bytes, nameBytes.Length + 1 + sizeBytes.Length + 2, firstBytes.Length);

                    ous.Write(bytes, 0, bytes.Length);

                    var buffer = new byte[8192];
                    do
                    {
                        var len = ins.Read(buffer, 0, buffer.Length);
                        if (len == 0 || IsSendingFile == false) break;
                        ous.Write(buffer, 0, buffer.Length);
                    } while (true);

                    ous.Close();
                    ins.Close();
                    client.Close();

受信側(Android)

                val socket = svSocket.accept()

                val ins = socket.getInputStream()

                val isFile = ins.read().toByte() == DataType.FILE

                if (isFile) {
                    val nameBytes = mutableListOf<Byte>()
                    do {
                        val byte = ins.read()
                        if (byte == 255) break
                        nameBytes.add(byte.toByte())
                    } while (true)
                    val name = String(nameBytes.toByteArray())

                    val progressN = NotificationCompat.Builder(context, CHANNEL_PROGRESS)
                        .setContentTitle("${name}を受信中")
                        .setColor(Color.parseColor("#87cefa"))
                        .setSmallIcon(R.drawable.tasktrayicon)
                        .setOnlyAlertOnce(true)
                        .setOngoing(true)

                    context.notificationManager.notify(PROGRESS_NOTIFICATION_ID, progressN.build())

                    val sizeBytes = mutableListOf<Byte>()
                    do {
                        val byte = ins.read()
                        if (byte == 255) break
                        sizeBytes.add(byte.toByte())
                    } while (true)
                    sizeBytes.reverse()
                    val size = ByteBuffer.wrap(sizeBytes.toByteArray()).long

                    val bufferSize = DEFAULT_BUFFER_SIZE

                    val dir = File(context.getExternalFilesDir(null), "Download")
                    dir.mkdirs()
                    val file = File(dir, name)
                    val ous = BufferedOutputStream(FileOutputStream(file))

                    val packetCount = size.toDouble() / bufferSize

                    val buffer = ByteArray(bufferSize)
                    var packet = 0
                    do {
                        val len = ins.read(buffer)
                        if (len == -1) break
                        ous.write(buffer, 0, buffer.size)
                        Thread.sleep(1)
                        packet++
                        if (packet % 1000 == 0 && packetCount != 0.toDouble()) {
                            val progress = packet / packetCount * 100
                            progressN.setProgress(100, progress.toInt(), false)
                                .setContentText("${String.format("%.2f", packet / packetCount * 100)} %")
                            context.notificationManager.notify(PROGRESS_NOTIFICATION_ID, progressN.build())
                        }
                    } while (true)

                    ous.close()
                    ins.close()

環境

Visual Studio Community 2019 v16.5.1
Android Studio 3.6.1
Android 10(実機)

Answer 1

   val len = ins.read(buffer)
   if (len == -1) break
   ous.write(buffer, 0, buffer.size)

read は buffer に取り込んだバイト数を返します.
なぜなら, 必ずしも buffer.size 分を読み込めるとは限らないからです.
ですので, write も len バイト数分しか書き込まないようにするべきです.

(そしてこれは恐らく送信側も同じです.)

スレッドを1ミリ秒くらい止めると少し大きめのファイルでも転送できる

のは, その間に buffer.size 分のデータが貯まるからでしょう.

Comments

[chika3742]

そういうことでしたか、完全に見落としていました。。。
ありがとうございます！