go网络编程

发表于 | 分类于
| 字数统计 531 | 阅读时长 2

连接过程

监听端口

1
2
3
listener, err := net.Listen("tcp", ":8000")
defer listener.Close()

客户端发送请求链接

1
2
3
conn, err := net.Dial("tcp", ":8000")
defer conn.Close()

接受客户端请求链接

1
2
conn, err := listener.Accept()
defer conn.Close()

接收数据

1
2
buffer := make([]byte, 2048)
n, err := conn.Read(buffer)

发送数据

1
n, err = conn.Write([]byte(。。。))

server处理单client

服务器

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
func main() {
	listener, err := net.Listen("tcp", ":8000")
	if err != nil {
		fmt.Println(err)
		return
	}
	defer listener.Close()
	buffer := make([]byte, 2048)
	conn, err := listener.Accept()
	if err != nil {
		fmt.Println(err)
	}
	fmt.Println(conn.RemoteAddr())
	n, err := conn.Read(buffer)
	if err != nil {
		fmt.Println(err)
	}
	fmt.Println(string(buffer[:n]))
	defer conn.Close()
}

client

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
func main() {
	conn, err := net.Dial("tcp", ":8000")
	defer conn.Close()
	if err != nil {
		fmt.Println(err)
		return
	}
	buf := make([]byte, 2048)
	content := "hello world"
	n, err := conn.Write([]byte(content))
	if err != nil {
		fmt.Println(err)
	}
	fmt.Println(n)
}

server并发处理多client，并保持链接状态

server

这是使用了go开启一个线程， 当有新的client链接时，都会开启一个go程。
如果把go去掉，只能处理单个client，当多个client请求链接时，只有第一个和server保持链接。其余的都在等待状态。有个教学视频说会被替换，经过测试，当不使用go时，线程会被阻塞到读取的位置，只是其余的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
func main() {
	listener, err := net.Listen("tcp", ":8000")
	if err != nil {
		fmt.Println(err)
		return
	}
	defer listener.Close()
	for {
		conn, err := listener.Accept()
		if err!=nil{
			fmt.Println(err)
		}
		go handle(conn)
	}
}
func handle(conn net.Conn) {
	fmt.Println(conn.RemoteAddr())
	defer conn.Close()
	buffer := make([]byte, 2048)
	for{
		n, err := conn.Read(buffer)
		if err != nil {
			fmt.Println(err)
			return
		}
		content := strings.Trim(string(buffer[:n]), " \r\n")
		fmt.Println(n, content)
		if content == "exit"{
			return
		}
		fmt.Println(time.Now())
		n, err = conn.Write([]byte(time.Now().String()))
		if err != nil {
			fmt.Println(err)
		}
	}
}

client

输入exit退出

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
func main() {
	conn, err := net.Dial("tcp", ":8000")
	defer conn.Close()
	if err != nil {
		fmt.Println(err)
		return
	}
	go func() {
		for {
			str := make([]byte, 2048)
			n, err := os.Stdin.Read(str)
			if err != nil{
				fmt.Println(err)
				return
			}
			n, err = conn.Write(str[:n])
			if err != nil {
				fmt.Println(err)
				return
			}
		}
	}()
	buf := make([]byte, 2048)
	for{
		n, err := conn.Read(buf)
		if err != nil{
			fmt.Println(err)
			return
		}
		fmt.Println(string(buf[:n]))
	}
}