websocket

package

v1.0.0 Latest Latest Go to latest Published: Jan 18, 2026 License: MIT Imports: 5 Imported by: 0

Details

This section is empty.

This section is empty.

func HandleWebSocket(hub *Hub) router.HandlerFunc

HandleWebSocket 处理 WebSocket 连接

type Client struct {
	ID   string
	Conn *websocket.Conn
	Send chan []byte
	Hub  *Hub
}

Client WebSocket 客户端

func (c *Client) ReadPump()

ReadPump 读取客户端消息

func (c *Client) WritePump()

WritePump 写入消息到客户端

type Hub struct {
	// contains filtered or unexported fields
}

Hub WebSocket 集线器

func NewHub() *Hub

NewHub 创建集线器

func (h *Hub) Broadcast(message []byte)

Broadcast 广播消息

func (h *Hub) ClientCount() int

ClientCount 获取客户端数量

func (h *Hub) GetClients() []*Client

GetClients 获取所有客户端

func (h *Hub) Run()

Run 运行集线器

func (h *Hub) SendToClient(clientID string, message []byte)

SendToClient 发送消息给指定客户端