ASP.NET MVC 5 响应流不起作用。仅登台/生产环境

Question

我正在尝试使用 http 持续将数据流式传输到客户端。该代码在 localhost 上工作，但在 IIS 或 Apache 下（在 Linux 上使用单声道）下的生产环境中不起作用。

当代码在生产服务器上时，它不会刷新任何内容，直到我关闭连接。它确实可以在本地主机上正常工作。

 public class EventsStreamController : Controller
    {
    static EventsStreamController()
    {
        ConcurrentDictionary = new ConcurrentDictionary<uint, Client>();
    }

    private static ConcurrentDictionary<uint, Client> ConcurrentDictionary { get; }

    /// <summary>
    /// http://localhost:42022/EventsStream/SendMesaage/?pollSessionID=2&message=cats
    /// </summary>
    [HttpGet]
    public async Task Connect(uint pollSessionID)
    {
        var httpResponse = this.Response;

        httpResponse.BufferOutput = false;

        var client = new Client(pollSessionID);

        if (!ConcurrentDictionary.TryAdd(client.ClientId, client))
        {
            throw new ApplicationException("The client is already in the dictionary.");
        }

        while (true)
        {
            await Task.Delay(2000);

            string message;

            if (client.Messages.TryDequeue(out message))
            {
                byte[] buffer = Encoding.UTF8.GetBytes(message);

                httpResponse.BinaryWrite(buffer);
                httpResponse.Flush();

                if (message == "close")
                {
                    break;
                }
            }
        }
    }

    /// <summary>
    /// http://localhost:42022/EventsStream/connect/?pollSessionID=2
    /// </summary>
    [HttpGet]
    public ActionResult SendMesaage(uint pollSessionID, string message)
    {
        Client client;
        if (!ConcurrentDictionary.TryGetValue(pollSessionID, out client))
        {
            throw new ApplicationException("Client not found.");
        }

        client.Messages.Enqueue(message);

        return new HttpStatusCodeResult(HttpStatusCode.OK);
    }

    public class Client
    {
        public Client(uint clientId)
        {
            this.ClientId = clientId;
            this.Messages = new ConcurrentQueue<string>();
        }

        public uint ClientId { get; set; }

        public ConcurrentQueue<string> Messages { get; }
    }
}

我使用TaskCompletionSource 通知等待请求它必须将数据流式传输到客户端，但为了简单起见，我将其更改为每 2 秒检查一次。（还在服务器上测试过，仍然无法正常工作.)

Answer 1

您需要发送块，并用Transfer-Encoding: chunked HTTP 标头指示它。

https://www.codeproject.com/Articles/648526/All-about-http-chunked-responses