UDPServer通过gudp.Server实现。

    使用方式:

    1. import "gitee.com/johng/gf/g/net/gudp"

    方法列表:
    godoc.org/github.com/johng-cn/gf/g/net/gudp#Server

    1. type Server
    2. func GetServer(name ...interface{}) *Server
    3. func NewServer(address string, handler func(*Conn), names ...string) *Server
    4. func (s *Server) Run() error
    5. func (s *Server) SetAddress(address string)
    6. func (s *Server) SetHandler(handler func(*Conn))

    其中GetServer使用单例模式通过给定一个唯一的名称获取/创建一个Server,后续可通过SetAddressSetHandler方法动态修改Server属性;NewServer则直接根据给定参数创建一个Server对象。

    来一个简单的示例:

    1. package main
    2. import (
    3. "fmt"
    4. "gitee.com/johng/gf/g/net/gudp"
    5. )
    6. func main() {
    7. gudp.NewServer("127.0.0.1:8999", func(conn *gudp.Conn) {
    8. defer conn.Close()
    9. for {
    10. if data, _ := conn.Recv(-1); len(data) > 0 {
    11. fmt.Println(string(data))
    12. }
    13. }
    14. }).Run()
    15. }

    UDPServer是阻塞运行的,用户可以在自定义的回调函数中根据读取内容进行并发处理。

    在Linux下可以使用以下命令向服务端发送UDP数据进行测试,随后查看服务端端是否有输出:

    1. echo "hello" > /dev/udp/127.0.0.1/8999