go语言标准http库在写入响应后会关闭请求体，这限制了高级双工通信。本文详细阐述如何通过`http.Hijacker`接口获取底层TCP连接，从而实现对HTTP请求和响应的精细流式控制。我们将探讨如何发送自定义响应头、并发处理请求体数据以及持续向客户端推送响应数据，以突破Go标准HTTP处理的限制，实现类似node.js的流式通信模式。
引言：Go HTTP双工流式处理的挑战
在Go语言的标准net/http库中，HTTP请求的处理遵循典型的请求-响应模型。当服务器开始向http.ResponseWriter写入任何数据时，请求体（http.Request.Body）通常会被视为已完成或即将关闭。这意味着，如果我们需要在向客户端发送响应的同时，仍然持续地从请求体中读取数据，或者实现更复杂的双向流式通信，标准处理机制会显得力不从心。这种限制使得实现类似Node.js中常见的、能够实时处理输入流并同时输出响应流的“双工”HTTP处理器变得复杂。
http.Hijacker：突破限制的关键
为了绕过net/http库的默认行为并实现对底层TCP连接的完全控制，Go提供了http.Hijacker接口。Hijacker接口允许HTTP处理器“劫持”连接，将其从net/http服务器的管理中移除。一旦连接被劫持，开发者就可以直接操作底层的net.Conn，实现自定义的协议逻辑，包括双向流式数据传输。
http.Hijacker接口定义如下：
立即学习“go语言免费学习笔记（深入）”；
type Hijacker interface { Hijack() (net.Conn, *bufio.ReadWriter, Error) }
调用Hijack()方法会返回三个值：
- net.Conn: 底层的TCP连接，可以直接进行读写操作。
- *bufio.ReadWriter: 一个带缓冲的读写器，它封装了net.Conn，方便进行高效的缓冲I/O操作。
- error: 如果劫持失败则返回错误。
通过Hijack()，我们可以完全掌控连接的生命周期和数据传输，从而实现真正的双工流式处理。
实现步骤与代码示例
以下是如何使用http.Hijacker在Go中构建一个双工HTTP处理器的详细步骤和代码示例。这个示例将展示如何在劫持连接后，同时从客户端读取请求体数据并向客户端发送响应数据。
package main import ( "bufio" "fmt" "io" "log" "net" "net/http" "time" ) // duplexHandler 是一个处理HTTP双工通信的函数 func duplexHandler(w http.ResponseWriter, r *http.Request) { // 1. 检查并获取 http.Hijacker 接口 // 并非所有 http.ResponseWriter 都支持 Hijacker，需要进行类型断言 hj, ok := w.(http.Hijacker) if !ok { http.Error(w, "服务器不支持连接劫持", http.StatusInternalServerError) return } // 2. 劫持连接 // Hijack() 返回底层的 net.Conn 和一个 *bufio.ReadWriter conn, bufrw, err := hj.Hijack() if err != nil { http.Error(w, fmt.Sprintf("劫持连接失败: %v", err), http.StatusInternalServerError) return } // 确保底层TCP连接最终被关闭，释放资源 defer func(conn net.Conn) { err := conn.Close() if err != nil { log.Printf("关闭连接失败: %v", err) } log.Println("连接已关闭。") }(conn) log.Printf("连接已劫持，客户端地址: %s", conn.RemoteAddr()) // 3. 手动发送初始HTTP响应头 // 劫持后，标准HTTP服务器不再管理响应，我们需要手动构造并发送HTTP响应头。 // 注意：使用 CRLF (rn) 作为行结束符，并用一个空行 (rn) 结束头部。 _, err = bufrw.WriteString("HTTP/1.1 200 OKrn") if err != nil { log.Printf("写入初始HTTP状态行失败: %v", err) return } _, err = bufrw.WriteString("Content-Type: text/plain; charset=utf-8rn") if err != nil { log.Printf("写入Content-Type头失败: %v", err) return } _, err = bufrw.WriteString("Connection: keep-alivern") // 保持连接活跃 if err != nil { log.Printf("写入Connection头失败: %v", err) return } _, err = bufrw.WriteString("rn") // 重要的空行，表示HTTP头结束 if err != nil { log.Printf("写入HTTP头结束符失败: %v", err) return } // 立即刷新缓冲区，确保头信息发送到客户端 err = bufrw.Flush() if err != nil { log.Printf("刷新初始HTTP头失败: %v", err) return } log.Println("初始HTTP响应头已发送。") // 4. 实现请求体和响应体的双向流式处理 // 启动一个goroutine来并发读取请求体数据 go func() { defer func() { log.Println("请求体读取goroutine结束。") // 即使 Hijack 了，r.Body 仍然是基于底层连接的， // 在读取完成后手动关闭是良好的实践。 // 但在并发读写场景下，关闭 r.Body 可能会影响 bufrw 的写入， // 因此更安全的做法是让其自然结束或仅在确定不再需要时关闭。 // 在此示例中，我们主要通过 bufrw 来管理连接的读写。 // r.Body 最终会被 Go 的 GC 回收。 }() // 从原始请求体中读取数据 // 注意：r.Body 在 Hijack 之后仍然是可读的，因为它只是底层连接的一个视图。 // 但一旦 Hijack，Go 标准库就不再负责其生命周期管理。 buf := make([]byte, 1024) for { n, readErr := r.Body.Read(buf) if n > 0 { receivedData := string(buf[:n]) log.Printf("从请求体接收到数据: %s", receivedData) // 可以在这里对接收到的数据进行处理或转换 // 然后通过 bufrw.Writer 将处理后的数据发送回客户端 responsePart := fmt.Sprintf("服务器回显: %s (收到于 %s)n", receivedData, time.Now().Format("15:04:05")) _, writeErr := bufrw.WriteString(responsePart) if writeErr != nil { log.Printf("写入回显数据到客户端失败: %v", writeErr) return // 写入失败，退出goroutine } flushErr := bufrw.Flush() // 刷新缓冲区，确保数据发送 if flushErr != nil { log.Printf("刷新回显数据失败: %v", flushErr) return // 刷新失败，退出goroutine } } if readErr == io.EOF { log.Println("请求体已读取完毕 (EOF)。") break } if readErr != nil { log.Printf("读取请求体时发生错误: