Scoket--并发操作--Go语言学习笔记

Posted 2021-05-21 旧时星空

Scoket–并发操作–Go语言学习笔记

服务器端

func main(){
	//1.创建服务器地址
addr,_:=net.ResolveTCPAddr("tcp4","localhost:8899")
	//2.创建监听器
    lis,_:=net.ListenTCP("tcp4",addr)
    fmt.Println("服务器端已启动")
	for {
		//3.通过监听器获取客户端传递过来的数据-阻塞式
		conn, _ := lis.Accept()
		//并发，开辟协程
		go func() {
			//4.转换数据
			b := make([]byte, 1024)
			count, _ := conn.Read(b)
			fmt.Println("获取到的数据为：", string(b[:count]))
			//发送消息
			conn.Write(append([]byte("sever"), b[:count]...))
			//5.关闭连接
			conn.Close()
		}()
	}
}}}}

服务器端结果：

服务器端已启动
获取到的数据为： 客户端发送的数据0
获取到的数据为： 客户端发送的数据1
获取到的数据为： 客户端发送的数据2
获取到的数据为： 客户端发送的数据3
获取到的数据为： 客户端发送的数据4

客户端

func main() {
	//1.创建服务器端的地址
	addr, _ := net.ResolveTCPAddr("tcp4", "localhost:8899")
	for i := 0; i < 5; i++ {
		//2.创建连接
		conn, _ := net.DialTCP("tcp", nil, addr)
		//3.发送数据
		conn.Write([]byte("客户端发送的数据"+strconv.Itoa(i)))
		//读取数据
		b := make([]byte, 1024)
		count, _ := conn.Read(b)
		fmt.Println("服务器发送的消息为：", string(b[:count]))
		//4.关闭连接
		conn.Close()
	}
}

客户端结果：

服务器发送的消息为： sever客户端发送的数据0
服务器发送的消息为： sever客户端发送的数据1
服务器发送的消息为： sever客户端发送的数据2
服务器发送的消息为： sever客户端发送的数据3
服务器发送的消息为： sever客户端发送的数据4