阅读(2797)
赞(12)
GoFrame UDP组件-基本介绍
2022-04-12 11:36:28 更新
UDP (User Datagram Protocol)
一种无连接的传输层协议,提供面向事务的简单不可靠信息传送服务。UDP
服务端通过gudp.Server
实现,客户端通过gudp.Conn
对象或者工具方法实现。
使用方式:
import "github.com/gogf/gf/v2/net/gudp"
接口文档: https://pkg.go.dev/github.com/gogf/gf/v2/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
,后续可通过SetAddress
和SetHandler
方法动态修改Server
属性;NewServer
则直接根据给定参数创建一个Server
对象。
来一个简单的示例:
package main
import (
"fmt"
"github.com/gogf/gf/v2/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