建站
咨詢
售后
建站咨詢
新聞中心
這里有您想知道的互聯(lián)網(wǎng)營(yíng)銷解決方案
創(chuàng)新互聯(lián)GoFrame教程：GoFrameUDP組件-連接對(duì)象
?gudp?模塊提供了非常簡(jiǎn)便易用的?gudp.Conn?鏈接操作對(duì)象。
成都創(chuàng)新互聯(lián)專注于慶安企業(yè)網(wǎng)站建設(shè),響應(yīng)式網(wǎng)站,商城系統(tǒng)網(wǎng)站開(kāi)發(fā)。慶安網(wǎng)站建設(shè)公司,為慶安等地區(qū)提供建站服務(wù)。全流程按需設(shè)計(jì)網(wǎng)站，專業(yè)設(shè)計(jì)，全程項(xiàng)目跟蹤，成都創(chuàng)新互聯(lián)專業(yè)和態(tài)度為您提供的服務(wù)
使用方式：
import "github.com/GOgf/gf/v2/net/gudp"接口文檔： https://pkg.go.dev/github.com/gogf/gf/v2/net/gudp
type Conn
func NewConn(raddr string, laddr ...string) (*Conn, error)
func NewConnByNetConn(udp *net.UDPConn) *Conn
func (c *Conn) Close() error
func (c *Conn) LocalAddr() net.Addr
func (c *Conn) Recv(length int, retry ...Retry) ([]byte, error)
func (c *Conn) RecvPkg(retry ...Retry) (result []byte, err error)
func (c *Conn) RecvPkgWithTimeout(timeout time.Duration, retry ...Retry) ([]byte, error)
func (c *Conn) RecvWithTimeout(length int, timeout time.Duration, retry ...Retry) ([]byte, error)
func (c *Conn) RemoteAddr() net.Addr
func (c *Conn) Send(data []byte, retry ...Retry) error
func (c *Conn) SendPkg(data []byte, retry ...Retry) error
func (c *Conn) SendPkgWithTimeout(data []byte, timeout time.Duration, retry ...Retry) error
func (c *Conn) SendRecv(data []byte, receive int, retry ...Retry) ([]byte, error)
func (c *Conn) SendRecvPkg(data []byte, retry ...Retry) ([]byte, error)
func (c *Conn) SendRecvPkgWithTimeout(data []byte, timeout time.Duration, retry ...Retry) ([]byte, error)
func (c *Conn) SendRecvWithTimeout(data []byte, receive int, timeout time.Duration, retry ...Retry) ([]byte, error)
func (c *Conn) SendWithTimeout(data []byte, timeout time.Duration, retry ...Retry) error
func (c *Conn) SetDeadline(t time.Time) error
func (c *Conn) SetRecvBufferWait(d time.Duration)
func (c *Conn) SetRecvDeadline(t time.Time) error
func (c *Conn) SetSendDeadline(t time.Time) error可以看到，?gudp.Conn?和?gtcp.Conn?的方法非常類似，并且也支持簡(jiǎn)單協(xié)議的消息包方法。
基本介紹
?gudp.Conn?的操作絕大部分類似于?gtcp?的操作方式（大部分的方法名稱也相同），但由于?UDP?是面向非連接的協(xié)議，因此?gudp.Conn?（底層通信端口）也只能完成最多一次數(shù)據(jù)寫入和讀取，客戶端下一次再與目標(biāo)服務(wù)端進(jìn)行通信的時(shí)候，將需要?jiǎng)?chuàng)建新的?Conn?對(duì)象進(jìn)行通信。
使用示例
package main
import (
"fmt"
"github.com/gogf/gf/v2/frame/g"
"github.com/gogf/gf/v2/net/gudp"
"github.com/gogf/gf/v2/os/gtime"
"time"
)
func main() {
// Server
go gudp.NewServer("127.0.0.1:8999", func(conn *gudp.Conn) {
defer conn.Close()
for {
data, err := conn.Recv(-1)
if len(data) > 0 {
if err := conn.Send(append([]byte("> "), data...)); err != nil {
g.Log().Error(err)
}
}
if err != nil {
g.Log().Error(err)
}
}
}).Run()
time.Sleep(time.Second)
// Client
for {
if conn, err := gudp.NewConn("127.0.0.1:8999"); err == nil {
if b, err := conn.SendRecv([]byte(gtime.Datetime()), -1); err == nil {
fmt.Println(string(b), conn.LocalAddr(), conn.RemoteAddr())
} else {
g.Log().Error(err)
}
conn.Close()
} else {
g.Log().Error(err)
}
time.Sleep(time.Second)
}
}該示例與?gtcp.Conn?中的通信示例類似，不同的是，客戶端與服務(wù)端無(wú)法保持連接，每次通信都需要?jiǎng)?chuàng)建的新的連接對(duì)象進(jìn)行通信。
執(zhí)行后，輸出結(jié)果如下：
> 2018-07-21 23:13:31 127.0.0.1:33271 127.0.0.1:8999
> 2018-07-21 23:13:32 127.0.0.1:45826 127.0.0.1:8999
> 2018-07-21 23:13:33 127.0.0.1:58027 127.0.0.1:8999
> 2018-07-21 23:13:34 127.0.0.1:33056 127.0.0.1:8999
> 2018-07-21 23:13:35 127.0.0.1:39260 127.0.0.1:8999
> 2018-07-21 23:13:36 127.0.0.1:33967 127.0.0.1:8999
> 2018-07-21 23:13:37 127.0.0.1:52359 127.0.0.1:8999
...網(wǎng)頁(yè)名稱：創(chuàng)新互聯(lián)GoFrame教程：GoFrameUDP組件-連接對(duì)象
轉(zhuǎn)載來(lái)源：http://m.fisionsoft.com.cn/article/djodoeo.html
