前言
什么是TCP粘包問題以及為什么會產生TCP粘包，本文不加討論。本文使用golang的bufio.Scanner來實現自定義協議解包。
下面話不多說了，來一起看看詳細的介紹吧。
協議數據包定義
本文模擬一個日志服務器，該服務器接收客戶端傳到的數據包并顯示出來
|
1
2
3
4
5
6
7
8
9
10
|
type Package struct { Version [2]byte // 協議版本，暫定V1 Length int16 // 數據部分長度 Timestamp int64 // 時間戳 HostnameLength int16 // 主機名長度 Hostname []byte // 主機名 TagLength int16 // 標簽長度 Tag []byte // 標簽 Msg []byte // 日志數據} |
協議定義部分沒有什么好講的，根據具體的業務邏輯定義即可。
數據打包
由于TCP協議是語言無關的協議，所以直接把協議數據包結構體發送到TCP連接中也是不可能的，只能發送字節流數據，所以需要自己實現數據編碼。所幸golang提供了binary來幫助我們實現網絡字節編碼。
|
1
2
3
4
5
6
7
8
9
10
11
12
|
func (p *Package) Pack(writer io.Writer) error { var err error err = binary.Write(writer, binary.BigEndian, &p.Version) err = binary.Write(writer, binary.BigEndian, &p.Length) err = binary.Write(writer, binary.BigEndian, &p.Timestamp) err = binary.Write(writer, binary.BigEndian, &p.HostnameLength) err = binary.Write(writer, binary.BigEndian, &p.Hostname) err = binary.Write(writer, binary.BigEndian, &p.TagLength) err = binary.Write(writer, binary.BigEndian, &p.Tag) err = binary.Write(writer, binary.BigEndian, &p.Msg) return err} |
Pack方法的輸出目標為io.Writer，有利于接口擴展，只要實現了該接口即可編碼數據寫入。binary.BigEndian是字節序，本文暫時不討論，有需要的讀者可以自行查找資料研究。
數據解包
解包需要將TCP數據包解析到結構體中，接下來會講為什么需要添加幾個數據無關的長度字段。
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
|
func (p *Package) Unpack(reader io.Reader) error { var err error err = binary.Read(reader, binary.BigEndian, &p.Version) err = binary.Read(reader, binary.BigEndian, &p.Length) err = binary.Read(reader, binary.BigEndian, &p.Timestamp) err = binary.Read(reader, binary.BigEndian, &p.HostnameLength) p.Hostname = make([]byte, p.HostnameLength) err = binary.Read(reader, binary.BigEndian, &p.Hostname) err = binary.Read(reader, binary.BigEndian, &p.TagLength) p.Tag = make([]byte, p.TagLength) err = binary.Read(reader, binary.BigEndian, &p.Tag) p.Msg = make([]byte, p.Length-8-2-p.HostnameLength-2-p.TagLength) err = binary.Read(reader, binary.BigEndian, &p.Msg) return err} |
由于主機名、標簽這種數據是不固定長度的，所以需要兩個字節來標識數據長度，否則讀取的時候只知道一個總的數據長度是無法區分主機名、標簽名、日志數據的。
數據包的粘包問題解決
上文只是解決了編碼/解碼問題，前提是收到的數據包沒有產生粘包問題，解決粘包就是要正確分割字節流中的數據。一般有以下做法：
- 定長分隔(每個數據包最大為該長度) 缺點是數據不足時會浪費傳輸資源
- 特定字符分隔(如rn) 缺點是如果正文中有rn就會導致問題
- 在數據包中添加長度字段(本文采用的)
golang提供了bufio.Scanner來解決粘包問題。
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
|
scanner := bufio.NewScanner(reader) // reader為實現了io.Reader接口的對象，如net.Connscanner.Split(func(data []byte, atEOF bool) (advance int, token []byte, err error) { if !atEOF && data[0] == 'V' { // 由于我們定義的數據包頭最開始為兩個字節的版本號，所以只有以V開頭的數據包才處理 if len(data) > 4 { // 如果收到的數據>4個字節(2字節版本號+2字節數據包長度) length := int16(0) binary.Read(bytes.NewReader(data[2:4]), binary.BigEndian, &length) // 讀取數據包第3-4字節(int16)=>數據部分長度 if int(length)+4 <= len(data) { // 如果讀取到的數據正文長度+2字節版本號+2字節數據長度不超過讀到的數據(實際上就是成功完整的解析出了一個包) return int(length) + 4, data[:int(length)+4], nil } } } return})// 打印接收到的數據包for scanner.Scan() { scannedPack := new(Package) scannedPack.Unpack(bytes.NewReader(scanner.Bytes())) log.Println(scannedPack)} |
本文的核心就在于scanner.Split方法，該方法用來解析TCP數據包
完整源碼
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
|
package mainimport ( "bufio" "bytes" "encoding/binary" "fmt" "io" "log" "os" "time")type Package struct { Version [2]byte // 協議版本 Length int16 // 數據部分長度 Timestamp int64 // 時間戳 HostnameLength int16 // 主機名長度 Hostname []byte // 主機名 TagLength int16 // Tag長度 Tag []byte // Tag Msg []byte // 數據部分長度}func (p *Package) Pack(writer io.Writer) error { var err error err = binary.Write(writer, binary.BigEndian, &p.Version) err = binary.Write(writer, binary.BigEndian, &p.Length) err = binary.Write(writer, binary.BigEndian, &p.Timestamp) err = binary.Write(writer, binary.BigEndian, &p.HostnameLength) err = binary.Write(writer, binary.BigEndian, &p.Hostname) err = binary.Write(writer, binary.BigEndian, &p.TagLength) err = binary.Write(writer, binary.BigEndian, &p.Tag) err = binary.Write(writer, binary.BigEndian, &p.Msg) return err}func (p *Package) Unpack(reader io.Reader) error { var err error err = binary.Read(reader, binary.BigEndian, &p.Version) err = binary.Read(reader, binary.BigEndian, &p.Length) err = binary.Read(reader, binary.BigEndian, &p.Timestamp) err = binary.Read(reader, binary.BigEndian, &p.HostnameLength) p.Hostname = make([]byte, p.HostnameLength) err = binary.Read(reader, binary.BigEndian, &p.Hostname) err = binary.Read(reader, binary.BigEndian, &p.TagLength) p.Tag = make([]byte, p.TagLength) err = binary.Read(reader, binary.BigEndian, &p.Tag) p.Msg = make([]byte, p.Length-8-2-p.HostnameLength-2-p.TagLength) err = binary.Read(reader, binary.BigEndian, &p.Msg) return err}func (p *Package) String() string { return fmt.Sprintf("version:%s length:%d timestamp:%d hostname:%s tag:%s msg:%s", p.Version, p.Length, p.Timestamp, p.Hostname, p.Tag, p.Msg, )}func main() { hostname, err := os.Hostname() if err != nil { log.Fatal(err) } pack := &Package{ Version: [2]byte{'V', '1'}, Timestamp: time.Now().Unix(), HostnameLength: int16(len(hostname)), Hostname: []byte(hostname), TagLength: 4, Tag: []byte("demo"), Msg: []byte(("現在時間是:" + time.Now().Format("2006-01-02 15:04:05"))), } pack.Length = 8 + 2 + pack.HostnameLength + 2 + pack.TagLength + int16(len(pack.Msg)) buf := new(bytes.Buffer) // 寫入四次，模擬TCP粘包效果 pack.Pack(buf) pack.Pack(buf) pack.Pack(buf) pack.Pack(buf) // scanner scanner := bufio.NewScanner(buf) scanner.Split(func(data []byte, atEOF bool) (advance int, token []byte, err error) { if !atEOF && data[0] == 'V' { if len(data) > 4 { length := int16(0) binary.Read(bytes.NewReader(data[2:4]), binary.BigEndian, &length) if int(length)+4 <= len(data) { return int(length) + 4, data[:int(length)+4], nil } } } return }) for scanner.Scan() { scannedPack := new(Package) scannedPack.Unpack(bytes.NewReader(scanner.Bytes())) log.Println(scannedPack) } if err := scanner.Err(); err != nil { log.Fatal("無效數據包") }} |
寫在最后
golang作為一門強大的網絡編程語言，實現自定義協議是非常重要的，實際上實現自定義協議也不是很難，以下幾個步驟：
- 數據包編碼
- 數據包解碼
- 處理TCP粘包問題
- 斷線重連(可以使用心跳實現)(非必須)
總結
以上就是這篇文章的全部內容了，希望本文的內容對大家的學習或者工作具有一定的參考學習價值，如果有疑問大家可以留言交流，謝謝大家對服務器之家的支持。
原文鏈接：https://segmentfault.com/a/1190000013493942
