UDP通信功能

 

UDP通信功能

1. UDP交互沟通案例

效果

clent有点小问题,输出终止,不退出。

 clent

server 

 

服务器

 

package main

import (
    "fmt"
    "os"
    "net"
)


func ServerHandleError(err error,when string) {
    if err != nil {
        fmt.Println(err, "net.Listen")
        os.Exit(1)

    }
}


func main(){

    //解析得到UDP地址
    udpAddr, e := net.ResolveUDPAddr("udp", "127.0.0.1:8080")
    ServerHandleError(e,"net.ResolveUDPAddr")

    //在UDP地址上建议UDP监听,得到链接
    udpConn, err := net.ListenUDP("udp", udpAddr)
    ServerHandleError(err,"net.ListenUDP")

    //建议缓冲区
    buffer := make([]byte, 1024)

    //从广口连接中源源不断地读取, 来自任何客户端的数据包
    for {

        //读取一个数据包,丢入到buffer中,同时获得该数据包的客户段信息
        n, remoteAddr, _ := udpConn.ReadFromUDP(buffer)

        //打印数据包消息
        clientMsg := string(buffer[:n])
        fmt.Printf("读到来自%v的内容: %s
",remoteAddr,clientMsg)

        //回复数据包的客户端
        if clientMsg != "ino" {

             udpConn.WriteToUDP([]byte("朕已阅:"+clientMsg), remoteAddr)

        }else {

            udpConn.WriteToUDP([]byte("去死吧:"+clientMsg), remoteAddr)
        }
    }

}

客户端

 

package main

import (
    "fmt"
    "os"
    "net"
    "bufio"
)




func main()  {

    //拨号申请连接
    conn, e := net.Dial("udp", "127.0.0.1:8080")
    ClentHandleError(e,"net.Dial")

    //创建命令行读取器
    reader := bufio.NewReader(os.Stdin)
    //创建缓冲区
    buffer := make([]byte, 1024)


    for {

        linBytes, _, _ := reader.ReadLine()
        conn.Write(linBytes)

        //从连接中读入信息
        n,_ := conn.Read(buffer)
        serverMsg := string(buffer[:n])
        fmt.Println("服务器：",serverMsg)

        if serverMsg == "ino" {

            //发出死前的哀叹
            conn.Write([]byte("啊啊啊啊...."))
            break
        }

    }

    fmt.Println("GAME OVER!")
}


func ClentHandleError(err error,when string) {
    if err != nil {
        fmt.Println(err, "net.Listen")
        os.Exit(1)

    }
}

2. 自动收发,一次性完事。

效果

server

clent

服务器端

package main

import (
    "fmt"
    "os"
    "net"
)


func ServerHandleError(err error,when string) {
    if err != nil {
        fmt.Println(err, "net.Listen")
        os.Exit(1)

    }
}


func main(){

    //解析得到UDP地址
    udpAddr, err := net.ResolveUDPAddr("udp", "127.0.0.1:8080")
    ServerHandleError(err,"net.ResolveUDPAddr")

    //在UDP地址上建议UDP监听,得到链接
    udpConn, err := net.ListenUDP("udp", udpAddr)
    ServerHandleError(err,"net.ListenUDP")
    defer udpConn.Close()

    //建议缓冲区
    buffer := make([]byte, 1024)

    //从链接中读入内容,丢入缓冲区
    n, remoteAddr, err := udpConn.ReadFromUDP(buffer)
    ServerHandleError(err,"udpConn.ReadFromUDP(buffer)")
    fmt.Printf("读到来自%v的内容: %s
",remoteAddr,string(buffer[:n]))

    //向客户端写出内容
    udpConn.WriteToUDP([]byte("朕已阅!"),remoteAddr)


}

客户端

package main

import (
    "fmt"
    "os"
    "net"
)



func ClentHandleError(err error,when string) {
    if err != nil {
        fmt.Println(err, "net.Listen")
        os.Exit(1)

    }
}





func main()  {

    //拨号申请连接
    conn, e := net.Dial("udp", "127.0.0.1:8080")
    ClentHandleError(e,"net.Dial")
    defer conn.Close()

    // 向连接中写出信息
    n, err := conn.Write([]byte("只有main包下的main函数才能运行啊啊啊!"))
    ClentHandleError(err,"conn.Write")
    fmt.Printf("成功写出%d个字节
",n)

    //创建缓冲区
    buffer := make([]byte, 1024)

    //从连接中读入信息
    n,err = conn.Read(buffer)
    ClentHandleError(err,"conn.Read(buffer)")
    fmt.Println(string(buffer[:n]))

    fmt.Println("GAME OVER!")
}