您好,登錄后才能下訂單哦!
這篇“go語言中的udp協(xié)議及TCP通訊怎么配置”文章的知識點大部分人都不太理解,所以小編給大家總結(jié)了以下內(nèi)容,內(nèi)容詳細,步驟清晰,具有一定的借鑒價值,希望大家閱讀完這篇文章能有所收獲,下面我們一起來看看這篇“go語言中的udp協(xié)議及TCP通訊怎么配置”文章吧。
package main import ( "fmt" "net" ) func main() { // 創(chuàng)建監(jiān)聽 socket, err := net.ListenUDP("udp4", &net.UDPAddr{ IP: net.IPv4(0, 0, 0, 0), Port: 8080, }) if err != nil { fmt.Println("監(jiān)聽失敗!", err) return } defer socket.Close() for { // 讀取客戶端傳來的數(shù)據(jù) data := make([]byte, 4096) read, remoteAddr, err := socket.ReadFromUDP(data) if err != nil { fmt.Println("讀取數(shù)據(jù)失敗!", err) continue } fmt.Println(read, remoteAddr) fmt.Printf("%s\n\n", data) //發(fā)送數(shù)據(jù),告訴客戶端已收到 senddata := []byte("hello client!") _, err = socket.WriteToUDP(senddata, remoteAddr) if err != nil { return fmt.Println("發(fā)送數(shù)據(jù)失敗!", err) } } }
package main import ( "fmt" "net" ) func main() { // 創(chuàng)建連接 socket, err := net.DialUDP("udp4", nil, &net.UDPAddr{ IP: net.IPv4(0, 0, 0, 0), Port: 8080, }) if err != nil { fmt.Println("連接失敗!", err) return } defer socket.Close() // 發(fā)送給服務端數(shù)據(jù) senddata := []byte("hello server!") _, err = socket.Write(senddata) if err != nil { fmt.Println("發(fā)送數(shù)據(jù)失敗!", err) return } // 接收客戶端的數(shù)據(jù) data := make([]byte, 4096) read, remoteAddr, err := socket.ReadFromUDP(data) if err != nil { fmt.Println("讀取數(shù)據(jù)失敗!", err) return } fmt.Println(read, remoteAddr) fmt.Printf("%s\n", data) }
package main import ( "fmt" "net" ) func main() { //監(jiān)聽 listener, err := net.Listen("tcp", "127.0.0.1:8000") if err != nil { fmt.Println("err = ", err) return } defer listener.Close() //阻塞等待用戶鏈接 conn, err := listener.Accept() if err != nil { fmt.Println("err = ", err) return } //接收用戶的請求 buf := make([]byte, 1024) //1024大小的緩沖區(qū) n, err1 := conn.Read(buf) if err1 != nil { fmt.Println("err1 = ", err1) return } fmt.Println("buf = ", string(buf[:n])) defer conn.Close() //關閉當前用戶鏈接 }
package main import ( "fmt" "net" ) func main() { //主動連接服務器 conn, err := net.Dial("tcp", "127.0.0.1:8000") if err != nil { fmt.Println("err = ", err) return } defer conn.Close() //發(fā)送數(shù)據(jù) conn.Write([]byte("are u ok?")) }
package main import ( "fmt" "net" "strings" ) //處理用戶請求 func HandleConn(conn net.Conn) { //函數(shù)調(diào)用完畢,自動關閉conn defer conn.Close() //獲取客戶端的網(wǎng)絡地址信息 addr := conn.RemoteAddr().String() fmt.Println(addr, " conncet sucessful") buf := make([]byte, 2048) for { //讀取用戶數(shù)據(jù) n, err := conn.Read(buf) if err != nil { fmt.Println("err = ", err) return } fmt.Printf("[%s]: %s\n", addr, string(buf[:n])) fmt.Println("len = ", len(string(buf[:n]))) //if "exit" == string(buf[:n-1]) { //nc測試 if "exit" == string(buf[:n-2]) { //自己寫的客戶端測試, 發(fā)送時,多了2個字符, "\r\n" fmt.Println(addr, " exit") return } //把數(shù)據(jù)轉(zhuǎn)換為大寫,再給用戶發(fā)送 conn.Write([]byte(strings.ToUpper(string(buf[:n])))) } } func main() { //監(jiān)聽 listener, err := net.Listen("tcp", "127.0.0.1:8000") if err != nil { fmt.Println("err = ", err) return } defer listener.Close() //接收多個用戶 for { conn, err := listener.Accept() if err != nil { fmt.Println("err = ", err) return } //處理用戶請求, 新建一個協(xié)程 go HandleConn(conn) } }
package main import ( "fmt" "net" "os" ) func main() { //主動連接服務器 conn, err := net.Dial("tcp", "127.0.0.1:8000") if err != nil { fmt.Println("net.Dial err = ", err) return } //main調(diào)用完畢,關閉連接 defer conn.Close() go func() { //從鍵盤輸入內(nèi)容,給服務器發(fā)送內(nèi)容 str := make([]byte, 1024) for { n, err := os.Stdin.Read(str) //從鍵盤讀取內(nèi)容, 放在str if err != nil { fmt.Println("os.Stdin. err = ", err) return } //把輸入的內(nèi)容給服務器發(fā)送 conn.Write(str[:n]) } }() //接收服務器回復的數(shù)據(jù) //切片緩沖 buf := make([]byte, 1024) for { n, err := conn.Read(buf) //接收服務器的請求 if err != nil { fmt.Println("conn.Read err = ", err) return } fmt.Println(string(buf[:n])) //打印接收到的內(nèi)容, 轉(zhuǎn)換為字符串再打印 } }
以上就是關于“go語言中的udp協(xié)議及TCP通訊怎么配置”這篇文章的內(nèi)容,相信大家都有了一定的了解,希望小編分享的內(nèi)容對大家有幫助,若想了解更多相關的知識內(nèi)容,請關注億速云行業(yè)資訊頻道。
免責聲明:本站發(fā)布的內(nèi)容(圖片、視頻和文字)以原創(chuàng)、轉(zhuǎn)載和分享為主,文章觀點不代表本網(wǎng)站立場,如果涉及侵權請聯(lián)系站長郵箱:is@yisu.com進行舉報,并提供相關證據(jù),一經(jīng)查實,將立刻刪除涉嫌侵權內(nèi)容。