yukixz / cqsocketapi Goto Github PK

// udp_client project main.go
package main

import (
    "fmt"
    "net"
    //"strconv"
    //"encoding/base64"
    "strings"
    "time"
)

func main() {
begin:
    s, e := net.DialUDP("udp4",
        &net.UDPAddr{
            IP:   net.IPv4(127, 0, 0, 1),
            Port: 11236,
        },
        &net.UDPAddr{
            IP:   net.IPv4(127, 0, 0, 1),
            Port: 11235,
        })

    if e != nil {
        fmt.Println(e)
        goto begin
    }

    fmt.Println("success connect to local upd 11253 ")

    fmt.Println("localAddr:", s.LocalAddr().String())
    lPort := strings.Split(s.LocalAddr().String(), ":")[1]
    fmt.Println(lPort)
    // send routine
    go func() {
        for {
            n, e := s.Write([]byte("ClientHello " + lPort))
            if e != nil {
                fmt.Println(e)
            }

            fmt.Println("write ", n, "message to", s.RemoteAddr().String())

            time.Sleep(time.Second * 20)
        }
    }()

    go func() {
        for {
            time.Sleep(time.Second * 5)
            n, e := s.Write([]byte(`PrivateMessage 379667034 dGVzdCCy4srU`))
            //n, e := s.Write([]byte(`PrivateMessage 379667034 dGVzdCDmtYvor5U=`))

            if e != nil {
                fmt.Println(e)
            }

            fmt.Println("write ", n, "message to", s.RemoteAddr().String())

            //time.Sleep(time.Second * 5)
        }
    }()

    // 接收routine
    go func() {
        for {
            fmt.Println("wait for message from server...")
            buf := make([]byte, 8)
            n, _ := s.Read(buf)
            fmt.Println("receive", n, "bytes message\n the message is:", string(buf))
        }
    }()

    //wait routine
    for {
        time.Sleep(time.Second * 3)
    }

}