本篇內(nèi)容主要講解“如何理解Go語言基礎(chǔ)之網(wǎng)絡(luò)編程”,感興趣的朋友不妨來看看。本文介紹的方法操作簡(jiǎn)單快捷,實(shí)用性強(qiáng)。下面就讓小編來帶大家學(xué)習(xí)“如何理解Go語言基礎(chǔ)之網(wǎng)絡(luò)編程”吧!
創(chuàng)新互聯(lián)是專業(yè)的丹東網(wǎng)站建設(shè)公司,丹東接單;提供網(wǎng)站設(shè)計(jì)、成都做網(wǎng)站,網(wǎng)頁設(shè)計(jì),網(wǎng)站設(shè)計(jì),建網(wǎng)站,PHP網(wǎng)站建設(shè)等專業(yè)做網(wǎng)站服務(wù);采用PHP框架,可快速的進(jìn)行丹東網(wǎng)站開發(fā)網(wǎng)頁制作和功能擴(kuò)展;專業(yè)做搜索引擎喜愛的網(wǎng)站,專業(yè)的做網(wǎng)站團(tuán)隊(duì),希望更多企業(yè)前來合作!
socker編程
我們所學(xué)的TCP和UDP,統(tǒng)稱為Socker編程,也叫做套接字編程。
多臺(tái)機(jī)器要實(shí)現(xiàn)互相通訊,其實(shí)是一個(gè)非常復(fù)雜的過程,底層從鋪設(shè)網(wǎng)線,網(wǎng)線接口,交換機(jī),路由器,在到規(guī)定各種協(xié)議。
再到應(yīng)用層QQ,微信等軟件。
如果沒有一套標(biāo)準(zhǔn),每次使用都要自己去實(shí)現(xiàn),可能每個(gè)程序員都不是掉頭發(fā)那么簡(jiǎn)單了!
有了Socker之后,Socker會(huì)在應(yīng)用層之前,將各種繁瑣的的底層操作隱藏,我們可能只需要Socker.TCP就實(shí)現(xiàn)了TCP協(xié)議的通訊。
Go語言TCP
TCP屬于穩(wěn)定的,可靠的長連接,
既然要涉及通訊,必然有兩個(gè)終端,最起碼一個(gè)是服務(wù)端,一個(gè)是客戶端,就像我們的淘寶,我們每次打開淘寶,都要去鏈接它,當(dāng)然,淘寶可不直接是TCP。
服務(wù)端
在Go中實(shí)現(xiàn)服務(wù)端,并且在服務(wù)端并發(fā)很簡(jiǎn)單,只需要將每個(gè)連接讓一個(gè)協(xié)程處理即可!
代碼
package main import ( "bufio" "fmt" "net" ) func process(conn net.Conn) { defer conn.Close() for { reader := bufio.NewReader(conn) buf := make([]byte, 128) n, err := reader.Read(buf) if err != nil { fmt.Println("數(shù)據(jù)讀取失敗", err) return } recvStr := string(buf[:n]) fmt.Println("客戶端發(fā)送過來的值:", recvStr) } } func main() { lister, err := net.Listen("tcp", "0.0.0.0:8008") if err != nil { fmt.Println("連接失敗", err) } for { fmt.Println("等待建立連接,此時(shí)會(huì)阻塞住") conn, err := lister.Accept() //等待建立連接 fmt.Println("連接建立成功,繼續(xù)") if err != nil { fmt.Println("建立連接失敗", err) //繼續(xù)監(jiān)聽下次鏈接 continue } go process(conn) } }
客戶端
客戶端就很簡(jiǎn)單了,相對(duì)來說是不需要并發(fā)的,只需要連接就行。
代碼
package main import ( "bufio" "fmt" "net" "os" ) //客戶端 func main() { conn, err := net.Dial("tcp", "192.168.10.148:8008") if err != nil { fmt.Println("連接服務(wù)器失敗",err) } defer conn.Close() inputReader:=bufio.NewReader(os.Stdin) for{ fmt.Println(":") input,_:=inputReader.ReadString('\n') _, err = conn.Write([]byte(input)) if err != nil { fmt.Println("發(fā)送成功") } } }
執(zhí)行結(jié)果
就這樣,我們實(shí)現(xiàn)了服務(wù)端并發(fā)的處理所有客戶端的請(qǐng)求。
粘包
我們先看一下什么是粘包。
服務(wù)端
package main import ( "bufio" "fmt" "io" "net" ) func process(conn net.Conn) { defer conn.Close() reader := bufio.NewReader(conn) buf := make([]byte, 1024) for { n, err := reader.Read(buf) //讀完了 if err == io.EOF { fmt.Println("讀完了") break } //讀錯(cuò)了 if err != nil { fmt.Println("數(shù)據(jù)讀取失敗", err) return } recvStr := string(buf[:n]) fmt.Println("客戶端發(fā)送過來的值:", recvStr) } } func main() { lister, err := net.Listen("tcp", "0.0.0.0:8008") if err != nil { fmt.Println("連接失敗", err) return } defer lister.Close() for { fmt.Println("等待建立連接,此時(shí)會(huì)阻塞住") conn, err := lister.Accept() //等待建立連接 fmt.Println("連接建立成功,繼續(xù)") if err != nil { fmt.Println("建立連接失敗", err) //繼續(xù)監(jiān)聽下次鏈接 continue } go process(conn) } }
客戶端
package main import ( "fmt" "net" ) //客戶端 func main() { conn, err := net.Dial("tcp", "192.168.10.148:8008") if err != nil { fmt.Println("連接服務(wù)器失敗", err) } defer conn.Close() for i := 0; i < 10; i++ { sendStr := "hello world ads asdf asd fads fadsf ads ads asd asd ads " conn.Write([]byte(sendStr)) time.Sleep(time.Second) } }
注意:18行代碼睡眠了1s
執(zhí)行結(jié)果
如果我注釋了第18行代碼
執(zhí)行結(jié)果
直接都淦到一行了,what?這是啥情況,不應(yīng)該跟原來一樣嗎???
每發(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)過各種復(fù)雜的操作,發(fā)送到對(duì)方機(jī)器
但是操作系統(tǒng)有一個(gè)發(fā)送數(shù)據(jù)緩沖區(qū),默認(rèn)情況如果緩沖區(qū)是有大小的,如果緩沖區(qū)沒滿,是不會(huì)發(fā)送數(shù)據(jù)的,所以上述客戶端在發(fā)送數(shù)據(jù)時(shí),系統(tǒng)的緩沖區(qū)都沒滿,一直壓在了操作系統(tǒng)的緩沖區(qū)中,最后發(fā)現(xiàn)沒數(shù)據(jù)了,才一次都發(fā)送到服務(wù)端
但是為什么sleep(1)又管用了呢?這是因?yàn)榫彌_區(qū)不止一個(gè)程序在用,1s的時(shí)間足夠其他程序?qū)⒕彌_區(qū)打滿,然后各自發(fā)各自的數(shù)據(jù),這也是為什么第一次操作沒問題,第二次有問題,因?yàn)榈诙稳慷际俏覀兛蛻舳舜驖M的
解決粘包
工具函數(shù)
我們將解包封包的函數(shù)封裝一下
socker_sitck/stick.go
package socker_stick import ( "bufio" "bytes" "encoding/binary" "fmt" ) //Encode 將消息編碼 func Encode(message string) ([]byte, error) { length := int32(len(message)) var pkg = new(bytes.Buffer) //寫入消息頭 err := binary.Write(pkg, binary.LittleEndian, length) if err != nil { fmt.Println("寫入消息頭失敗", err) return nil, err } //寫入消息實(shí)體 err = binary.Write(pkg, binary.LittleEndian, []byte(message)) if err != nil { fmt.Println("寫入消息實(shí)體失敗", err) return nil, err } return pkg.Bytes(), nil } //Decode解碼消息 func Decode(reader *bufio.Reader) (string, error) { //讀取信息長度 lengthByte, _ := reader.Peek(4) lengthBuff := bytes.NewBuffer(lengthByte) var length int32 err := binary.Read(lengthBuff, binary.LittleEndian, &length) if err != nil { return "", err } //BuffRead 返回緩沖區(qū)現(xiàn)有的可讀的字節(jié)數(shù) if int32(reader.Buffered()) < length+4 { return "", err } pack := make([]byte, int(4+length)) _, err = reader.Read(pack) if err != nil { return "", err } return string(pack[4:]), nil }
服務(wù)端
package main import ( "a3_course/socker_stick" "bufio" "fmt" "io" "net" ) func process(conn net.Conn) { defer conn.Close() reader := bufio.NewReader(conn) for { msg, err := socker_stick.Decode(reader) //讀完了 if err == io.EOF { fmt.Println("讀完了") break } //讀錯(cuò)了 if err != nil { fmt.Println("數(shù)據(jù)讀取失敗", err) return } fmt.Println("客戶端發(fā)送過來的值:", msg) } } func main() { lister, err := net.Listen("tcp", "0.0.0.0:8008") if err != nil { fmt.Println("連接失敗", err) return } defer lister.Close() for { fmt.Println("等待建立連接,此時(shí)會(huì)阻塞住") conn, err := lister.Accept() //等待建立連接 fmt.Println("連接建立成功,繼續(xù)") if err != nil { fmt.Println("建立連接失敗", err) //繼續(xù)監(jiān)聽下次鏈接 continue } go process(conn) } }
客戶端
package main import ( "a3_course/socker_stick" "fmt" "net" ) //客戶端 func main() { conn, err := net.Dial("tcp", "192.168.10.148:8008") if err != nil { fmt.Println("連接服務(wù)器失敗", err) } defer conn.Close() for i := 0; i < 10; i++ { sendStr := "hello world ads asdf asd fads fadsf ads ads asd asd ads " data, err := socker_stick.Encode(sendStr) if err != nil { fmt.Println("編碼失敗",err) return } conn.Write(data) //time.Sleep(time.Second) } }
執(zhí)行結(jié)果
這次真的不管執(zhí)行幾次,都是這樣的結(jié)果
對(duì)了,只有TCP才有粘包
Go語言UDP
UDP是一個(gè)無連接協(xié)議,客戶端不會(huì)在乎服務(wù)端有沒有問題,客戶端只管發(fā),通常用于實(shí)時(shí)性比較高的領(lǐng)域
例如直播行業(yè)
服務(wù)端
package main import ( "fmt" "net" ) func main() { listen, err := net.ListenUDP("udp", &net.UDPAddr{ IP: net.IPv4(0, 0, 0, 0), Port: 8009, }) if err != nil { panic(fmt.Sprintf("udp啟動(dòng)失敗,err:%v", err)) } defer listen.Close() for{ var data = make([]byte,1024) n, addr, err := listen.ReadFromUDP(data) if err != nil { panic(fmt.Sprintf("讀取數(shù)據(jù)失敗,err:%v", err)) } fmt.Println(string(data[:n]),addr,n) } }
客戶端
package main import ( "fmt" "net" ) func main() { socker, err := net.DialUDP("udp", nil, &net.UDPAddr{ IP: net.IPv4(0, 0, 0, 0), Port: 8009, }) if err != nil { panic(fmt.Sprintf("連接服務(wù)器失敗,err:%v", err)) } defer socker.Close() sendStr:="你好呀" _, err = socker.Write([]byte(sendStr)) if err != nil { panic(fmt.Sprintf("數(shù)據(jù)發(fā)送失敗,err:%v", err)) } }
執(zhí)行結(jié)果
到此,相信大家對(duì)“如何理解Go語言基礎(chǔ)之網(wǎng)絡(luò)編程”有了更深的了解,不妨來實(shí)際操作一番吧!這里是創(chuàng)新互聯(lián)網(wǎng)站,更多相關(guān)內(nèi)容可以進(jìn)入相關(guān)頻道進(jìn)行查詢,關(guān)注我們,繼續(xù)學(xué)習(xí)!
新聞名稱:如何理解Go語言基礎(chǔ)之網(wǎng)絡(luò)編程
標(biāo)題來源:http://muchs.cn/article10/gedogo.html
成都網(wǎng)站建設(shè)公司_創(chuàng)新互聯(lián),為您提供移動(dòng)網(wǎng)站建設(shè)、網(wǎng)頁設(shè)計(jì)公司、營銷型網(wǎng)站建設(shè)、、做網(wǎng)站、品牌網(wǎng)站建設(shè)
聲明:本網(wǎng)站發(fā)布的內(nèi)容(圖片、視頻和文字)以用戶投稿、用戶轉(zhuǎn)載內(nèi)容為主,如果涉及侵權(quán)請(qǐng)盡快告知,我們將會(huì)在第一時(shí)間刪除。文章觀點(diǎn)不代表本網(wǎng)站立場(chǎng),如需處理請(qǐng)聯(lián)系客服。電話:028-86922220;郵箱:631063699@qq.com。內(nèi)容未經(jīng)允許不得轉(zhuǎn)載,或轉(zhuǎn)載時(shí)需注明來源: 創(chuàng)新互聯(lián)