Golang中http.ResponseWriter延迟执行的原因是什么？

golang学习网今天将给大家带来《Golang中http.ResponseWriter延迟执行的原因是什么？》，感兴趣的朋友请继续看下去吧！以下内容将会涉及到等等知识点，如果你是正在学习Golang或者已经是大佬级别了，都非常欢迎也希望大家都能给我建议评论哈~希望能帮助到大家！

我试图在收到请求后立即发送页面响应，然后处理某些内容，但我发现响应不会“首先”发送出去，即使它是代码序列中的第一个。在现实生活中，我有一个用于上传 excel 工作表的页面，该工作表将保存到数据库中，这需要时间（50,000+ 行）并且希望更新用户进度。这是一个简化的例子； （根据您有多少 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 < 1000000; i++ {

        if i%1000 == 0 {
            fmt.Println(i)
        }
    }
    w.Write([]byte("Finished counting"))

}

func main() {
    http.HandleFunc("/", writeAndCount)
    http.ListenAndServe(":8080", nil)

}

正确答案

HTTP protocol的最初概念是一个简单的请求-响应服务器-客户端计算模型。没有流或“连续”客户端更新支持。如果需要某种信息，首先联系服务器的总是客户端。

此外，由于大多数网络服务器都会缓存响应，直到它完全准备好（或达到某个限制 - 通常是缓冲区大小），因此您写入（发送）到客户端的数据不会立即传输。 p>

“开发”了几种技术来绕过这个“限制”，以便服务器能够通知客户端有关更改或进度的信息，例如 http 长轮询、http 流、http/2 服务器推送或 websockets。您可以在此答案中阅读有关这些的更多信息：Is there a real server push over http?

因此，要实现您想要的目标，您必须绕过 http 协议的原始“边界”。

如果你想定期发送数据，或者将数据流式传输到客户端，你必须将其告诉服务器。最简单的方法是检查传递给您的 http.ResponseWriter 是否实现了 http.Flusher 接口（使用 type assertion），如果实现了，则调用其 flusher.flush() 方法将所有缓冲数据发送到客户端。

使用 http.flusher 只是解决方案的一半。由于这是 http 协议的非标准用法，通常还需要客户端支持才能正确处理。

首先，您必须通过设置 contenttype=text/event-stream 响应标头，让客户端了解响应的“流式”性质。

接下来，为了避免客户端缓存响应，请务必设置 cache-control=no-cache。

最后，为了让客户端知道您可能不会将响应作为单个单元发送（而是作为定期更新或作为流），以便客户端应保持连接处于活动状态并等待进一步的数据，请设置connection=keep-alive 响应标头。

一旦响应头设置为上述，您就可以开始漫长的工作，每当您想要向客户端更新进度时，写入一些数据并调用 flusher.flush()。

让我们看一个简单的例子，它一切都“正确”：

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 < max; {
        time.sleep(time.second) // simulating work...
        rows += 10 * 1000
        fmt.fprintf(w, "rows done: %d (%d%%), elapsed: %v\n",
            rows, rows*100/max, time.since(start).truncate(time.millisecond))
        flusher.flush()
    }
}

func main() {
    http.handlefunc("/long", longhandler)
    panic(http.listenandserve("localhost:8080", nil))
}

现在，如果您在浏览器中打开 http://localhost:8080/long，您将看到每秒“增长”的输出：

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 “。

“文献”和进一步阅读/教程

了解有关 Server-sent events on Wikipedia 的更多信息。

查看 Golang HTML5 SSE example。

参见 Golang SSE server example with client codes using it。

查看 w3school.com 在 Server-Sent Events - One Way Messaging 上的图例。

您可以检查 responsewriter 是否为 http.Flusher，如果是，则强制刷新到网络：

if f, ok := w.(http.Flusher); ok {
    f.Flush()
}

但是，请记住，这是一个非常规的 http 处理程序。将进度消息流式传输到响应（就好像它是终端一样）会带来一些问题，特别是当客户端是 web 浏览器时。

您可能需要考虑更符合 http 性质的方法，例如立即返回 202 accepted 响应，并带有唯一标识符，客户端可以使用该标识符通过后续调用 api 来检查处理状态。 p>

本篇关于《Golang中http.ResponseWriter延迟执行的原因是什么？》的介绍就到此结束啦，但是学无止境，想要了解学习更多关于Golang的相关知识，请关注golang学习网公众号！