在Go中实现类似Node.js的HTTP双工流处理，即在写入响应的同时持续读取请求体，标准HTTP处理器会因响应写入而关闭请求体。本教程将深入探讨如何利用`http.Hijacker`接口来劫持底层TCP连接，从而获得对连接的完全控制，实现自定义的HTTP协议处理和双向数据流传输，满足高性能、低延迟的流式应用需求。
理解 Go HTTP 处理器的局限性
Go标准库的net/http包提供了一个强大且易用的HTTP服务器。然而，在某些需要高级流处理的场景下，其默认行为可能会成为限制。一个常见的挑战是，当处理一个HTTP请求时，一旦服务器开始向http.ResponseWriter写入任何数据，http.Request.Body通常会被关闭。这意味着，如果应用程序需要在一个请求-响应周期内进行双向流式通信（例如，实时数据转换、长轮询、自定义协议协商），这种“写入即关闭”的行为会阻碍其实现。
例如，设想一个场景，客户端持续发送数据作为请求体的一部分，服务器需要实时处理这些数据，并同时将处理结果以流的形式写回响应体。标准HTTP处理器的设计使得这种并发的读写操作难以实现，因为它倾向于将请求体视为在响应开始前完全读取完毕的资源。
http.Hijacker：解锁底层连接控制
为了克服这一限制，Go标准库提供了http.Hijacker接口。http.Hijacker允许HTTP处理器“劫持”底层的TCP连接，从而脱离net/http服务器的常规管理。一旦连接被劫持，开发者将获得一个net.Conn对象和一个*bufio.ReadWriter对象，从而可以直接对原始TCP连接进行读写操作，实现完全自定义的协议逻辑。
http.Hijacker 的工作原理
当一个HTTP请求到达服务器时，net/http包会解析请求行和请求头。在这一点之后，如果你决定使用http.Hijacker，你就可以获取到原始的TCP连接。
Hijack()方法返回三个值：
- conn net.Conn: 这是底层的TCP连接，可以直接对其进行读写操作。
- bufrw *bufio.ReadWriter: 这是一个封装了conn的带缓冲的读写器。它包含一个*bufio.Reader和一个*bufio.Writer，允许你以缓冲的方式读取和写入数据，提高I/O效率。
- err error: 如果劫持失败，则返回错误。
一旦连接被劫持，net/http服务器将不再管理该连接。这意味着：
- 你必须手动处理HTTP协议的剩余部分，包括发送HTTP响应头、响应体以及任何后续的通信。
- 你必须负责关闭conn。
- http.ResponseWriter和http.Request.Body将不再可用或不再被服务器管理。
实现一个 Go HTTP 双工处理器
以下是如何利用http.Hijacker构建一个能够进行双工流处理的Go HTTP处理器的步骤：
1. 检查并劫持连接
首先，你的http.Handler需要尝试将http.ResponseWriter断言为http.Hijacker接口。如果成功，就可以调用Hijack()方法。
package main
import (
"bufio"
"fmt"
"io"
"log"
"net"
"net/http"
"time"
)
func duplexHandler(w http.ResponseWriter, r *http.Request) {
// 1. 尝试将ResponseWriter断言为Hijacker
hj, ok := w.(http.Hijacker)
if !ok {
http.Error(w, "Hijacking not supported", http.StatusInternalServerError)
return
}
// 2. 劫持连接
conn, bufrw, err := hj.Hijack() 
