新聞中心
??UDP ?(User Datagram Protocol)?一種無(wú)連接的傳輸層協(xié)議,提供面向事務(wù)的簡(jiǎn)單不可靠信息傳送服務(wù)。?UDP?服務(wù)端通過(guò)?gudp.Server?實(shí)現(xiàn),客戶端通過(guò)?gudp.Conn?對(duì)象或者工具方法實(shí)現(xiàn)。

使用方式:
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?使用單例模式通過(guò)給定一個(gè)唯一的名稱獲取/創(chuàng)建一個(gè)?Server?,后續(xù)可通過(guò)?SetAddress?和?SetHandler?方法動(dòng)態(tài)修改?Server?屬性;?NewServer?則直接根據(jù)給定參數(shù)創(chuàng)建一個(gè)?Server?對(duì)象。
來(lái)一個(gè)簡(jiǎn)單的示例:
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?是阻塞運(yùn)行的,用戶可以在自定義的回調(diào)函數(shù)中根據(jù)讀取內(nèi)容進(jìn)行并發(fā)處理。
在?Linux?下可以使用以下命令向服務(wù)端發(fā)送?UDP?數(shù)據(jù)進(jìn)行測(cè)試,隨后查看服務(wù)端端是否有輸出:
echo "hello" > /dev/udp/127.0.0.1/8999 當(dāng)前標(biāo)題:創(chuàng)新互聯(lián)GoFrame教程:GoFrame UDP組件-基本介紹
本文網(wǎng)址:http://m.5511xx.com/article/cccghpd.html


咨詢
建站咨詢
