WebSocket连接建立后需用gorilla/websocket的Read()或ReadMessage()获取原始数据流；ReadMessage()自动解帧返回payload，Read()更底层但需手动处理帧边界和错误；实时写入文件须用带缓冲的channel解耦读写，避免阻塞；写入binary/text message均应保持payload原样，禁加换行；关闭前须响应close帧并确保channel数据清空。
WebSocket连接建立后如何获取原始数据流
Go标准库net/http本身不提供WebSocket支持，必须用gorilla/websocket或gobwas/ws。推荐gorilla/websocket，它把连接封装为*websocket.Conn，其ReadMessage()和Read() 方法才能拿到字节流。别直接用http.ResponseWriter去读——那是HTTP响应体，不是WS帧。
关键点：WebSocket是帧协议，每帧带opcode（text/binary/close等），ReadMessage()会自动解帧并返回payload；若需原始二进制流（比如写入文件不加任何解析），应使用Read()配合bufio.Reader或直接循环conn.Read()，但要注意帧边界——Read()默认只读一帧的payload，不会跨帧。
-
ReadMessage()适合文本或已知结构的数据，返回messageType, []byte, error -
Read()更底层，但需手动处理io.EOF（连接关闭）和websocket.CloseMessage类型帧 - 不要在goroutine里反复调用
Read()而不检查错误，否则容易卡死或panic
实时写入文件时如何避免阻塞WebSocket读取
WebSocket读取是同步阻塞的，如果每次收到数据都同步os.WriteFile()或f.Write()，一旦磁盘慢、文件大、路径挂载异常，整个连接会卡住，导致ping超时、对端断连。必须把写文件逻辑从读循环中剥离。
典型做法是用channel做缓冲：读goroutine只负责从conn.ReadMessage()取数据，塞进chan []byte；另一个goroutine从channel取数据，批量或逐条写入文件。注意channel容量要设限（比如make(chan []byte, 100)），否则内存爆掉。
立即学习“go语言免费学习笔记（深入）”；
- 写文件goroutine应使用
os.O_APPEND | os.O_CREATE | os.O_WRONLY打开文件，避免每次Seek(0, io.SeekEnd) - 用
bufio.NewWriter(f)包装文件句柄，减少系统调用次数；记得定期Flush()，别等buffer满才写 - 若需按时间分片（如每5分钟一个文件），在写goroutine里判断当前时间戳，close旧文件、open新文件
写入二进制数据时要注意哪些编码与换行问题
WebSocket binary message本质就是[]byte，直接f.Write(data)即可。但如果你收到的是text message（websocket.TextMessage），内容是UTF-8字符串，Write()也没问题——UTF-8本身就是字节流。唯一要小心的是：别自己加换行符。
常见误操作：收到一条JSON文本，想“格式化日志”就fmt.Fprintf(f, "%s\n", msg)。这会污染原始数据流——下游解析JSON时遇到多余换行直接失败。除非你明确要存成带时间戳的日志行（即非原始流），否则所有写入必须保持原始payload一字不差。
- binary message直接
f.Write(payload)，不要string(payload)再转回[]byte - text message也直接
f.Write(payload)，Go里string转[]byte是零拷贝，但显式转换没必要 - 如果需要追加元信息（如时间戳、消息长度），建议另起一个日志文件，而不是混入原始数据文件
如何安全关闭连接并确保最后几条数据不丢失
用户Ctrl+C或服务重启时，如果只conn.Close()就退出，channel里可能还有未消费的数据。必须实现优雅退出：用context.WithCancel控制两个goroutine，通知写goroutine停止接收新数据，并等待它把channel里剩余数据写完再close文件。
具体信号传递方式：定义一个done chan struct{}，读goroutine在收到done信号后不再读，写goroutine在收到done后继续消费channel直到空，然后close(f)并return。
- 不要用
defer f.Close()在main函数里——它会在程序退出时才执行，此时channel可能还在写 - 写goroutine里
for data := range ch是安全的，但需配合close(ch)触发退出，而close(ch)必须由读goroutine在确认不再发送后调用 - 务必检查
f.Sync()返回值，尤其在Linux上，它能确保数据真正落盘，不只是进page cache
最易被忽略的是：没处理websocket.CloseMessage帧。客户端主动关闭时发的是close帧，服务端要用conn.WriteMessage(websocket.CloseMessage, websocket.FormatCloseMessage(websocket.CloseNormalClosure, ""))响应，再关闭连接，否则TCP连接可能滞留TIME_WAIT且数据残留。
