日本综合一区二区|亚洲中文天堂综合|日韩欧美自拍一区|男女精品天堂一区|欧美自拍第6页亚洲成人精品一区|亚洲黄色天堂一区二区成人|超碰91偷拍第一页|日韩av夜夜嗨中文字幕|久久蜜综合视频官网|精美人妻一区二区三区

RELATEED CONSULTING
相關(guān)咨詢
選擇下列產(chǎn)品馬上在線溝通
服務(wù)時(shí)間：8:30-17:00
你可能遇到了下面的問(wèn)題
關(guān)閉右側(cè)工具欄

新聞中心

這里有您想知道的互聯(lián)網(wǎng)營(yíng)銷解決方案
一篇文章帶你了解Go語(yǔ)言基礎(chǔ)之網(wǎng)絡(luò)編程

前言

創(chuàng)新互聯(lián)建站長(zhǎng)期為上1000家客戶提供的網(wǎng)站建設(shè)服務(wù)，團(tuán)隊(duì)從業(yè)經(jīng)驗(yàn)10年，關(guān)注不同地域、不同群體，并針對(duì)不同對(duì)象提供差異化的產(chǎn)品和服務(wù)；打造開(kāi)放共贏平臺(tái)，與合作伙伴共同營(yíng)造健康的互聯(lián)網(wǎng)生態(tài)環(huán)境。為漳州企業(yè)提供專業(yè)的成都網(wǎng)站設(shè)計(jì)、成都網(wǎng)站制作，漳州網(wǎng)站改版等技術(shù)服務(wù)。擁有10余年豐富建站經(jīng)驗(yàn)和眾多成功案例,為您定制開(kāi)發(fā)。

Hi，大家好呀，我是碼農(nóng)，星期八，我們身處21世紀(jì)，我們的世界已經(jīng)在不知不覺(jué)中，就像很多網(wǎng)一樣在互聯(lián)互通。

互聯(lián)網(wǎng)是一個(gè)統(tǒng)稱，目前比較常用的有TCP，UDP協(xié)議。

當(dāng)然，還有很多其他的協(xié)議，但是本次主要講最常用的TCP和UDP協(xié)議。

socker編程

我們所學(xué)的TCP和UDP，統(tǒng)稱為Socker編程，也叫做套接字編程。

多臺(tái)機(jī)器要實(shí)現(xiàn)互相通訊，其實(shí)是一個(gè)非常復(fù)雜的過(guò)程，底層從鋪設(shè)網(wǎng)線，網(wǎng)線接口，交換機(jī)，路由器，在到規(guī)定各種協(xié)議。

再到應(yīng)用層QQ，微信等軟件。

如果沒(méi)有一套標(biāo)準(zhǔn)，每次使用都要自己去實(shí)現(xiàn)，可能每個(gè)程序員都不是掉頭發(fā)那么簡(jiǎn)單了!

有了Socker之后，Socker會(huì)在應(yīng)用層之前，將各種繁瑣的的底層操作隱藏，我們可能只需要Socker.TCP就實(shí)現(xiàn)了TCP協(xié)議的通訊。

Go語(yǔ)言TCP

TCP屬于穩(wěn)定的，可靠的長(zhǎng)連接，

既然要涉及通訊，必然有兩個(gè)終端，最起碼一個(gè)是服務(wù)端，一個(gè)是客戶端，就像我們的淘寶，我們每次打開(kāi)淘寶，都要去鏈接它，當(dāng)然，淘寶可不直接是TCP。

服務(wù)端

在Go中實(shí)現(xiàn)服務(wù)端，并且在服務(wù)端并發(fā)很簡(jiǎn)單，只需要將每個(gè)連接讓一個(gè)協(xié)程處理即可!

代碼

 
 
 
 
    
  
  
  
  
  1. package main 
    2. 
  
  
  
  
  2.  
    3. 
  
  
  
  
  3. import ( 
    4. 
  
  
  
  
  4.     "bufio" 
    5. 
  
  
  
  
  5.     "fmt" 
    6. 
  
  
  
  
  6.     "net" 
    7. 
  
  
  
  
  7. ) 
    8. 
  
  
  
  
  8.  
    9. 
  
  
  
  
  9. func process(conn net.Conn) { 
    10. 
  
  
  
  
  10.     defer conn.Close() 
    11. 
  
  
  
  
  11.     for { 
    12. 
  
  
  
  
  12.         reader := bufio.NewReader(conn) 
    13. 
  
  
  
  
  13.         buf := make([]byte， 128) 
    14. 
  
  
  
  
  14.         n， err := reader.Read(buf) 
    15. 
  
  
  
  
  15.         if err != nil { 
    16. 
  
  
  
  
  16.             fmt.Println("數(shù)據(jù)讀取失敗"， err) 
    17. 
  
  
  
  
  17.             return 
    18. 
  
  
  
  
  18.         } 
    19. 
  
  
  
  
  19.         recvStr := string(buf[:n]) 
    20. 
  
  
  
  
  20.         fmt.Println("客戶端發(fā)送過(guò)來(lái)的值:"， recvStr) 
    21. 
  
  
  
  
  21. } 
    22. 
  
  
  
  
  22.  
    23. 
  
  
  
  
  23. } 
    24. 
  
  
  
  
  24. func main() { 
    25. 
  
  
  
  
  25.     lister， err := net.Listen("tcp"， "0.0.0.0:8008") 
    26. 
  
  
  
  
  26.     if err != nil { 
    27. 
  
  
  
  
  27.         fmt.Println("連接失敗"， err) 
    28. 
  
  
  
  
  28. } 
    29. 
  
  
  
  
  29.     for { 
    30. 
  
  
  
  
  30.         fmt.Println("等待建立連接，此時(shí)會(huì)阻塞住") 
    31. 
  
  
  
  
  31.         conn， err := lister.Accept() //等待建立連接 
    32. 
  
  
  
  
  32.         fmt.Println("連接建立成功，繼續(xù)") 
    33. 
  
  
  
  
  33.         if err != nil { 
    34. 
  
  
  
  
  34.             fmt.Println("建立連接失敗"， err) 
    35. 
  
  
  
  
  35.             //繼續(xù)監(jiān)聽(tīng)下次鏈接 
    36. 
  
  
  
  
  36.             continue 
    37. 
  
  
  
  
  37.         } 
    38. 
  
  
  
  
  38.         go process(conn) 
    39. 
  
  
  
  
  39. } 
    40. 
  
  
  
  
  40. } 
    41.

客戶端

客戶端就很簡(jiǎn)單了，相對(duì)來(lái)說(shuō)是不需要并發(fā)的，只需要連接就行。

代碼

 
 
 
 
    
  
  
  
  
  1. package main 
    2. 
  
  
  
  
  2.  
    3. 
  
  
  
  
  3. import ( 
    4. 
  
  
  
  
  4.     "bufio" 
    5. 
  
  
  
  
  5.     "fmt" 
    6. 
  
  
  
  
  6.     "net" 
    7. 
  
  
  
  
  7.     "os" 
    8. 
  
  
  
  
  8. ) 
    9. 
  
  
  
  
  9.  
    10. 
  
  
  
  
  10. //客戶端 
    11. 
  
  
  
  
  11. func main() { 
    12. 
  
  
  
  
  12.     conn， err := net.Dial("tcp"， "192.168.10.148:8008") 
    13. 
  
  
  
  
  13.     if err != nil { 
    14. 
  
  
  
  
  14.         fmt.Println("連接服務(wù)器失敗"，err) 
    15. 
  
  
  
  
  15. } 
    16. 
  
  
  
  
  16.     defer conn.Close() 
    17. 
  
  
  
  
  17.     inputReader:=bufio.NewReader(os.Stdin) 
    18. 
  
  
  
  
  18.     for{ 
    19. 
  
  
  
  
  19.         fmt.Println(":") 
    20. 
  
  
  
  
  20.         input，_:=inputReader.ReadString('\n') 
    21. 
  
  
  
  
  21.         _， err = conn.Write([]byte(input)) 
    22. 
  
  
  
  
  22.         if err != nil { 
    23. 
  
  
  
  
  23.             fmt.Println("發(fā)送成功") 
    24. 
  
  
  
  
  24.         } 
    25. 
  
  
  
  
  25. } 
    26. 
  
  
  
  
  26. } 
    27.

執(zhí)行結(jié)果

就這樣，我們實(shí)現(xiàn)了服務(wù)端并發(fā)的處理所有客戶端的請(qǐng)求。

粘包

我們先看一下什么是粘包。

服務(wù)端

 
 
 
 
    
  
  
  
  
  1. package main 
    2. 
  
  
  
  
  2.  
    3. 
  
  
  
  
  3. import ( 
    4. 
  
  
  
  
  4.     "bufio" 
    5. 
  
  
  
  
  5.     "fmt" 
    6. 
  
  
  
  
  6.     "io" 
    7. 
  
  
  
  
  7.     "net" 
    8. 
  
  
  
  
  8. ) 
    9. 
  
  
  
  
  9.  
    10. 
  
  
  
  
  10. func process(conn net.Conn) { 
    11. 
  
  
  
  
  11.     defer conn.Close() 
    12. 
  
  
  
  
  12.     reader := bufio.NewReader(conn) 
    13. 
  
  
  
  
  13.     buf := make([]byte， 1024) 
    14. 
  
  
  
  
  14.     for { 
    15. 
  
  
  
  
  15.         n， err := reader.Read(buf) 
    16. 
  
  
  
  
  16.         //讀完了 
    17. 
  
  
  
  
  17.         if err == io.EOF { 
    18. 
  
  
  
  
  18.             fmt.Println("讀完了") 
    19. 
  
  
  
  
  19.             break 
    20. 
  
  
  
  
  20.         } 
    21. 
  
  
  
  
  21.         //讀錯(cuò)了 
    22. 
  
  
  
  
  22.         if err != nil { 
    23. 
  
  
  
  
  23.             fmt.Println("數(shù)據(jù)讀取失敗"， err) 
    24. 
  
  
  
  
  24.             return 
    25. 
  
  
  
  
  25.         } 
    26. 
  
  
  
  
  26.         recvStr := string(buf[:n]) 
    27. 
  
  
  
  
  27.         fmt.Println("客戶端發(fā)送過(guò)來(lái)的值:"， recvStr) 
    28. 
  
  
  
  
  28. } 
    29. 
  
  
  
  
  29.  
    30. 
  
  
  
  
  30. } 
    31. 
  
  
  
  
  31. func main() { 
    32. 
  
  
  
  
  32.     lister， err := net.Listen("tcp"， "0.0.0.0:8008") 
    33. 
  
  
  
  
  33.     if err != nil { 
    34. 
  
  
  
  
  34.         fmt.Println("連接失敗"， err) 
    35. 
  
  
  
  
  35.         return 
    36. 
  
  
  
  
  36. } 
    37. 
  
  
  
  
  37.     defer lister.Close() 
    38. 
  
  
  
  
  38.     for { 
    39. 
  
  
  
  
  39.         fmt.Println("等待建立連接，此時(shí)會(huì)阻塞住") 
    40. 
  
  
  
  
  40.         conn， err := lister.Accept() //等待建立連接 
    41. 
  
  
  
  
  41.         fmt.Println("連接建立成功，繼續(xù)") 
    42. 
  
  
  
  
  42.         if err != nil { 
    43. 
  
  
  
  
  43.             fmt.Println("建立連接失敗"， err) 
    44. 
  
  
  
  
  44.             //繼續(xù)監(jiān)聽(tīng)下次鏈接 
    45. 
  
  
  
  
  45.             continue 
    46. 
  
  
  
  
  46.         } 
    47. 
  
  
  
  
  47.         go process(conn) 
    48. 
  
  
  
  
  48. } 
    49. 
  
  
  
  
  49. } 
    50.

客戶端

 
 
 
 
    
  
  
  
  
  1. package main 
    2. 
  
  
  
  
  2.  
    3. 
  
  
  
  
  3. import ( 
    4. 
  
  
  
  
  4.     "fmt" 
    5. 
  
  
  
  
  5.     "net" 
    6. 
  
  
  
  
  6. ) 
    7. 
  
  
  
  
  7.  
    8. 
  
  
  
  
  8. //客戶端 
    9. 
  
  
  
  
  9. func main() { 
    10. 
  
  
  
  
  10.     conn， err := net.Dial("tcp"， "192.168.10.148:8008") 
    11. 
  
  
  
  
  11.     if err != nil { 
    12. 
  
  
  
  
  12.         fmt.Println("連接服務(wù)器失敗"， err) 
    13. 
  
  
  
  
  13. } 
    14. 
  
  
  
  
  14.     defer conn.Close() 
    15. 
  
  
  
  
  15.     for i := 0; i < 10; i++ { 
    16. 
  
  
  
  
  16.         sendStr := "hello world ads asdf asd fads fadsf ads ads asd asd ads " 
    17. 
  
  
  
  
  17.         conn.Write([]byte(sendStr)) 
    18. 
  
  
  
  
  18.         time.Sleep(time.Second) 
    19. 
  
  
  
  
  19. } 
    20. 
  
  
  
  
  20. } 
    21.

注意:18行代碼睡眠了1s

執(zhí)行結(jié)果

如果我注釋了第18行代碼

執(zhí)行結(jié)果

直接都淦到一行了，what?這是啥情況，不應(yīng)該跟原來(lái)一樣嗎???

每發(fā)送一個(gè)值，那邊就接收一下，這怎么整到一塊了!!!

原因

主要原因是因?yàn)槲覀兪菓?yīng)用層軟件，是跑在操作系統(tǒng)之上的軟件，當(dāng)我們向服務(wù)器發(fā)送一個(gè)數(shù)據(jù)時(shí)，是調(diào)用操作系統(tǒng)的相關(guān)接口發(fā)送的，操作系統(tǒng)再經(jīng)過(guò)各種復(fù)雜的操作，發(fā)送到對(duì)方機(jī)器

但是操作系統(tǒng)有一個(gè)發(fā)送數(shù)據(jù)緩沖區(qū)，默認(rèn)情況如果緩沖區(qū)是有大小的，如果緩沖區(qū)沒(méi)滿，是不會(huì)發(fā)送數(shù)據(jù)的，所以上述客戶端在發(fā)送數(shù)據(jù)時(shí)，系統(tǒng)的緩沖區(qū)都沒(méi)滿，一直壓在了操作系統(tǒng)的緩沖區(qū)中，最后發(fā)現(xiàn)沒(méi)數(shù)據(jù)了，才一次都發(fā)送到服務(wù)端

但是為什么sleep(1)又管用了呢?這是因?yàn)榫彌_區(qū)不止一個(gè)程序在用，1s的時(shí)間足夠其他程序?qū)⒕彌_區(qū)打滿，然后各自發(fā)各自的數(shù)據(jù)，這也是為什么第一次操作沒(méi)問(wèn)題，第二次有問(wèn)題，因?yàn)榈诙稳慷际俏覀兛蛻舳舜驖M的

解決粘包

工具函數(shù)

我們將解包封包的函數(shù)封裝一下

 
 
 
 
    
  
  
  
  
  1. socker_sitck/stick.go 
    2. 
 
 
 
 
 
 
 
 
    
  
  
  
  
  1. package socker_stick 
    2. 
  
  
  
  
  2.  
    3. 
  
  
  
  
  3. import ( 
    4. 
  
  
  
  
  4.     "bufio" 
    5. 
  
  
  
  
  5.     "bytes" 
    6. 
  
  
  
  
  6.     "encoding/binary" 
    7. 
  
  
  
  
  7.     "fmt" 
    8. 
  
  
  
  
  8. ) 
    9. 
  
  
  
  
  9.  
    10. 
  
  
  
  
  10. //Encode 將消息編碼 
    11. 
  
  
  
  
  11. func Encode(message string) ([]byte， error) { 
    12. 
  
  
  
  
  12.     length := int32(len(message)) 
    13. 
  
  
  
  
  13.     var pkg = new(bytes.Buffer) 
    14. 
  
  
  
  
  14.     //寫(xiě)入消息頭 
    15. 
  
  
  
  
  15.     err := binary.Write(pkg， binary.LittleEndian， length) 
    16. 
  
  
  
  
  16.     if err != nil { 
    17. 
  
  
  
  
  17.         fmt.Println("寫(xiě)入消息頭失敗"， err) 
    18. 
  
  
  
  
  18.         return nil， err 
    19. 
  
  
  
  
  19. } 
    20. 
  
  
  
  
  20.     //寫(xiě)入消息實(shí)體 
    21. 
  
  
  
  
  21.     err = binary.Write(pkg， binary.LittleEndian， []byte(message)) 
    22. 
  
  
  
  
  22.     if err != nil { 
    23. 
  
  
  
  
  23.         fmt.Println("寫(xiě)入消息實(shí)體失敗"， err) 
    24. 
  
  
  
  
  24.         return nil， err 
    25. 
  
  
  
  
  25. } 
    26. 
  
  
  
  
  26.     return pkg.Bytes()， nil 
    27. 
  
  
  
  
  27. } 
    28. 
  
  
  
  
  28.  
    29. 
  
  
  
  
  29. //Decode解碼消息 
    30. 
  
  
  
  
  30. func Decode(reader *bufio.Reader) (string， error) { 
    31. 
  
  
  
  
  31.     //讀取信息長(zhǎng)度 
    32. 
  
  
  
  
  32.     lengthByte， _ := reader.Peek(4) 
    33. 
  
  
  
  
  33.     lengthBuff := bytes.NewBuffer(lengthByte) 
    34. 
  
  
  
  
  34.     var length int32 
    35. 
  
  
  
  
  35.     err := binary.Read(lengthBuff， binary.LittleEndian， &length) 
    36. 
  
  
  
  
  36.     if err != nil { 
    37. 
  
  
  
  
  37.         return ""， err 
    38. 
  
  
  
  
  38. } 
    39. 
  
  
  
  
  39.     //BuffRead 返回緩沖區(qū)現(xiàn)有的可讀的字節(jié)數(shù) 
    40. 
  
  
  
  
  40.     if int32(reader.Buffered()) < length+4 { 
    41. 
  
  
  
  
  41.         return ""， err 
    42. 
  
  
  
  
  42. } 
    43. 
  
  
  
  
  43.     pack := make([]byte， int(4+length)) 
    44. 
  
  
  
  
  44.     _， err = reader.Read(pack) 
    45. 
  
  
  
  
  45.     if err != nil { 
    46. 
  
  
  
  
  46.         return ""， err 
    47. 
  
  
  
  
  47. } 
    48. 
  
  
  
  
  48.     return string(pack[4:])， nil 
    49. 
  
  
  
  
  49. } 
    50.

服務(wù)端

 
 
 
 
    
  
  
  
  
  1. package main 
    2. 
  
  
  
  
  2.  
    3. 
  
  
  
  
  3. import ( 
    4. 
  
  
  
  
  4.     "a3_course/socker_stick" 
    5. 
  
  
  
  
  5.     "bufio" 
    6. 
  
  
  
  
  6.     "fmt" 
    7. 
  
  
  
  
  7.     "io" 
    8. 
  
  
  
  
  8.     "net" 
    9. 
  
  
  
  
  9. ) 
    10. 
  
  
  
  
  10.  
    11. 
  
  
  
  
  11. func process(conn net.Conn) { 
    12. 
  
  
  
  
  12.     defer conn.Close() 
    13. 
  
  
  
  
  13.     reader := bufio.NewReader(conn) 
    14. 
  
  
  
  
  14.  
    15. 
  
  
  
  
  15.     for { 
    16. 
  
  
  
  
  16.         msg， err := socker_stick.Decode(reader) 
    17. 
  
  
  
  
  17.         //讀完了 
    18. 
  
  
  
  
  18.         if err == io.EOF { 
    19. 
  
  
  
  
  19.             fmt.Println("讀完了") 
    20. 
  
  
  
  
  20.             break 
    21. 
  
  
  
  
  21.         } 
    22. 
  
  
  
  
  22.         //讀錯(cuò)了 
    23. 
  
  
  
  
  23.         if err != nil { 
    24. 
  
  
  
  
  24.             fmt.Println("數(shù)據(jù)讀取失敗"， err) 
    25. 
  
  
  
  
  25.             return 
    26. 
  
  
  
  
  26.         } 
    27. 
  
  
  
  
  27.  
    28. 
  
  
  
  
  28.         fmt.Println("客戶端發(fā)送過(guò)來(lái)的值:"， msg) 
    29. 
  
  
  
  
  29. } 
    30. 
  
  
  
  
  30.  
    31. 
  
  
  
  
  31. } 
    32. 
  
  
  
  
  32. func main() { 
    33. 
  
  
  
  
  33.     lister， err := net.Listen("tcp"， "0.0.0.0:8008") 
    34. 
  
  
  
  
  34.     if err != nil { 
    35. 
  
  
  
  
  35.         fmt.Println("連接失敗"， err) 
    36. 
  
  
  
  
  36.         return 
    37. 
  
  
  
  
  37. } 
    38. 
  
  
  
  
  38.     defer lister.Close() 
    39. 
  
  
  
  
  39.     for { 
    40. 
  
  
  
  
  40.         fmt.Println("等待建立連接，此時(shí)會(huì)阻塞住") 
    41. 
  
  
  
  
  41.         conn， err := lister.Accept() //等待建立連接 
    42. 
  
  
  
  
  42.         fmt.Println("連接建立成功，繼續(xù)") 
    43. 
  
  
  
  
  43.         if err != nil { 
    44. 
  
  
  
  
  44.             fmt.Println("建立連接失敗"， err) 
    45. 
  
  
  
  
  45.             //繼續(xù)監(jiān)聽(tīng)下次鏈接 
    46. 
  
  
  
  
  46.             continue 
    47. 
  
  
  
  
  47.         } 
    48. 
  
  
  
  
  48.         go process(conn) 
    49. 
  
  
  
  
  49. } 
    50. 
  
  
  
  
  50. } 
    51.

客戶端

 
 
 
 
    
  
  
  
  
  1. package main 
    2. 
  
  
  
  
  2.  
    3. 
  
  
  
  
  3. import ( 
    4. 
  
  
  
  
  4.     "a3_course/socker_stick" 
    5. 
  
  
  
  
  5.     "fmt" 
    6. 
  
  
  
  
  6.     "net" 
    7. 
  
  
  
  
  7. ) 
    8. 
  
  
  
  
  8.  
    9. 
  
  
  
  
  9. //客戶端 
    10. 
  
  
  
  
  10. func main() { 
    11. 
  
  
  
  
  11.     conn， err := net.Dial("tcp"， "192.168.10.148:8008") 
    12. 
  
  
  
  
  12.     if err != nil { 
    13. 
  
  
  
  
  13.         fmt.Println("連接服務(wù)器失敗"， err) 
    14. 
  
  
  
  
  14. } 
    15. 
  
  
  
  
  15.     defer conn.Close() 
    16. 
  
  
  
  
  16.     for i := 0; i < 10; i++ { 
    17. 
  
  
  
  
  17.         sendStr := "hello world ads asdf asd fads fadsf ads ads asd asd ads " 
    18. 
  
  
  
  
  18.         data， err := socker_stick.Encode(sendStr) 
    19. 
  
  
  
  
  19.         if err != nil { 
    20. 
  
  
  
  
  20.             fmt.Println("編碼失敗"，err) 
    21. 
  
  
  
  
  21.             return 
    22. 
  
  
  
  
  22.         } 
    23. 
  
  
  
  
  23.         conn.Write(data) 
    24. 
  
  
  
  
  24.         //time.Sleep(time.Second) 
    25. 
  
  
  
  
  25. } 
    26. 
  
  
  
  
  26. } 
    27.

執(zhí)行結(jié)果

這次真的不管執(zhí)行幾次，都是這樣的結(jié)果

對(duì)了，只有TCP才有粘包

Go語(yǔ)言UDP

UDP是一個(gè)無(wú)連接協(xié)議，客戶端不會(huì)在乎服務(wù)端有沒(méi)有問(wèn)題，客戶端只管發(fā)，通常用于實(shí)時(shí)性比較高的領(lǐng)域

例如直播行業(yè)

服務(wù)端

 
 
 
 
    
  
  
  
  
  1. package main 
    2. 
  
  
  
  
  2.  
    3. 
  
  
  
  
  3. import ( 
    4. 
  
  
  
  
  4.     "fmt" 
    5. 
  
  
  
  
  5.     "net" 
    6. 
  
  
  
  
  6. ) 
    7. 
  
  
  
  
  7.  
    8. 
  
  
  
  
  8. func main() { 
    9. 
  
  
  
  
  9.     listen， err := net.ListenUDP("udp"， &net.UDPAddr{ 
    10. 
  
  
  
  
  10.         IP:   net.IPv4(0， 0， 0， 0)， 
    11. 
  
  
  
  
  11.         Port: 8009， 
    12. 
  
  
  
  
  12. }) 
    13. 
  
  
  
  
  13.     if err != nil { 
    14. 
  
  
  
  
  14.         panic(fmt.Sprintf("udp啟動(dòng)失敗，err:%v"， err)) 
    15. 
  
  
  
  
  15. } 
    16. 
  
  
  
  
  16.     defer listen.Close() 
    17. 
  
  
  
  
  17.     for{ 
    18. 
  
  
  
  
  18.         var data = make([]byte，1024) 
    19. 
  
  
  
  
  19.         n， addr， err := listen.ReadFromUDP(data) 
    20. 
  
  
  
  
  20.         if err != nil { 
    21. 
  
  
  
  
  21.             panic(fmt.Sprintf("讀取數(shù)據(jù)失敗，err:%v"， err)) 
    22. 
  
  
  
  
  22.         } 
    23. 
  
  
  
  
  23.         fmt.Println(string(data[:n])，addr，n) 
    24. 
  
  
  
  
  24. } 
    25. 
  
  
  
  
  25. } 
    26.

客戶端

 
 
 
 
    
  
  
  
  
  1. package main 
    2. 
  
  
  
  
  2.  
    3. 
  
  
  
  
  3. import ( 
    4. 
  
  
  
  
  4.     "fmt" 
    5. 
  
  
  
  
  5.     "net" 
    6. 
  
  
  
  
  6. ) 
    7. 
  
  
  
  
  7.  
    8. 
  
  
  
  
  8. func main() { 
    9. 
  
  
  
  
  9.     socker， err := net.DialUDP("udp"， nil， &net.UDPAddr{ 
    10. 
  
  
  
  
  10.         IP:   net.IPv4(0， 0， 0， 0)， 
    11. 
  
  
  
  
  11.         Port: 8009， 
    12. 
  
  
  
  
  12. }) 
    13. 
  
  
  
  
  13.     if err != nil { 
    14. 
  
  
  
  
  14.         panic(fmt.Sprintf("連接服務(wù)器失敗，err:%v"， err)) 
    15. 
  
  
  
  
  15. } 
    16. 
  
  
  
  
  16.     defer socker.Close() 
    17. 
  
  
  
  
  17.     sendStr:="你好呀" 
    18. 
  
  
  
  
  18.     _， err = socker.Write([]byte(sendStr)) 
    19. 
  
  
  
  
  19.     if err != nil { 
    20. 
  
  
  
  
  20.         panic(fmt.Sprintf("數(shù)據(jù)發(fā)送失敗，err:%v"， err)) 
    21. 
  
  
  
  
  21. } 
    22. 
  
  
  
  
  22. } 
    23.

執(zhí)行結(jié)果

總結(jié)

本次章節(jié)我們講述了什么是TCP，什么是UDP。

并且編寫(xiě)了代碼如何實(shí)現(xiàn)TCP服務(wù)端，TCP客戶端，UDP服務(wù)端，UDP客戶端。

講述了為什么會(huì)出現(xiàn)粘包，該怎么解決粘包。

逆水行舟，不進(jìn)則退!


當(dāng)前題目：一篇文章帶你了解Go語(yǔ)言基礎(chǔ)之網(wǎng)絡(luò)編程
轉(zhuǎn)載來(lái)源：http://www.dlmjj.cn/article/codihhg.html