asp.net 5 / mvc 6 中的 PushStreamContent 不起作用

Question

我正在尝试将使用 PushStreamContent 的 web api 项目（经典 web.config 项目）迁移到最新的 asp.net 5 web 应用程序（project.json）。

我的问题是我无法让 PushStreamContent 工作。

当我使用这个 api 控制器时，结果将以 json 格式结束，而不是流：

[Route("api/[controller]")]
public class EventsController : Controller
{
    private static readonly ConcurrentQueue<StreamWriter> s_streamWriter = new ConcurrentQueue<StreamWriter>();

   [HttpGet]
    public HttpResponseMessage Get(HttpRequestMessage request)
    {
         HttpResponseMessage response = request.CreateResponse();
        response.Content = new PushStreamContent(new Action<Stream, HttpContent, TransportContext>(WriteToStream), "text/event-stream");
        return response;
    }

    private void WriteToStream(Stream outputStream, HttpContent headers, TransportContext context)
    {
        var streamWriter = new StreamWriter(outputStream) {AutoFlush = true};
        s_streamWriter.Enqueue(streamWriter);
    }
}

如果我更改控制器操作以返回任务并将 PushStreamContent 包装在 MyPushStreamResult 类中 - 像这样：

[HttpGet]
public async Task<IActionResult> Get(HttpRequestMessage request)
{
    var stream = new PushStreamContent(new Action<Stream, HttpContent, TransportContext>(WriteToStream), "text/event-stream");
    return new MyPushStreamResult(stream, "text/event-stream");
}

public class MyPushStreamResult : ActionResult
{
    public string ContentType { get; private set; }
    public PushStreamContent Stream { get; private set; }
    public MyPushStreamResult(PushStreamContent stream, string contentType)
    {
        Stream = stream;
        ContentType = contentType;
    }
    public override async Task ExecuteResultAsync(ActionContext context)
    {
        var response = context.HttpContext.Response;
        response.ContentType = ContentType;
        await Stream.CopyToAsync(response.Body);
    }
}

对我的控制器操作的请求现在返回一个流，但该流在服务器端关闭或包含大量数据之前没有刷新。当我将数据推送到 PushStreamContent 输出流时，我会在每次写入文本后刷新，但我猜刷新不在 response.Body 流上。

我想念什么？找不到任何具有 asp.net 5 结构的示例。

Answer 1

HttpResponseMessage 在 ASP.NET 5 中没有被特殊处理，除非您使用 Microsoft.AspNet.Mvc.WebApiCompatShim 包。如果您可以使用 ASP.NET 5 功能来做类似的事情并且创建该包以支持向后兼容性，则不推荐使用此包。

因此，由于 HttpResponseMessage 不被认为是特殊的，它被 JsonOutuptFormatter 呈现为 json，就像任何其他 .NET 对象一样

您目前可以通过HttpContext.Response.Body 属性直接访问响应流，而不是PushStreamContent，因此您可以直接写入流。

更新：
Web API 中的PushStreamContent 允许您直接写入响应流。这种类型是创建的（由 Web API 团队创建，不作为 System.Net.Http 库的一部分存在，所有其他内容类型都存在），因此可以直接写入流，例如，从控制器或过滤器等。 PushStreamContent 是StreamContent，它只允许您提供一个 Stream 对象，然后主机层从源流中“复制”数据（如“拉”数据）。 PushStreamContent 本身也没什么特别的。可以编写自己的类型，该类型派生自 HttpContent。

总而言之，PushStreamContent 允许直接写入响应流，在 ASP.NET 5 中我们可以直接访问流，因此您可以写入它。

更新：
在非常基本的形式（正确，您可以转换为可测试性的 actionresult），以下应该可以工作。

[HttpGet]
public Task Get()
{
    HttpContext.Response.ContentType = "text/event-stream";
    var sourceStream = // get the source stream
    return sourceStream.CopyToAsync(HttpContext.Response.Body);
}