UDP (User Datagram Protocol)一种无连接的传输层协议,提供面向事务的简单不可靠信息传送服务。UDP服务端通过gudp.Server实现,客户端通过gudp.Conn对象或者工具方法实现。

使用方式

import "github.com/gogf/gf/net/gudp"

接口文档 https://godoc.org/github.com/gogf/gf/net/gudp

type Server
    func GetServer(name ...interface{}) *Server
    func NewServer(address string, handler func(*Conn), names ...string) *Server
    func (s *Server) Close() error
    func (s *Server) Run() error
    func (s *Server) SetAddress(address string)
    func (s *Server) SetHandler(handler func(*Conn))

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

来一个简单的示例:

package main

import (
    "fmt"
    "github.com/gogf/gf/net/gudp"
)

func main() {
    gudp.NewServer("127.0.0.1:8999", func(conn *gudp.Conn) {
        defer conn.Close()
        for {
            if data, _ := conn.Recv(-1); len(data) > 0 {
                fmt.Println(string(data))
            }
        }
    }).Run()
}

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

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

echo "hello" > /dev/udp/127.0.0.1/8999
  • No labels