如何在执行响应中不需要的计算之前向客户端发送响应
How to send response to the client before executing the calculations that are not required in response
我们可以发送响应(或写在用户端),声明如下:
json.NewEncoder(w).Encode("some data")
在 api 之前做一些计算部分,这些部分在响应中不需要,但需要存储在数据库中。我在想我们可以在更短的时间内向用户做出响应,并且功能的其他部分将继续工作,直到 return 声明。
如果我的思路不对请指正。
一种方法是做你的额外工作,这不是另一个 goroutine 中的响应所必需的:
func someHandler(w http.ResponseWriter, r *http.Request) {
go func() {
// Do anything here, this won't delay the response
// But don't touch the writer or request, as they may not be available here
}()
if err := json.NewEncoder(w).Encode("some data"); err != nil {
log.Printf("Error sending response: %v", err)
}
}
请注意,在启动的 gorotuine 中,您不能使用 http.ResponseWriter
或 http.Request
,因为它们仅在您从处理程序 return 之前有效。如果你需要他们的东西,你必须在启动 goroutine 之前复制所需的部分。
如果你想在处理程序 return 之前完成额外的任务,你仍然可以使用 goroutine,并使用 sync.WaitGroup
等待它完成,然后才 return 来自处理程序。您可能会也可能不会刷新响应:
func someHandler(w http.ResponseWriter, r *http.Request) {
wg := &sync.WaitGroup{}
wg.Add(1)
go func() {
defer wg.Done()
// You may use the writer and request here
}()
if err := json.NewEncoder(w).Encode("some data"); err != nil {
log.Printf("Error sending response: %v", err)
}
// Optionally you may flush the data written so far (icnluding HTTP headers)
if flusher, ok := w.(http.Flusher); ok {
flusher.Flush()
}
wg.Wait()
}
注意,这里允许 goroutine 使用 http.ResponseWriter
和 http.Request
,因为在附加任务完成之前,处理程序不会 return。
我们可以发送响应(或写在用户端),声明如下:
json.NewEncoder(w).Encode("some data")
在 api 之前做一些计算部分,这些部分在响应中不需要,但需要存储在数据库中。我在想我们可以在更短的时间内向用户做出响应,并且功能的其他部分将继续工作,直到 return 声明。
如果我的思路不对请指正。
一种方法是做你的额外工作,这不是另一个 goroutine 中的响应所必需的:
func someHandler(w http.ResponseWriter, r *http.Request) {
go func() {
// Do anything here, this won't delay the response
// But don't touch the writer or request, as they may not be available here
}()
if err := json.NewEncoder(w).Encode("some data"); err != nil {
log.Printf("Error sending response: %v", err)
}
}
请注意,在启动的 gorotuine 中,您不能使用 http.ResponseWriter
或 http.Request
,因为它们仅在您从处理程序 return 之前有效。如果你需要他们的东西,你必须在启动 goroutine 之前复制所需的部分。
如果你想在处理程序 return 之前完成额外的任务,你仍然可以使用 goroutine,并使用 sync.WaitGroup
等待它完成,然后才 return 来自处理程序。您可能会也可能不会刷新响应:
func someHandler(w http.ResponseWriter, r *http.Request) {
wg := &sync.WaitGroup{}
wg.Add(1)
go func() {
defer wg.Done()
// You may use the writer and request here
}()
if err := json.NewEncoder(w).Encode("some data"); err != nil {
log.Printf("Error sending response: %v", err)
}
// Optionally you may flush the data written so far (icnluding HTTP headers)
if flusher, ok := w.(http.Flusher); ok {
flusher.Flush()
}
wg.Wait()
}
注意,这里允许 goroutine 使用 http.ResponseWriter
和 http.Request
,因为在附加任务完成之前,处理程序不会 return。