mudp

package
v0.5.2 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Jan 16, 2026 License: MIT Imports: 4 Imported by: 0

README

mudp 使用说明

基于 github.com/panjf2000/gnet/v2 的简单 UDP 封装。

使用示例

# 1. 启动接收端
go run ./mudp/udp_listener_demo

# 2. 运行发送端(在另一个终端)
go run ./mudp/udp_send_demo

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Listener added in v0.4.1

type Listener struct {
	IP        string
	Port      int
	OnMessage OnMessageFunc
	MultiCore bool

	// Engine 对外暴露 gnet 引擎实例,OnBoot 时由内部引擎填充。
	// 注意:该字段在 Start() 后,当引擎启动并触发 OnBoot 回调时才会被设置,
	// 在此之前为 nil。
	Engine gnet.Engine
	// Conn 对外暴露当前连接的 gnet.Conn 实例,在 OnTraffic 时会被更新。
	// 注意:该字段在 Start() 后,当有数据到达并触发 OnTraffic 回调时才会被设置,
	// 在此之前为 nil。
	Conn gnet.Conn
	// contains filtered or unexported fields
}

Listener 表示一个 UDP 监听器配置。

示例:

l, err := mudp.NewListener(mudp.Listener{IP: "127.0.0.1", Port: 9999, OnMessage: fn})

func NewListener added in v0.4.1

func NewListener(opt Listener) (l *Listener, err error)

NewListener 根据传入配置创建并返回一个 Listener 实例。 返回的 Listener 仅为配置容器;调用者需要调用 Start() 启动服务。

func (*Listener) Start added in v0.4.1

func (l *Listener) Start() error

Start 阻塞启动监听,返回非 nil 错误表示启动失败或运行期间出错。

type OnMessageFunc added in v0.4.0

type OnMessageFunc func(eventName string, data []byte)

OnMessageFunc 是接收到数据时的回调函数签名。 eventName: 事件名(例如 "OnBoot"/"OnTraffic") data: 原始字节数据

type Sender

type Sender struct {
	IP   string
	Port int
	Conn net.Conn
	// contains filtered or unexported fields
}

Sender 表示一个简易 UDP 发送客户端。

func NewSender

func NewSender(opt Sender) (send *Sender, err error)

NewSender 创建并连接到目标 UDP 地址。 NOTE: 该函数会立即进行网络拨号,调用者负责在不需要时调用 Close()

func (*Sender) Close

func (s *Sender) Close() (err error)

Close 关闭底层连接。

func (*Sender) Write added in v0.4.1

func (s *Sender) Write(data []byte) (n int, err error)

Write 发送数据到已连接的 UDP 目标。

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL