FileStreamでWriteAsyncを利用したファイルの書き込みについて

Question

ファイルのアップロードするプログラムを作成しているのですが、
ファイルアップロードはできるのですがファイルが壊れてしまって開けない状態になってしまいます。

下記ソースでファイルはできるのですが壊れています。
よろしくお願いします。

var stream = Request.InputStream; //1mbづつアップされる。
var position = Int32.Parse(Request.Headers["ChunkPosition"]);

var bytes = ReadToEnd(InputStream);

if (bytes.Length > 0)
{
using (FileStream fs = new FileStream(_path, FileMode.Open, FileAccess.Write, FileShare.Write, bytes.Length, true))
{
fs.Seek(position, SeekOrigin.Begin);
fs.WriteAsync(bytes, 0, bytes.Length);
}
}

   public static byte[] ReadToEnd(System.IO.Stream stream)
    {
        long originalPosition = 0;

        if (stream.CanSeek)
        {
            originalPosition = stream.Position;
            stream.Position = 0;
        }

        try
        {
            byte[] readBuffer = new byte[4096];

            int totalBytesRead = 0;
            int bytesRead;

            while ((bytesRead = stream.Read(readBuffer, totalBytesRead, readBuffer.Length - totalBytesRead)) > 0)
            {
                totalBytesRead += bytesRead;

                if (totalBytesRead == readBuffer.Length)
                {
                    int nextByte = stream.ReadByte();
                    if (nextByte != -1)
                    {
                        byte[] temp = new byte[readBuffer.Length * 2];
                        Buffer.BlockCopy(readBuffer, 0, temp, 0, readBuffer.Length);
                        Buffer.SetByte(temp, totalBytesRead, (byte)nextByte);
                        readBuffer = temp;
                        totalBytesRead++;
                    }
                }
            }

            byte[] buffer = readBuffer;
            if (readBuffer.Length != totalBytesRead)
            {
                buffer = new byte[totalBytesRead];
                Buffer.BlockCopy(readBuffer, 0, buffer, 0, totalBytesRead);
            }
            return buffer;
        }
        finally
        {
            if (stream.CanSeek)
            {
                stream.Position = originalPosition;
            }
        }
    }

Answer 1

using (FileStream fs = new FileStream(_path, FileMode.Open, FileAccess.Write, FileShare.Write, bytes.Length, true))
{
    fs.Seek(position, SeekOrigin.Begin);
    fs.WriteAsync(bytes, 0, bytes.Length);
}

WriteAsyncは、非同期にファイル書き込みを行うものなので、メソッド自体は即座に終了します
書き込みが始まらない／終わらないうちにFilestreamがCloseされるため、ファイルは壊れてしまいます

Comments

[punineko]

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

非同期で1mbづつファイルを書き込む処理になっております。
最初のpositionに開始位置が入ってきて1mbづつファイルに書き込みすることになっています。

[y_waiwai]

ふつーにWriteでいいんじゃないでしょうか

[punineko]

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

にしてもファイルが壊れていました。
ということはストリームで送られてくるところで壊れている可能背のほうが大きいですかね。

[punineko]

２mbのファイルを書き込む際にバイナリを確認すると前半１mb分が空っぽになっていまいた。

[YAmaGNZ]

受信したものをそのままそれぞれファイルへ書き込み(1.tmp、2.tmp
って感じ)、全受信終了後に再構築(copy 1.tmp + 2.tmp 受信ファイル名）すればいいのでは？

[y_waiwai]

書き込むデータがどうなってるか確認しましょう。
そこのWriteのせいで壊れるってことはないはずです

[punineko]

ご回答ありがとうございます。
前任者が毎回ファイルを作成するロジックにしており
ファイルの中身が消して書き込むという感じになっておりました。
ファイルサイズは指定されたサイズで作成されるため気づきませんでした。
皆様ありがとうございました。