Go基础知识-TCP/UDP
作者:互联网
1.网络编程:物理层->数据链路层->网络层->传输层->应用层
2.Socket是应用层与TCP/IP协议族通信的中间软件抽象层
3.TCP编程:net包里面,并且粘包的问题需要注意
服务端处理流程:
1.监听端口
2.接收客户端请求建立链接
3.创建goroutine处理链接
客户端处理流程:
1.建立与服务端连接 2. 收发数据 3.关闭连接
案例:
服务端:
func main(){
//1.监听端口:Listen
listen,err := net.Listen("tcp","127.0.0.1:4567")
if err != nil{
fmt.Println("listen error:",err)
return
}
defer listen.Close()
fmt.Println("listen success")
//接收客户端请求建立连接 Accept
for{
//建立连接
conn,err := listen.Accept()
if err != nil{
fmt.Println("Accept error:",err)
continue
}
fmt.Println("收到客户端连接进来=",conn.RemoteAddr().String())
//接收数据
go func(_conn net.Conn) {
defer _conn.Close()
for{
reader := bufio.NewReader(_conn)
var buf [128]byte
n,err := reader.Read(buf[:])
if err != nil{
fmt.Println("read err:",err)
break
}
data := string(buf[:n])
fmt.Println("receive data=",data)
//给客户端发一条
_conn.Write([]byte("已经收到这条消息"))
}
}(conn)
}
}
//使用tcp工具发送
//结果如下:
listen success
收到客户端连接进来= 127.0.0.1:55559
receive data= 你哈啊
read err: read tcp 127.0.0.1:4567->127.0.0.1:55559: wsarecv: An existing connection was forcibly closed by the remote host.
客户端:
func main(){
//1.建立与服务端连接 2. 收发数据 3.关闭连接
_conn,err := net.Dial("tcp","127.0.0.1:4567")
if err != nil{
fmt.Println("conn to server error:",err)
return
}
defer _conn.Close()
//2. 收发数据 Accept
for i:=0;i<10;i++{
//发送数据
_,err = _conn.Write([]byte("你好server"))
if err != nil{
fmt.Println("send msg err=",err)
return
}
//接收服务端数据
var buf [128]byte
n,err := _conn.Read(buf[:])
if err != nil{
fmt.Println("read server content error",err)
return
}
fmt.Println("server msg=",string(buf[:n]))
}
}
4.UDP编程:换个函数
标签:UDP,err,fmt,TCP,Println,Go,listen,conn,客户端 来源: https://www.cnblogs.com/yyouki/p/15966296.html