11

我正在尝试将使用 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 结构的示例。

4

1 回答 1

8

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

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

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

更新：
PushStreamContent在 Web API 中允许您直接写入响应流。这种类型是由 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);
}
于 2015-11-24T17:10:55.693 回答