go語言如何處理TCP拆包/粘包

這篇文章主要講解了“go語言如何處理TCP拆包/粘包”，文中的講解內(nèi)容簡單清晰，易于學(xué)習(xí)與理解，下面請大家跟著小編的思路慢慢深入，一起來研究和學(xué)習(xí)“go語言如何處理TCP拆包/粘包”吧！

part 1

最近在學(xué)習(xí)go自帶的rpc，看完了一遍想著自己實(shí)現(xiàn)一個(gè)codec，也就是自定義消息的序列化和反序列化。消息的序列化和反序列化涉及到兩步：

1、從網(wǎng)絡(luò)中讀取數(shù)據(jù)和將數(shù)據(jù)寫到網(wǎng)絡(luò)中；

2、根據(jù)拿到的二進(jìn)制數(shù)據(jù)反序列化以及把現(xiàn)有的對象序列化成二進(jìn)制數(shù)據(jù)。而這個(gè)過程中就需要處理TCP的拆包粘包了。

TCP的拆包/粘包也算是網(wǎng)絡(luò)編程中一個(gè)比較基礎(chǔ)的問題了，具體的問題含義和解決方式也不再詳細(xì)描述了。雖然作為實(shí)現(xiàn)應(yīng)用層邏輯的程序員可能根本不需要關(guān)心這個(gè)，作為中間件的開發(fā)，同時(shí)也出于學(xué)習(xí)go語言的目的，還是稍微進(jìn)行一下練習(xí)。

part 2

TCP拆包粘包的解決思路：在讀取數(shù)據(jù)時(shí)，將讀取到的二進(jìn)制數(shù)據(jù)在正確的位置進(jìn)行分割即可。這里直接使用head+body的方式，也就是在發(fā)送數(shù)據(jù)時(shí)先將整個(gè)數(shù)據(jù)的大小附加在數(shù)據(jù)前，就像這樣：

+++++++++++++++++++++++++++++++++++++
size (2 bytes)  | body (size bytes)
+++++++++++++++++++++++++++++++++++++

這里將數(shù)據(jù)包的size作為head
注：這里舉的例子里，size占2個(gè)byte；size具體占用的byte數(shù)可以根據(jù)實(shí)際情況決定

part 3

server具體實(shí)現(xiàn)：

func doConn(conn net.Conn) {
    var (
        buffer = bytes.NewBuffer(make([]byte, 0, BUF_SIZE)) //buffer用來緩存讀取到的數(shù)據(jù)
        readBytes = make([]byte, BUF_SIZE) //readBytes用來接收每次讀取的數(shù)據(jù)，每次讀取完成之后將readBytes添加到buffer中
        isHead = true //用來標(biāo)識(shí)當(dāng)前的狀態(tài)：正在處理size部分還是body部分
        bodyLen = 0 //表示body的長度
    )

    for {
        //首先讀取數(shù)據(jù)
        readByteNum, err := conn.Read(readBytes)
        if err != nil {
            log.Fatal(err)
            return
        }
        buffer.Write(readBytes[0:readByteNum])//將讀取到的數(shù)據(jù)放到buffer中
        
        // 然后處理數(shù)據(jù)
        for {
            if isHead {
                if buffer.Len() >= HEAD_SIZE {
                    isHead = false
                    head := make([]byte, HEAD_SIZE)
                    _, err = buffer.Read(head)
                    if err != nil {
                        log.Fatal(err)
                        return
                    }
                    bodyLen = int(binary.BigEndian.Uint16(head))
                } else {
                    break;
                }
            }

            if !isHead {
                if buffer.Len() >= bodyLen {
                    body := make([]byte, bodyLen)
                    _, err = buffer.Read(body[:bodyLen])
                    if err != nil {
                        log.Fatal(err)
                        return
                    }
                    fmt.Println("received body: " + string(body[:bodyLen]))
                    isHead = true
                } else {
                    break;
                }
            }
        }
    }
    
    func HandleTcp() {
 listener, err := net.Listen("tcp", ":1234")
 if err != nil {
  log.Fatal(err)
  return
 }
 log.Println("start listening on 1234")
 for {
  conn, err := listener.Accept()
  if err != nil {
   log.Fatal(err)
   return
  }
  go doConn(conn)
 }
}

client具體實(shí)現(xiàn)：

func SendStringwithTcp(arg string) error {
 conn, err := net.Dial("tcp", ":1234")
 if err != nil {
  log.Fatal(err)
  return err
 }

 head := make([]byte, server.HEAD_SIZE)
 content := []byte(arg)
 headSize := len(content)
 binary.BigEndian.PutUint16(head, uint16(headSize))

    //先寫入head部分，再寫入body部分
 _, err = conn.Write(head)
 if err != nil {
  log.Fatal(err)
  return err
 }
 _, err = conn.Write(content)
 if err != nil {
  log.Fatal(err)
  return err
 }
 return nil
}

感謝各位的閱讀，以上就是“go語言如何處理TCP拆包/粘包”的內(nèi)容了，經(jīng)過本文的學(xué)習(xí)后，相信大家對go語言如何處理TCP拆包/粘包這一問題有了更深刻的體會(huì)，具體使用情況還需要大家實(shí)踐驗(yàn)證。這里是億速云，小編將為大家推送更多相關(guān)知識(shí)點(diǎn)的文章，歡迎關(guān)注！