另外,UDP 是不保证可靠性的通信协议,所以客户机和服务器之间只要建立连接,就可以直接通信,而不用调用 Aceept() 进行连接确认。本节将详细讲解 UDP 网络编程服务器、客户机的设计原理和设计过程。
UDPAddr 地址结构体
在进行 UDP 网络编程时,服务器或客户机的地址使用 UDPAddr 地址结构体表示,UDPAddr 包含两个字段:IP 和 Port,形式如下:
type UDPAddr struct {
IP IP
Port int
}
函数 ResolveUDPAddr() 可以把网络地址转换为 UDPAddr 地址结构,该函数原型定义如下:
func ResolveUDPAddr(net, addr string) (*UDPAddr, error)
在调用函数 ResolveUDPAddr() 时,参数 net 是网络协议名,可以是“udp”、“udp4”或“udp6”。参数 addr 是 IP 地址或域名,如果是 IPv6 地址则必须使用“[]”括起来。另外,端口号以“:”的形式跟随在 IP 地址或域名的后面,端口是可选的。
函数 ResolveUDPAddr() 调用成功后返回一个指向 UDPAddr 结构体的指针,否则返回一个错误类型。
另外,UDPAddr 地址对象还有两个方法:Network() 和 String(),Network() 方法用于返回 UDPAddr 地址对象的网络协议名,比如“udp”;String() 方法可以将 UDPAddr 地址转换成字符串形式。这两个方法原型定义如下:
func (a *UDPAddr) Network() string
func (a *UDPAddr) String() string
UDPConn 对象
在进行 UDP 网络编程时,客户机和服务器之间是通过 UDPConn 对象实现连接的,UDPConn 是 Conn 接口的实现。UDPConn 对象绑定了服务器的网络协议和地址信息。UDPConn 对象定义如下:
type UDPConn struct {
//空结构
}
通过 UDPConn 连接对象在客户机和服务器之间进行通信,UDP 并不能保证通信的可靠性和有序性,这些都要由程序员来处理。为此,TCPConn 对象提供了 ReadFromUDP() 方法和 WriteToUDP() 方法,这两个方法直接使用远端主机地址进行数据发送和接收,即便在链路失效的情况下,通信操作都能正常进行。
ReadFromUDP() 方法和 WriteToUDP() 方法的原型定义如下:
func (c *UDPConn) ReadFromUDP(b []byte) (n int, addr *UDPAddr, err error)
func (c *UDPConn) WriteToUDP(b []byte, addr *UDPAddr) (int, error)
ReadFromUDP() 方法调用成功后返回接收字节数和发送方地址,否则返回一个错误类型;WriteToUDP() 方法调用成功后返回发送字节数,否则返回一个错误类型。
UDP 服务器设计
在 UDP 网络编程中,服务器工作过程如下:
1) UDP 服务器首先注册一个公知端口,然后调用 ListenUDP() 函数在这个端口上创建一个 UDPConn 连接对象,并在该对象上和客户机建立不可靠连接。
2) 如果服务器和某个客户机建立了 UDPConn 连接,就可以使用该对象的 ReadFromUDP() 方法和 WriteToUDP() 方法相互通信了。
3) 不管上一次通信是否完成或正常,UDP 服务器依然会接受下一次连接请求。
函数 ListenUDP() 原型定义如下:
func ListenUDP(net sting, laddr *UDPAddr) (*UDPConn, error)
在调用函数 ListenUDP() 时,参数 net 是网络协议名,可以是“udp”、“udp4”或“udp6”。参数 laddr 是服务器本地地址,可以是任意活动的主机地址,或者是内部测试地址“127.0.0.1”。该函数调用成功,返回一个 UDPConn 对象;调用失败,返回一个错误类型。
【示例 1】UDP Server 端设计,服务器使用本地地址,服务端口号为 5001。服务器设计工作模式采用循环服务器,对每一个连接请求调用线程 handleClient 来处理。
//UDP Server 端设计 package main import( "fmt" "net" "os" ) func main() { service := ":5001" udpAddr, err := net.ResolveUDPAddr("udp", service) checkError(err) conn, err := net.ListenUDP("udp", udpAddr) checkError(err) for { handleClient(conn) } } func handleClient(conn *net.UDPConn) { var buf [512]byte n, addr, err := conn.ReadFromUDP(buf[0:]) if err != nil { return } fmt.Println("Receive from client", addr.String(), string(buf[0:n])) conn.WriteToUDP([]byte("Welcome Client!"), addr) } func checkError(err error) { if err != nil { fmt.Fprintf(os.Stderr, "Fatal error: %s", err.Error()) os.Exit(1) } }
UDP 客户机设计
在 UDP 网络编程中,客户机工作过程如下:
1) UDP 客户机在获取了服务器的服务端口号和服务地址之后,可以调用 DialUDP() 函数向服务器发出连接请求,如果请求成功会返回 UDPConn 对象。
2) 客户机可以直接调用 UDPConn 对象的 ReadFromUDP() 方法或 WriteToUDP() 方法,与服务器进行通信活动。
3) 通信完成后,客户机调用 Close() 方法关闭 UDPConn 连接,断开通信链路。
函数 DialUDP() 原型定义如下:
func DialUDP(net string, laddr, raddr *UDPAddr)(*UDPConn, error)
在调用函数 DialUDP() 时,参数 net 是网络协议名,可以是“udp”、“udp4”或“udp6”。参数 laddr 是本地主机地址,可以设为 nil。参数 raddr 是对方主机地址,必须指定不能省略。函数调用成功后,返回 UDPConn 对象;调用失败,返回一个错误类型。
方法 Close() 的原型定义如下:
func (c *UDPConn) Close() error
该方法调用成功后,关闭 UDPConn 连接;调用失败,返回一个错误类型。
【示例 2】UDP Client 端设计,客户机通过内部测试地址“127.0.0.1”和端口 5001 和服务器建立通信连接。
// UDP Client端设计 package main import( "fmt" "net" "os" ) func main() { if len(os.Args) != 2 { fmt.Fprintf(os.Stderr, "Usage: %s host:port", os.Args[0]) } service := os.Args[1] udpAddr, err := net.ResolveUDPAddr("udp", service) checkError(err) conn, err := net.DialUDP("udp", nil, udpAddr) checkError(err) _, err = conn.Write([]byte("Hello server!")) checkError(err) var buf [512]byte n, addr, err := conn.ReadFromUDP(buf[0:]) checkError(err) fmt.Println("Reply form server", addr.String(), string(buf[0:n])) conn.Close() os.Exit(0) } func checkError(err error) { if err != nil { fmt.Fprintf(os.Stderr, "Fatal error: %s", err.Error()) os.Exit(1) } }
编译并运行服务器端和客户端,测试过程如下:
启动服务器:go run ./main.go
客户机连接:go run ./client.go 127.0.0.1:5001
服务器响应:Receive from client 127.0.0.1:53825 Hello server!
客户机接收:Reply form server 127.0.0.1:5001 Welcome Client!
通过测试结果会发现,采用 TCP 时必须先启动服务器,然后才能正常启动客户机,如果服务器中断,则客户机也会异常退出。而采用 UDP 时,客户机和服务器启动没有先后次序,而且即便是服务器异常退出,客户机也能正常工作。
总之,TCP 可以保证客户机、服务器双方按照可靠有序的方式进行通信,但通信效率低;而 UDP 虽然不能保证通信的可靠性,但通信效率要高得多,在有些场合还是非常有用的。
原创文章,作者:奋斗,如若转载,请注明出处:https://blog.ytso.com/23068.html