中文字幕av专区_日韩电影在线播放_精品国产精品久久一区免费式_av在线免费观看网站

溫馨提示×

溫馨提示×

您好,登錄后才能下訂單哦!

密碼登錄×
登錄注冊×
其他方式登錄
點擊 登錄注冊 即表示同意《億速云用戶服務條款》

Golang端口復用測試的實現方法

發布時間:2021-03-26 13:51:07 來源:億速云 閱讀:446 作者:小新 欄目:開發技術

小編給大家分享一下Golang端口復用測試的實現方法,相信大部分人都還不怎么了解,因此分享這篇文章給大家參考一下,希望大家閱讀完這篇文章后大有收獲,下面讓我們一起去了解一下吧!

先給出結論:

同一個進程,使用一個端口,然后連接關閉,大約需要30s后才可再次使用這個端口。

測試

首先使用端口9001連接服務端,發送數據,然后關閉連接,接著再次使用端口9001連接服務端,如果連接失敗,間隔15s后,再次嘗試,最多嘗試3次,。

client

package main
import (

 "bufio"
 "fmt"
 "net"
 "os"
 "time"
)

func DialCustom(network, address string, timeout time.Duration, localIP []byte, localPort int)(net.Conn,error) {
 netAddr := &net.TCPAddr{Port:localPort}

 if len(localIP) != 0 {
 netAddr.IP = localIP
 }

 fmt.Println("netAddr:", netAddr)

 d := net.Dialer{Timeout: timeout, LocalAddr: netAddr}
 return d.Dial(network, address)
}


func getOneConn() {

 serverAddr := "127.0.0.1:8080"

 // 172.28.172.180
 //localIP := []byte{0xAC, 0x1C, 0xAC, 0xB4} // IP
 localIP := []byte{} // any IP
 localPort := 9001

 var conn net.Conn
 var err error

 for i:=0;i<3;i++{

 conn, err = DialCustom("tcp", serverAddr, time.Second*10, localIP,localPort)
 if err != nil {
 fmt.Println("dial failed:", err)
 if i == 2 {
 os.Exit(1)
 }
 time.Sleep(15*time.Second)
 } else {
 break
 }
 }

 defer conn.Close()


 buffer := make([]byte, 512)
 reader := bufio.NewReader(conn)

 n, err2 := reader.Read(buffer)
 if err2 != nil {
 fmt.Println("Read failed:", err2)
 return
 }

 fmt.Println("count:", n, "msg:", string(buffer))

}


func main() {
 getOneConn()
 fmt.Println("=========================")
 getOneConn()
 fmt.Println("=========================")
 select{}

}

server

package main

import (
 "fmt"
 "net"
 "log"
)

func main() {

 addr := "0.0.0.0:8080"

 tcpAddr, err := net.ResolveTCPAddr("tcp",addr)

 if err != nil {
 log.Fatalf("net.ResovleTCPAddr fail:%s", addr)
 }

 listener, err := net.ListenTCP("tcp", tcpAddr)
 if err != nil {
 log.Fatalf("listen %s fail: %s", addr, err)
 } else {
 
 log.Println("rpc listening", addr)
 }


 for {
 conn, err := listener.Accept()
 if err != nil {
 log.Println("listener.Accept error:", err)
 continue
 }
 
 go handleConnection(conn)
 
 }

}


func handleConnection(conn net.Conn) {

 //defer conn.Close()

 var buffer []byte = []byte("You are welcome. I'm server.")

 n, err := conn.Write(buffer)

 if err != nil {
 
 fmt.Println("Write error:", err)
 }
 fmt.Println("send:", n)

 fmt.Println("connetion end")
}

output

client輸出:

$ ./client
netAddr: :9001
count: 28 msg: You are welcome. I'm server.
=========================
netAddr: :9001
dial failed: dial tcp :9001->127.0.0.1:8080: bind: address already in use


netAddr: :9001
dial failed: dial tcp :9001->127.0.0.1:8080: bind: address already in use

netAddr: :9001
count: 28 msg: You are welcome. I'm server.
=========================

經過3次重試,30s后,才可以重新使用同一個端口9001進行連接。也就是同一個進程的情況狂下,一個連接關閉后,端口大約30s后才可以被使用。

以上是“Golang端口復用測試的實現方法”這篇文章的所有內容,感謝各位的閱讀!相信大家都有了一定的了解,希望分享的內容對大家有所幫助,如果還想學習更多知識,歡迎關注億速云行業資訊頻道!

向AI問一下細節

免責聲明:本站發布的內容(圖片、視頻和文字)以原創、轉載和分享為主,文章觀點不代表本網站立場,如果涉及侵權請聯系站長郵箱:is@yisu.com進行舉報,并提供相關證據,一經查實,將立刻刪除涉嫌侵權內容。

AI

积石山| 蓬溪县| 贡觉县| 商丘市| 同江市| 水城县| 共和县| 荃湾区| 新化县| 含山县| 嘉峪关市| 房产| 杭州市| 琼海市| 潍坊市| 微山县| 龙游县| 昭觉县| 武山县| 凤山市| 鄂托克旗| 重庆市| 云和县| 孟连| 通榆县| 洪泽县| 邛崃市| 江陵县| 黑水县| 治多县| 紫阳县| 旬邑县| 桑植县| 盘锦市| 寿光市| 离岛区| 安化县| 济南市| 大英县| 喀喇| 博湖县|