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
  • No labels

3 Comments

  1. camry

    func Test_Buffer(t *testing.T) {
   var ctx = context.TODO()
   s := gudp.NewServer(gudp.FreePortAddress, func(conn *gudp.Conn) {
      defer conn.Close()
      for {
         data, err := conn.Recv(1)
         if len(data) > 0 {
            if err := conn.Send(data); err != nil {
               glog.Error(ctx, err)
            }
         }
         if err != nil {
            break
         }
      }
   })
   go s.Run()
   defer s.Close()
   time.Sleep(100 * time.Millisecond)
   gtest.C(t, func(t *gtest.T) {
      result, err := gudp.SendRecv(s.GetListenedAddress(), []byte("123"), -1)
      t.AssertNil(err)
      t.Assert(string(result), "1")
   })
   gtest.C(t, func(t *gtest.T) {
      result, err := gudp.SendRecv(s.GetListenedAddress(), []byte("456"), -1)
      t.AssertNil(err)
      t.Assert(string(result), "4")
   })
}

    === RUN   Test_Buffer
    2022-12-01 18:26:22.209 [ERRO] Write data failed: write udp [::]:63488: wsasend: A request to send or receive data was disallowed because the socket is not connected and (when sending on a datagram socket using a sendto call) no address was supplied.
    Stack:
    1.  github.com/gogf/gf/v2/net/gudp_test.Test_Buffer.func1
        E:/project/DGame/Go/gf/net/gudp/gudp_z_unit_test.go:148
    2.  github.com/gogf/gf/v2/net/gudp.(*Server).Run
        E:/project/DGame/Go/gf/net/gudp/gudp_server.go:112


    强哥，实际使用时遇到这个问题，结果发现这个测试用例也跑不通，可以解决下么。


    1. 糖水不加糖

      data, err := conn.Recv(1) -> data, err := conn.Recv(-1) 另外,使用SendRecv会建立句柄,与Send有差别.

  2. ayamzh

    能支持下kcp么