快捷導(dǎo)航

golang中net的tcp服務(wù)使用

更新時間：2022年04月14日 16:28:05 作者：zhijie

這篇文章主要介紹了golang中net的tcp服務(wù)使用，文章通過服務(wù)端監(jiān)聽端口展開主題的詳細(xì)內(nèi)容，具有一定的參考價值，需要的小伙伴可以參考一下

服務(wù)端監(jiān)聽端口 listen()

方法：net.listen({監(jiān)聽類型},{監(jiān)聽的ip和端口})(conn, err){}

返回值：conn是監(jiān)聽的對象，有獲取消息關(guān)閉監(jiān)聽等方法err錯誤信息，如果沒有錯誤信息值為nil

import ("net"
"fmt"
)
conn,err := net.Lisien("tcp","127.0.0.1:8082")
if err != nil{
 ?fmt.Println("鏈接失敗，錯誤信息為："+err)
}

接受客戶端的鏈接conn.Accept()

方法：conn.Accept() (newConn,err){} 返回值： newConn客戶端的鏈接對象，類型為net.Conn.存放了客戶端的鏈接信息，和與客戶端交互的方法.err存放錯誤，如果沒有錯誤信息值為nil 注意點： Accept()方法會阻塞，直到有鏈接過來

//  ...上面的代碼...
// 因為客戶端的鏈接不止一個，需要一直監(jiān)聽，所以加個死循環(huán)
for{
    newConn,err := conn.Accept()
    if err != nil{
        fmt.Println(err)
    }
 ? ?go handler(newConn)
}
?
// 客戶端連接后處理邏輯
func handler(newConn net.Conn){
 ? ?// TODO
}

接收客戶端發(fā)過來的數(shù)據(jù)newConn.Read()

方法：newConn.Read(msg)(num,err){}

返回值： num數(shù)據(jù)內(nèi)容的長度，單位字節(jié)err錯誤信息，如果沒有錯誤信息值為nil

注意點：參數(shù)msg是一個byte類型的切片，用來保存客戶端發(fā)送的數(shù)據(jù)。Read方法同樣會阻塞??！

// ...上上邊代碼補充...
// 客戶端連接后處理邏輯
func handler(newConn net.Conn){
 ? ?for{
 ? ? ? ?// 新建一個位置用于存放客戶端數(shù)據(jù)
 ? ? ? ?msg := make([]byte,1024)
 ? ? ? ?num,err := newConn.Read(msg)
 ? ? ? ?if err != nil{
 ? ? ? ? ? ?// 打印錯誤信息
 ? ? ?  }
 ? ? ? ?fmt.Println("客戶端消息："+msg)
 ?  }
 ? ?
}

獲取客戶端的IP地址newConn.RemoteAddr().String()

// 獲取ip地址，轉(zhuǎn)為之字符串
newConn.RemoteAddr().String()

向客戶端發(fā)送數(shù)據(jù)newConn.Write()

方法：newConn.Write(msg){}

參數(shù)：msg類型為[]byte。

注意點：需要把待發(fā)送的字符串轉(zhuǎn)為byte切片類型

newConn.Write([]bye("你好世界，helloworld1"))

關(guān)閉客戶端連接newConn.Close()

方法： newConn.Close(){}

在客戶端連接的返回的對象上調(diào)用Close()方法即可

newConn.Close()

客戶端連接tpc服務(wù)端

連接服務(wù)端net.Dial()

方法： net.Dial({連接類型},{地址})(conn,err){}

放回值： conn連接成功后的連接對象，err連接出錯時的錯誤信息，如果沒有錯誤信息，返回nil

// 建立tcp連接
package main
import (
 ? ?"net"
 ? ?"fmt"
)
Ip,Port := "127.0.0.1",8081
conn,err := net.Dial("tcp",fmt.Sprintf("%s:%d",Ip,Port))
if err != nil{
 ? ?fmt.Println("net.Dial 錯誤：",err)
 ? ?return nil
}
if(conn == nil){
 ? ?fmt.Println(">>>>>>>>連接錯誤")
 ? ?return
}
fmt.Println(">>>>>>>>連接成功")

運行：