什么是粘包问题
最近在使用Golang编写Socket层,发现有时候接收端会一次读到多个数据包的问题。于是通过查阅资料,发现这个就是传说中的TCP粘包问题。下面通过编写代码来重现这个问题:
服务端代码 server/main.go
func main() { l, err := net.Listen("tcp", ":4044") if err != nil { panic(err) } fmt.Println("listen to 4044") for { // 监听到新的连接,创建新的 goroutine 交给 handleConn函数 处理 conn, err := l.Accept() if err != nil { fmt.Println("conn err:", err) } else { go handleConn(conn) } } } func handleConn(conn net.Conn) { defer conn.Close() defer fmt.Println("关闭") fmt.Println("新连接:", conn.RemoteAddr()) result := bytes.NewBuffer(nil) var buf [1024]byte for { n, err := conn.Read(buf[0:]) result.Write(buf[0:n]) if err != nil { if err == io.EOF { continue } else { fmt.Println("read err:", err) break } } else { fmt.Println("recv:", result.String()) } result.Reset() } }
客户端代码 client/main.go
func main() { data := []byte("[这里才是一个完整的数据包]") conn, err := net.DialTimeout("tcp", "localhost:4044", time.Second*30) if err != nil { fmt.Printf("connect failed, err : %v\n", err.Error()) return } for i := 0; i <1000; i++ { _, err = conn.Write(data) if err != nil { fmt.Printf("write failed , err : %v\n", err) break } } }
运行结果
listen to 4044
新连接: [::1]:53079
recv: [这里才是一个完整的数据包][这里才是一个完整的数据包][这里才是一个完整的数据包][这里才是一个完整的数据包][这里才是一个完整的数据包][这里才是一个完整的数据包][这里才是一个完整的数据包][这里才是一个完整的数据包][这里才是一个完整的数据包][这里才是一个完整的数据包][这里才是一个完整的数据包][这里才是一个完整的数据包][这里才是一个完整的数据包][这里才是一个完整的数据包][这里才是一个完整的数据包][这里才是一个完整的数据包][这里才是一个完整的数据包][这里才是一个完整的数据包][这里才是一个完整的数据包][这里才是一个完整的数据包][这里才是一个完整的数据包][这里才是一个完整的数据包][这里才是一个完整的数据包][这里才是一个完整的数据包][这里才是一个完整的数据包][这里才是一个完整的数据包][这里才是一个完整的数据"htmlcode">type SplitFunc func(data []byte, atEOF bool) (advance int, token []byte, err error)Golang官网文档上提供的使用例子"htmlcode">
func main() { // An artificial input source. const input = "1234 5678 1234567901234567890" scanner := bufio.NewScanner(strings.NewReader(input)) // Create a custom split function by wrapping the existing ScanWords function. split := func(data []byte, atEOF bool) (advance int, token []byte, err error) { advance, token, err = bufio.ScanWords(data, atEOF) if err == nil && token != nil { _, err = strconv.ParseInt(string(token), 10, 32) } return } // Set the split function for the scanning operation. scanner.Split(split) // Validate the input for scanner.Scan() { fmt.Printf("%s\n", scanner.Text()) } if err := scanner.Err(); err != nil { fmt.Printf("Invalid input: %s", err) } }于是,我们可以这样改写我们的程序:
服务端代码 server/main.go
func main() { l, err := net.Listen("tcp", ":4044") if err != nil { panic(err) } fmt.Println("listen to 4044") for { conn, err := l.Accept() if err != nil { fmt.Println("conn err:", err) } else { go handleConn2(conn) } } } func packetSlitFunc(data []byte, atEOF bool) (advance int, token []byte, err error) { // 检查 atEOF 参数 和 数据包头部的四个字节是否 为 0x123456(我们定义的协议的魔数) if !atEOF && len(data) > 6 && binary.BigEndian.Uint32(data[:4]) == 0x123456 { var l int16 // 读出 数据包中 实际数据 的长度(大小为 0 ~ 2^16) binary.Read(bytes.NewReader(data[4:6]), binary.BigEndian, &l) pl := int(l) + 6 if pl <= len(data) { return pl, data[:pl], nil } } return } func handleConn2(conn net.Conn) { defer conn.Close() defer fmt.Println("关闭") fmt.Println("新连接:", conn.RemoteAddr()) result := bytes.NewBuffer(nil) var buf [65542]byte // 由于 标识数据包长度 的只有两个字节 故数据包最大为 2^16+4(魔数)+2(长度标识) for { n, err := conn.Read(buf[0:]) result.Write(buf[0:n]) if err != nil { if err == io.EOF { continue } else { fmt.Println("read err:", err) break } } else { scanner := bufio.NewScanner(result) scanner.Split(packetSlitFunc) for scanner.Scan() { fmt.Println("recv:", string(scanner.Bytes()[6:])) } } result.Reset() } }客户端代码 client/main.go
func main() { l, err := net.Listen("tcp", ":4044") if err != nil { panic(err) } fmt.Println("listen to 4044") for { conn, err := l.Accept() if err != nil { fmt.Println("conn err:", err) } else { go handleConn2(conn) } } } func packetSlitFunc(data []byte, atEOF bool) (advance int, token []byte, err error) { // 检查 atEOF 参数 和 数据包头部的四个字节是否 为 0x123456(我们定义的协议的魔数) if !atEOF && len(data) > 6 && binary.BigEndian.Uint32(data[:4]) == 0x123456 { var l int16 // 读出 数据包中 实际数据 的长度(大小为 0 ~ 2^16) binary.Read(bytes.NewReader(data[4:6]), binary.BigEndian, &l) pl := int(l) + 6 if pl <= len(data) { return pl, data[:pl], nil } } return } func handleConn2(conn net.Conn) { defer conn.Close() defer fmt.Println("关闭") fmt.Println("新连接:", conn.RemoteAddr()) result := bytes.NewBuffer(nil) var buf [65542]byte // 由于 标识数据包长度 的只有两个字节 故数据包最大为 2^16+4(魔数)+2(长度标识) for { n, err := conn.Read(buf[0:]) result.Write(buf[0:n]) if err != nil { if err == io.EOF { continue } else { fmt.Println("read err:", err) break } } else { scanner := bufio.NewScanner(result) scanner.Split(packetSlitFunc) for scanner.Scan() { fmt.Println("recv:", string(scanner.Bytes()[6:])) } } result.Reset() } }运行结果
listen to 4044
新连接: [::1]:55738
recv: [这里才是一个完整的数据包]
recv: [这里才是一个完整的数据包]
recv: [这里才是一个完整的数据包]
recv: [这里才是一个完整的数据包]
recv: [这里才是一个完整的数据包]
recv: [这里才是一个完整的数据包]
recv: [这里才是一个完整的数据包]
recv: [这里才是一个完整的数据包]
...省略其它的...总结
以上就是这篇文章的全部内容了,希望本文的内容对大家的学习或者工作具有一定的参考学习价值,谢谢大家对的支持。
golang,tcp粘包拆包
免责声明:本站文章均来自网站采集或用户投稿,网站不提供任何软件下载或自行开发的软件! 如有用户或公司发现本站内容信息存在侵权行为,请邮件告知! 858582#qq.com
更新日志
- 刘欢.2004-经典20年珍藏锦集【新索】【WAV+CUE】
- 中唱唱片群星《好歌珍藏-游子情深》2CDWAV
- CD圣经上榜天碟1995-乌仁娜-《蒙古草原之歌》[WAV+CUE].
- 【电影原声】武满彻《旭日东升》1993[WAV+CUE整轨]
- Taylor Swift《THE TORTURED POETS DEPARTMENT》[320K/MP3][148.54MB]
- Taylor Swift《THE TORTURED POETS DEPARTMENT》[FLAC/分轨][405.72MB]
- Joyce Jonathan《法式松弛感 漫步香榭丽舍》[320K/MP3][80.8MB]
- 女神异闻录5佐仓双叶coop攻略 p5r佐仓双叶对话选项攻略
- 【民谣】张智《尼勒克小镇》[FLAC]
- 林一峰2018-TRAVELOGUE4ESCAPE[香港首版][WAV+CUE]
- MollyLewis《OnTheLips》(2024)[Hi-Res96kHz_24bitFLAC]
- Joyce Jonathan《法式松弛感 漫步香榭丽舍》[FLAC/分轨][230.77MB]
- 群星《影视剧 春色寄情人 原声带》[320K/MP3][394.18MB]
- 吴牧野《强者独白II 李斯特巅峰作品选》[320K/MP3][216.01MB]
- 女神异闻录5御船千早coop攻略 p5r御船千早对话选项攻略