
定义一个 buffer 来临时存放消息 从 conn 里面读取固定字节大小内容,判断当前内容里面有没有分隔符 如果没有找到分隔符,把当前内容追加到 buffer 里面,然后重复第 2 步 如果找到分隔符,把当前内容里面分隔符之前的内容追加到 buffer 后输出 然后重置 buffer ,把分隔符之后的内容追加到 buffer ,重复第 2 步 把分隔符之后的内容追加到 buffer 这个环节我不知道处理 package main import ( "bufio" "io" "log" "net" ) func main() { listener, err := net.Listen("tcp", "127.0.0.1:8866") if err != nil { log.Fatal(err) } defer listener.Close() for { con, err := listener.Accept() if err != nil { log.Println(err) continue } defer con.Close() reader := bufio.NewReader(con) for { data, err := reader.ReadSlice('\n') if err != nil { if err != io.EOF { // 分隔符之后 } else { //读取结束 break } } log.Println("received msg", len(data), "bytes:", string(data)) } } } package main import ( "log" "net" "time" ) func main() { conn, err := net.Dial("tcp", "127.0.0.1:8866") if err != nil { log.Fatal(err) } defer conn.Close() _, err = conn.Write([]byte("bbbb\ndfdfdfdfd")) if err != nil { panic(err) } time.Sleep(time.Second) } 1 ggvoking Jul 12, 2023 消息包头带个长度不就行了。 |
2 awanganddong OP @ggvoking 主要是想搞明白采用分格符这种方式是怎么处理的 |
3 itechify PRO 粘包警察马上到! |
4 awanganddong OP TCP 流数据边界问题 这个没人吐槽了吧。 |
5 LeegoYih Jul 12, 2023 |
6 awanganddong OP bufio.NewReader 这个概念,理解错了。这个得出来的结果比较清晰一些 ``` func main() { conn, err := net.Dial("tcp", "127.0.0.1:8866") if err != nil { log.Fatal(err) } defer conn.Close() _, err = conn.Write([]byte("bbbb\ndfdfdfdfd\nsdsdsd")) _, err = conn.Write([]byte("aaa\n")) if err != nil { panic(err) } time.Sleep(time.Second) } ``` |
7 Vegetable Jul 12, 2023 你这个 TCP 结束之前,不会收到 EOF ,你就一直读不就行了吗,有什么需要处理的 |
8 awanganddong OP 这个文章可以参考 消息长度固定,提前确定包长度,读取的时候也安固定长度读取,适合定长消息包。 使用特殊的字符或字符串作为消息的边界,例如 HTTP 协议的 headers 以“\r\n”为字段的分隔符 自定义协议,将消息分为消息头和消息体,消息头中包含表示消息总长度 https://wangbjun.site/2019/coding/golang/golang-tcp-package.html 谢谢各位 |
9 Vegetable Jul 12, 2023 最后 err==EOF 的时候,data 是有值的,你不能直接丢掉,其他没什么问题 |
10 awanganddong OP @Vegetable 好的,谢谢了。 |
11 iceheart Jul 12, 2023 via Android 一直收不到分隔符,内存不是要爆掉啦 |
12 nightwitch Jul 12, 2023 这种方案也就在内网环境下用用,本质上和用换行符做分割没有什么区别。 一旦被人摸清楚方案,无限给你发不带分割符的包,轻轻松松 oom |
13 deorth Jul 12, 2023 via Android 出警怎么这么慢啊 |
14 rrfeng Jul 12, 2023 via Android 这种适合搞一个 ringbuffer |
15 MoYi123 Jul 13, 2023 @nightwitch OOM 是另一个问题, http 协议的 content-length 也没有机制保证你不 oom 吧. |
16 itechify PRO @MoYi123 类似 nginx 的 client_max_body_size ,默认 0 无限制,设置最大长度,超过了就拒绝? |
17 mcfog Jul 13, 2023 直接 bufio.NewScanner 搞定,用 https://pkg.go.dev/bufio#Scanner.Split 配置一个,分隔符策略几乎可以照抄默认的 ScanLines |
18 trzzzz Jul 15, 2023 @awanganddong 确实,像 scp 和 sftp 底层的实现都是基于 tcp 基础上自己规定客户端和服务端间的协议 |
19 voidmnwzp Jul 21, 2023 via iPhone 建议用 CRLF 分割 |
20 wkong Jul 25, 2023 |
21 ace12 Aug 3, 2023 怎么还没有喷沾包的啊,我好难受 |