net.Conn.Write仅将数据写入内核发送缓冲区,不保证全部发出,需检查返回值n和err,不重试、不分包、不处理粘包。

Go 中用 net.Conn.Write 发送 TCP 数据最直接
只要拿到一个已建立连接的 net.Conn,调用它的 Write 方法就能发数据。它底层就是系统调用 send() 的封装,不带重试、不自动分包、不处理粘包——你给什么字节,它就原样往 socket 里塞。
常见错误是写完没检查返回值,或者误以为 Write 会阻塞到全部数据发出(其实只保证写入内核发送缓冲区成功):
-
Write返回实际写入字节数和可能的错误;若n ,说明缓冲区满或连接异常,需手动重试 - 不要假设一次
Write就能把整个消息发出去,尤其在高负载或小窗口时 - 如果服务端按行或按长度解析,必须自己加协议头或换行符,
Write不会帮你做
conn, _ := net.Dial("tcp", "127.0.0.1:8080")
n, err := conn.Write([]byte("HELLO\n"))
if err != nil {
log.Fatal(err)
}
if n < len("HELLO\n") {
// 需要补发剩余部分
}用 bufio.Writer 提升小数据频繁发送的效率
每调用一次 Write 都是一次系统调用开销,如果连续发多个短消息(比如心跳、日志片段),直接裸写效率低且易触发 Nagle 算法延迟。
bufio.Writer 提供用户态缓冲,把多次 Write 合并成一次系统调用,适合「攒一批再发」的场景:
立即学习“go语言免费学习笔记(深入)”;
- 初始化时指定缓冲大小,一般
4096足够;太小起不到合并作用,太大可能增加延迟 - 记得在关闭连接前调用
Flush(),否则缓冲区里残留的数据不会发出 - 不适用于要求低延迟的实时指令(如游戏操作),因为缓冲行为不可控
w := bufio.NewWriter(conn)
w.Write([]byte("cmd1"))
w.Write([]byte("cmd2"))
w.Flush() // 必须显式调用发送结构化数据时优先用 encoding/binary 而非字符串拼接
如果要传整数、浮点、固定长度字段(比如协议头里的长度、类型、时间戳),别用 fmt.Sprintf 或字符串拼接——可读性差、字节序错乱、无法跨平台解析。
本文档主要讲述的是android rtsp流媒体播放介绍;实时流协议(RTSP)是应用级协议,控制实时数据的发送。RTSP提供了一个可扩展框架,使实时数据,如音频与视频,的受控、点播成为可能。数据源包括现场数据与存储在剪辑中数据。该协议目的在于控制多个数据发送连接,为选择发送通道,如UDP、组播UDP与TCP,提供途径,并为选择基于RTP上发送机制提供方法。希望本文档会给有需要的朋友带来帮助;感兴趣的朋友可以过来看看
encoding/binary 提供确定性的二进制序列化,明确控制大小端和对齐:
- 用
binary.BigEndian.PutUint32(buf, 12345)写入大端 4 字节整数 - 接收方必须用相同字节序读取,否则得到乱码数值
- 注意目标切片容量是否足够,
PutUint32不做越界检查
buf := make([]byte, 4) binary.BigEndian.PutUint32(buf, uint32(len(payload))) conn.Write(buf) // 先发长度 conn.Write(payload) // 再发内容
超时控制必须设在 Write 之前,不能靠 SetWriteDeadline 事后补救
很多人以为设置 SetWriteDeadline 就能防止卡死,但这是个常见误解:该方法只影响下一次 I/O 操作,不是全局开关。如果在循环中反复写,每次都要重新设置 deadline。
更稳妥的做法是在 Dial 阶段就用 net.DialTimeout 或上下文控制整个连接生命周期:
-
conn.SetWriteDeadline(time.Now().Add(5 * time.Second))必须在每次Write前调用 - 推荐用
context.WithTimeout包裹net.DialContext,避免连接阶段无限等待 - 写入超时 ≠ 服务端处理超时,只是确保 socket 层不卡住
真正容易被忽略的是:TCP 连接一旦因网络中断进入 ESTABLISHED 但不可达状态,Write 可能长时间无响应,直到系统 TCP keepalive 触发(默认 2 小时)。这种情况下,仅靠 SetWriteDeadline 不足以及时发现断连。









