asp.net web api 文件上传

首先分别介绍正确的做法和错误的做法，然后分析他们的不同和错误之处，以便读者在实现此功能时可避开误区

1正确的做法

public class AvaterController : BaseApiController

{

[HttpPost]

        public async Task<IHttpActionResult> UploadAvater(int userId)

        {

            AvatarBLL pictureBLL = new AvatarBLL(this.Request);

            await pictureBLL.UploadAvatar(userId);

            return Ok();

     }

//其他Action

}

public class AvatarBLL

{

private HttpRequestMessage HttpRequestMessage;

public AvatarBLL(HttpRequestMessage httpRequestMessage)

{

     this.HttpRequestMessage = httpRequestMessage;

}

public async Task UploadAvatar(int userId)

        {

            if (!HttpRequestMessage.Content.IsMimeMultipartContent("form-data"))

            {

                //抛异常

            }

//获得客户端传递到服务器的数据

            List<byte> list = new List<byte>();

            await HttpRequestMessage.Content.ReadAsMultipartAsync().ContinueWith(multipartContent =>

            {

                if (multipartContent.IsFaulted || multipartContent.IsCanceled)

                {

                    //抛异常

                }

                foreach (var content in multipartContent.Result.Contents)

                {

                    var b = content.ReadAsByteArrayAsync().Result;

                    list.AddRange(b);

                }

         });

//其他部分（将数据存入Mongodb以及其他的业务逻辑）

}

}

2错误的做法

public class AvaterController : BaseApiController

{

[HttpPost]

        public IHttpActionResult UploadAvater(int userId)

        {

            AvatarBLL pictureBLL = new AvatarBLL(this.Request);

            pictureBLL.UploadAvatar(userId);

            return Ok();

     }

//其他Action

}

public class AvatarBLL

{

private HttpRequestMessage HttpRequestMessage;

public AvatarBLL(HttpRequestMessage httpRequestMessage)

{

     this.HttpRequestMessage = httpRequestMessage;

}

public void UploadAvatar(int userId)

        {

            if (!HttpRequestMessage.Content.IsMimeMultipartContent("form-data"))

            {

                //抛异常

            }

//获得客户端传递到服务器的数据

            List<byte> list = new List<byte>();

            MemoryStream ms = new MemoryStream();

            try

            {

                 MultipartMemoryStreamProvider mmsp = new MultipartMemoryStreamProvider();

                 var task =                          HttpRequestMessage.Content.ReadAsMultipartAsync<MultipartMemoryStreamProvider>(mmsp, );

                 task.Wait();

                 var contents = task.Result.Contents;

                 foreach (var c in contents)

                 {

                    var b = c.ReadAsByteArrayAsync();

                    b.Wait();

                    list.AddRange(b.Result);

                 }

              }

              catch (AggregateException ex)

                 { }

//其他部分（将数据存入Mongodb以及其他的业务逻辑）

}

}

3 错误现象：

采用第二种方式，如果客户端上传到服务的数据量（调用UploadAvater上传的数据）小于服务端设置的缓冲区的大小，那么可正常上传文件，如果大于服务端设置的缓冲区的大小，则无法正常上传，调试服务端代码，当执行到task.Wait();这行语句时，客户端一直等待，直到客户端调用超时，永远也无法返回调用结果，发生了死锁！！！使用HttpRequestMessage.Content.ReadAsMultipartAsync<MultipartMemoryStreamProvider>(mmsp, 1000);设置缓冲区大小为1000bit。这个方法有几个重载的方法，其中一个是不显示设置缓冲区大小，那么缓冲区大小为默认的。

4 对第二种方法的错误点分析：

看Web api dll源码中的设置：

可以看出默认的缓冲区区大小为32*1024，即32K，那么上传超过32k而不设置缓冲区大小的情况下，为什么会发生死锁，而将缓冲区设置超过上传文件大小为什么不会发生死锁呢？不论是否将缓冲区大小设置的足够大，都有发生死锁的可能。

主要的方法见上图，在方法体中有下面这段代码：

这段代码的核心方法：

上面的方法，循环读取请求数据，当设置的缓冲区大小小于客户端发送到服务器的数据量时，要执行多次循环读取数据，每次循环读取数据都是调用两个异步方法：

然而，ReadAsMultipartAsync方法的返回值是Task<T>（T为 streamProvider），所以当调用Task.Wait()方法等待的时候，ReadAsMultipartAsync方法内部也在等待异步处理streamProvider返回结果，这样就造成了死锁。

5 第一种方法为什么不会出现死锁？

第一种方法使用await，实现同步机制，而没有调用Task.Wait()方法，这样就避免了A、B两块代码块互相等待返回结果而导致死锁的可能。

巴特西

asp.net web api 文件上传

最新文章

热门文章