首先分别介绍正确的做法和错误的做法,然后分析他们的不同和错误之处,以便读者在实现此功能时可避开误区
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两块代码块互相等待返回结果而导致死锁的可能。