在Asp.net core返回PushStream

最近用asp.net core webapi实现了一个实时视频流的推送功能，在Asp.net中，这个是通过PushStreamContent来实现的。

基于对asp.net core的知识，随手写了一个（要求控制器继承自Controller基类）

[HttpGet]
public async Task Get()
{var response = HttpContext.Response;response.ContentType = "text/html";response.StatusCode = 200;var stream = HttpContext.Response.Body;while (true){await Task.Delay(1000);var content = DateTime.Now + @"<br>";var data = Encoding.Default.GetBytes(content);await stream.WriteAsync(data, 0, data.Length);await stream.FlushAsync();}
}

使用chrome调试这个接口时，发现它确实行之有效的将当前的时间推送到了浏览器的页面上。

然而，当我进一步的调试它的异常情况时，发现就算将chrome关掉，这个程序却依然在继续运行。从调试器中看到stream的状态为Aborted，已经识别到位终止的流了。

并且从VS的调试窗口也能看到异常信息：

但下面这两行就是不抛异常：

await stream.WriteAsync(data, 0, data.Length);
await stream.FlushAsync();

单单从接口的实现角度上来看，这个已经不合理了。这是一个很大的坑，功能看上去还是正确的，没有详细调试还看不出来。一个不留神就踩上了。不知道微软为什么要这么设计。

埋怨归埋怨，问题还是要解决的。我查看了下FileStreamResult的源码，发现它是靠HttpContext.RequestAborted来判断客户端是否终止了的。这是一个CancellationToken类型的对象，当客户端连接断开后，它就处于被取消的状态。

知道原因后，就可以知道如何修改我的程序了。

[HttpGet]
public async Task Get()
{var cancel = HttpContext.RequestAborted;var response = HttpContext.Response;response.ContentType = "text/html";response.StatusCode = 200;var stream = HttpContext.Response.Body;while (true){cancel.ThrowIfCancellationRequested();await Task.Delay(1000, cancel);var content = DateTime.Now + @"<br>";var data = Encoding.Default.GetBytes(content);await stream.WriteAsync(data, 0, data.Length, cancel);await stream.FlushAsync(cancel);}
}

再然后就是封装了，我这里将其封装为了一个PushStreamResult，这样就可以在PocoController中使用了。

class MyPushStreamResult :IActionResult
{Func<Stream, CancellationToken, Task> _pushAction;string _contentType;public MyPushStreamResult(Func<Stream, CancellationToken, Task> pushAction, string contentType){_pushAction = pushAction;_contentType = contentType;}public Task ExecuteResultAsync(ActionContext context){var response = context.HttpContext.Response;response.ContentType = _contentType;response.StatusCode = 200;return _pushAction(response.Body, context.HttpContext.RequestAborted);}
}

使用方法如下：

[HttpGet]
public IActionResult Get()
{return new MyPushStreamResult(pushData, "text/html");
}async Task pushData(Stream stream, CancellationToken cancel)
{while (true){if (cancel.IsCancellationRequested)return;await Task.Delay(1000, cancel);var content = DateTime.Now + @"<br>";var data = Encoding.Default.GetBytes(content);await stream.WriteAsync(data, 0, data.Length, cancel);await stream.FlushAsync(cancel);}
}

转载于:https://www.cnblogs.com/TianFang/p/8502770.html

在Asp.net core返回PushStream相关推荐

iactionresult 图片_从显式类型的ASP.NET Core API控制器（不是IActionResult）返回404
在ASP.NET Core 2.1中使用return null;解决了此问题: public ActionResult Get(int id) { Thing thing = GetThingFrom ...
asp.net core系列 38 WebAPI 返回类型与响应格式--必备
一.返回类型 ASP.NET Core 提供以下 Web API Action方法返回类型选项,以及说明每种返回类型的最佳适用情况: (1) 固定类型 (2) IActionResult (3) Ac ...
ASP.NET Core 2.2 基础知识(十四) WebAPI Action返回类型(未完待续)
要啥自行车,直接看手表 //返回基元类型public string Get(){return "hello world";} //返回复杂类型public Person Get() ...
客户要求ASP.NET Core API返回特定格式，怎么办？(续2)
前言前2次,我们都是假设客户需要返回不同的字符串格式. 但是,有可能客户要求的返回是非本文格式,比如文件流. 怎么办? 思路前提,当然还是使用同一API接口,不影响现有使用方式. 虽然ASP.NE ...
客户要求ASP.NET Core API返回特定格式，怎么办？(续)
前言上次,我们用客户就要求API的返回值属性名必须是PascalCase(如UserName),但是这些API需要同时提供给内部系统使用,默认都是CamelCase(如userName). 其实, ...
ASP.Net Core Web API 如何返回 File。
咨询区 Jan Kruse: 我想在 ASP.Net Web API 中返回 File 文件,我目前的做法是将 Action 返回值设为 HttpResponseMessage,参考代码如下: pub ...
客户要求ASP.NET Core API返回特定格式，怎么办？
当ASP.NET Core API提供给到外部系统使用时,在某些情况下,可能需要根据这些外部系统的要求来格式化数据. 比如,客户就要求API的返回值属性名必须是PascalCase(如UserName ...
asp.net core 使用newtonsoft完美序列化WebApi返回的ValueTuple
由于开发功能的需要,又懒得新建太多的class,所以ValueTuple是个比较好的偷懒方法,但是,由于WebApi需要返回序列化后的json,默认的序列化只能将ValueTuple定义的各个属性序列 ...
ASP.NET Core WebAPI控制器返回类型的最佳选项
ASP.NET Core WebAPI控制器返回类型的最佳选项原文:ASP.NET Core WebAPI控制器返回类型的最佳选项前言从.NET Core 2.1版开始,到目前为止,控制器操作可 ...

在Asp.net core返回PushStream

在Asp.net core返回PushStream相关推荐

最新文章

热门文章