服务器之家

服务器之家 > 正文

Golang 端口复用测试的实现

时间:2021-04-22 01:02     来源/作者:翔云123456

先给出结论:

同一个进程,使用一个端口,然后连接关闭,大约需要30s后才可再次使用这个端口。

测试

首先使用端口9001连接服务端,发送数据,然后关闭连接,接着再次使用端口9001连接服务端,如果连接失败,间隔15s后,再次尝试,最多尝试3次,。

client

?
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
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

?
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
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 端口复用测试的实现的文章就介绍到这了,更多相关Golang 端口复用内容请搜索服务器之家以前的文章或继续浏览下面的相关文章希望大家以后多多支持服务器之家!

原文链接:https://blog.csdn.net/lanyang123456/article/details/80754010

标签:

相关文章

热门资讯

2020微信伤感网名听哭了 让对方看到心疼的伤感网名大全
2020微信伤感网名听哭了 让对方看到心疼的伤感网名大全 2019-12-26
yue是什么意思 网络流行语yue了是什么梗
yue是什么意思 网络流行语yue了是什么梗 2020-10-11
背刺什么意思 网络词语背刺是什么梗
背刺什么意思 网络词语背刺是什么梗 2020-05-22
苹果12mini价格表官网报价 iPhone12mini全版本价格汇总
苹果12mini价格表官网报价 iPhone12mini全版本价格汇总 2020-11-13
Intellij idea2020永久破解,亲测可用!!!
Intellij idea2020永久破解,亲测可用!!! 2020-07-29
返回顶部