UDPServer通过gudp.Server实现。
使用方式:
import "github.com/gogf/gf/g/net/gudp"
接口文档:https://godoc.org/github.com/gogf/gf/g/net/gudp
type Serverfunc GetServer(name ...interface{}) *Serverfunc NewServer(address string, handler func(*Conn), names ...string) *Serverfunc (s *Server) Close() errorfunc (s *Server) Run() errorfunc (s *Server) SetAddress(address string)func (s *Server) SetHandler(handler func(*Conn))
其中GetServer使用单例模式通过给定一个唯一的名称获取/创建一个Server,后续可通过SetAddress和SetHandler方法动态修改Server属性;NewServer则直接根据给定参数创建一个Server对象。
来一个简单的示例:
package mainimport ("fmt""github.com/gogf/gf/g/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
