ASP.NET Core迁移后PushStreamContent无法正常工作

• PushStreamContent是.NET Framework下ASP.NET Web API 2的内置类型，ASP.NET Core重构了整套HTTP响应管道，没有对这个类型做原生兼容，直接照搬旧代码无法正常被管道识别执行。
• 原代码本身存在适配性隐患：回调方法用了async void签名、异步IO操作混用.Result同步阻塞，在.NET Framework的特殊同步上下文下可能侥幸运行，到ASP.NET Core环境下会出现管道无法跟踪回调执行状态、请求提前结束、线程死锁等问题，直接导致流传输中断。
• 原代码重复打开了两次Blob存储流，第一次打开的流既未使用也未释放，存在资源泄漏问题。

ASP.NET Core下不需要强行适配旧的PushStreamContent逻辑，直接用原生流式响应API实现即可，性能比旧实现更好，代码更简洁：

[HttpGet("wav-stream")]
public async Task GetWavAudioStream([FromQuery] string inputSessionId)
{
    var fileName = $"{inputSessionId}.wav";
    var targetBlob = cloudBlobContainer.GetBlockBlobReference(fileName);
    
    if (!await targetBlob.ExistsAsync())
    {
        Response.StatusCode = StatusCodes.Status404NotFound;
        return;
    }
    // 设置响应音频头
    Response.ContentType = "audio/wav";
    // 如需触发浏览器下载，可放开下面注释
    // Response.Headers.ContentDisposition = new ContentDispositionHeaderValue("attachment")
    // {
    //     FileName = fileName
    // }.ToString();

    const int bufferSize = 65536; // 和原逻辑保持64KB缓冲区
    var buffer = new byte[bufferSize];
    // 异步打开Blob流，using自动释放资源
    await using var blobReadStream = await targetBlob.OpenReadAsync();
    int readBytes;
    // 循环读流写入响应，全程异步无阻塞
    while ((readBytes = await blobReadStream.ReadAsync(buffer, 0, buffer.Length)) > 0)
    {
        await Response.Body.WriteAsync(buffer, 0, readBytes);
        // 主动刷缓冲区，降低客户端首包等待延迟
        await Response.Body.FlushAsync();
    }
}

关键注意点 #

• 所有IO操作必须加await，禁止在ASP.NET Core管道里用.Result、.Wait()这类同步阻塞方法，否则极易触发线程池死锁，导致请求无响应。
• 绝对不要用async void编写业务回调，ASP.NET Core管道无法跟踪这类方法的执行状态，会出现回调还在写流、请求已经被框架判定为处理完成而提前断开的问题，这是旧代码迁移后失效的核心原因。
• 所有流、存储连接对象必须用using/await using声明，自动完成资源释放，避免连接泄漏。

如果需要兼容旧代码的PushStreamContent写法，可以自己实现一个轻量兼容版本，逻辑非常简单：

public class PushStreamContent : HttpContent
{
    private readonly Func<Stream, Task> _streamWriteCallback;

    // 兼容旧代码的Action签名
    public PushStreamContent(Action<Stream, HttpContent, TransportContext> writeCallback, MediaTypeHeaderValue contentType)
    {
        Headers.ContentType = contentType;
        _streamWriteCallback = stream =>
        {
            writeCallback(stream, this, null);
            return Task.CompletedTask;
        };
    }

    // 推荐用的异步回调重载
    public PushStreamContent(Func<Stream, Task> writeCallback, MediaTypeHeaderValue contentType)
    {
        Headers.ContentType = contentType;
        _streamWriteCallback = writeCallback;
    }

    protected override async Task SerializeToStreamAsync(Stream outputStream, TransportContext context)
    {
        await _streamWriteCallback(outputStream);
    }

    protected override bool TryComputeLength(out long length)
    {
        // 流式输出无法提前预知内容长度，固定返回false
        length = 0;
        return false;
    }
}

就算用这个兼容类，也必须把原来的onStreamAvailable方法签名从async void改为async Task，移除所有.Result同步阻塞调用，否则依然无法正常运行。

内容的提问来源于stack exchange，提问作者viji