• Go语言UDP网络程序设计

    UDP 和上一节《TCP网络程序设计》中的 TCP 一样,也工作在网络传输层,但和 TCP 不同的是,它提供不可靠的通信服务。UDP 网络编程也为 C-S 模式,要设计一个服务器,一个或多个客户机。

    另外,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 虽然不能保证通信的可靠性,但通信效率要高得多,在有些场合还是非常有用的。

更多...

加载中...