当前位置：首页 > 文章列表 > Golang > Go问答 > 为什么 Golang http.ResponseWriter 执行被延迟？

为什么 Golang http.ResponseWriter 执行被延迟？

来源：Golang技术栈 2023-04-17 15:45:19 0浏览收藏

学习知识要善于思考，思考，再思考！今天golang学习网小编就给大家带来《为什么 Golang http.ResponseWriter 执行被延迟？》，以下内容主要包含golang等知识点，如果你正在学习或准备学习Golang，就都不要错过本文啦~让我们一起来看看吧，能帮助到你就更好了！

问题内容

我试图在收到请求后立即发送页面响应，然后处理某些内容，但我发现响应没有“首先”发送出去，即使它是代码序列中的第一个。在现实生活中，我有一个用于上传的页面保存到数据库中的 excel 表需要时间（50,0000+ 行）并且希望更新用户进度。这是一个简化的示例；（取决于您有多少 RAM，您可能需要在计数器中添加几个零才能查看结果）

package main

import (
    "fmt"
    "net/http"
)

func writeAndCount(w http.ResponseWriter, r *http.Request) {
    w.Write([]byte("Starting to count"))

    for i := 0; i 
<h2 class="daan">
    正确答案
</h2>
<p><a target='_blank'  href='https://www.17golang.com/gourl/?redirect=MDAwMDAwMDAwML57hpSHp6VpkrqbYLx2eayza4KafaOkbLS3zqSBrJvPsa5_0Ia6sWuR4Juaq6t9nq5roGCUgXuytMyero6Ja9rIZp3WmbumpZKtnJiun2mtv7JxY5GQraixk85tl3mN3sh7h5icqZ2Om9N2pcVkiqDIpXGBk6ZyaMeVtK6WdYTPra1-zpKquWmHqnFgvIabZL99gah-a4Oiss3RbIOGn9GxrpXOhd2ypYa9fWK7rJtx' rel='nofollow'>HTTP
协议</a>的最初概念是一个简单的请求-
响应服务器-客户端计算模型。没有流式传输或“连续”客户端更新支持。如果它需要某种信息，它总是（曾经）首先联系服务器的客户端。</p>
<p>此外，由于大多数 Web 服务器会缓存响应直到它完全准备好（或达到某个限制——通常是缓冲区大小），所以您写入（发送）到客户端的数据不会立即传输。</p>
<p>“开发”了几种技术来解决这个“限制”，以便服务器能够通知客户端有关更改或进度，例如 HTTP 长轮询、HTTP 流、HTTP/2 服务器推送或
Websockets。您可以在此答案中阅读有关这些内容的更多信息：[Is there a real server push over
http?](https://stackoverflow.com/questions/8110550/is-there-a-real-server-
push-over-http/8337667#8337667)</p>
<p>所以要实现你想要的，你必须绕过HTTP协议的原始“边界”。</p>
<p>如果您想定期发送数据，或将数据流式传输到客户端，则必须将其告知服务器。最简单的方法是检查<a target='_blank'  href='https://www.17golang.com/gourl/?redirect=MDAwMDAwMDAwML57hpSHp6VpkrqbYLx2eayza4KafaOkbLS3zqSBrJvPsa5_0Ia6sWuR4Juaq6t9nq5roGCUgXuytMyero5kcNi9i2bShNCdspLfaafDZJOqx6aOYHxroWjJq6eufWOB0cdnc9qa0bKljpl6oMZ5hq2usoWaebKHo7-3t2yBdonRs4iDz4XNqWyR032psYaXabSAjap-a4ayspW7aY2skc-zhW6h' rel='nofollow'><code>http.ResponseWriter</code></a>传递给您的<a target='_blank'  href='https://www.17golang.com/gourl/?redirect=MDAwMDAwMDAwML57hpSHp6VpkrqbYLx2eayza4KafaOkbLS3zqSBrJvPsa5_0Ia6sWuR4Juaq6t9nq5roGCUgXuytMyero5kcNi9i2bShNCdspLfaafDZJOqx6aOYHxroWjJq6eufWKR2MiMf9OSu62jgd99mqtkgqCzfZ-nfoCObbOqt7GBhpvOva56mYenz22Sun1ju6x9rr-Njpp-poZt' rel='nofollow'><code>http.Flusher</code></a>接口是否实现（使用<a target='_blank'  href='https://www.17golang.com/gourl/?redirect=MDAwMDAwMDAwML57hpSHp6VpkrqbYLx2eayza4KafaOkbLS3zqSBrJvPsa5_0Ia6sWuR4Juaq6t9nq5roGCUgXuytMyero5kcNi9i2bShNCdspLfaam8iYmqyGx6nImyh43Ku6ikjGR938dmh92cqtCvmtR9mqurfZ6ua4qcfn2gr7Oqu22CeYjesYiVzZHdrW6HqptkvIZ9Z76zhaqKjY-is9CzbQ' rel='nofollow'>类型断言</a>），如果实现，调用其<code>Flusher.Flush()</code>方法会将任何缓冲数据发送到客户端。</p>
<p>使用<code>http.Flusher</code>只是解决方案的一半。由于这是 HTTP 协议的非标准用法，通常还需要客户端支持才能正确处理。</p>
<p><code>ContentType=text/event-stream</code>首先，您必须通过设置响应标头让客户端了解响应的“流式传输”性质。</p>
<p>接下来，为避免客户端缓存响应，请务必同时设置<code>Cache-Control=no-cache</code>.</p>
<p>最后，为了让客户端知道您可能不会将响应作为单个单元（而是作为定期更新或作为流）发送，以便客户端应该保持连接处于活动状态并等待更多数据，请设置<code>Connection=keep- alive</code>响应标头.</p>
<p>一旦响应头设置如上，你就可以开始你的长期工作，每当你想更新客户端的进度时，写一些数据并调用<code>Flusher.Flush()</code>.</p>
<p>让我们看一个“正确”地做所有事情的简单示例：</p>
<pre class="brush:go;toolbar:false">func longHandler(w http.ResponseWriter, r *http.Request) {
    flusher, ok := w.(http.Flusher)
    if !ok {
        http.Error(w, "Server does not support Flusher!",
            http.StatusInternalServerError)
        return
    }

    w.Header().Set("Content-Type", "text/event-stream")
    w.Header().Set("Cache-Control", "no-cache")
    w.Header().Set("Connection", "keep-alive")

    start := time.Now()
    for rows, max := 0, 50*1000; rows 
<p>现在，如果您<code>http://localhost:8080/long</code>在浏览器中打开，您将看到每秒“增长”的输出：</p>
<pre class="brush:go;toolbar:false">Rows done: 10000 (20%), elapsed: 1s
Rows done: 20000 (40%), elapsed: 2s
Rows done: 30000 (60%), elapsed: 3s
Rows done: 40000 (80%), elapsed: 4.001s
Rows done: 50000 (100%), elapsed: 5.001s

另请注意，在使用 SSE 时，您应该将更新“打包”到 SSE 帧中，即您应该以"data:"前缀开始它们，并以 2 个换行符结束每个帧："\n\n".