ws

Documentation

Index

• Variables
• func SendAll(msg []byte)
• func SendGroup(msg []byte)
• func SendOne(ctx context.Context, id string, group string, msg []byte)
• func WsLogout(id string, group string)
• type BroadCastMessageData
• type Client
  • func (c *Client) Read(cxt context.Context)
  • func (c *Client) Write(cxt context.Context)
• type GroupMessageData
• type Manager
  • func (manager *Manager) Info() map[string]interface{}
  • func (manager *Manager) LenClient() uint
  • func (manager *Manager) LenGroup() uint
  • func (manager *Manager) RegisterClient(client *Client)
  • func (manager *Manager) Send(cxt context.Context, id string, group string, message []byte)
  • func (manager *Manager) SendAll(message []byte)
  • func (manager *Manager) SendAllService()
  • func (manager *Manager) SendGroup(group string, message []byte)
  • func (manager *Manager) SendGroupService()
  • func (manager *Manager) SendService()
  • func (manager *Manager) Start()
  • func (manager *Manager) UnRegisterClient(client *Client)
  • func (manager *Manager) UnWsClient(c *gin.Context)
  • func (manager *Manager) WsClient(c *gin.Context)
• type MessageData

Variables

var WebsocketManager = Manager{
	Group:            make(map[string]map[string]*Client),
	Register:         make(chan *Client, 128),
	UnRegister:       make(chan *Client, 128),
	GroupMessage:     make(chan *GroupMessageData, 128),
	Message:          make(chan *MessageData, 128),
	BroadCastMessage: make(chan *BroadCastMessageData, 128),
	// contains filtered or unexported fields
}

初始化 wsManager 管理器

Functions

func SendAll

func SendAll(msg []byte)

func SendGroup

func SendGroup(msg []byte)

func SendOne

func SendOne(ctx context.Context, id string, group string, msg []byte)

func WsLogout

func WsLogout(id string, group string)

Types

type BroadCastMessageData

type BroadCastMessageData struct {
	Message []byte
}

广播发送数据信息

type Client

type Client struct {
	Id, Group  string
	Context    context.Context
	CancelFunc context.CancelFunc
	Socket     *websocket.Conn
	Message    chan []byte
}

Client 单个 websocket 信息

func (*Client) Read

func (c *Client) Read(cxt context.Context)

读信息，从 websocket 连接直接读取数据

func (*Client) Write

func (c *Client) Write(cxt context.Context)

写信息，从 channel 变量 Send 中读取数据写入 websocket 连接

type GroupMessageData

type GroupMessageData struct {
	Group   string
	Message []byte
}

groupMessageData 组广播数据信息

type Manager

type Manager struct {
	Group map[string]map[string]*Client

	Lock                 sync.Mutex
	Register, UnRegister chan *Client
	Message              chan *MessageData
	GroupMessage         chan *GroupMessageData
	BroadCastMessage     chan *BroadCastMessageData
	// contains filtered or unexported fields
}

Manager 所有 websocket 信息

func (*Manager) Info

func (manager *Manager) Info() map[string]interface{}

获取 wsManager 管理器信息

func (*Manager) LenClient

func (manager *Manager) LenClient() uint

当前连接个数

func (*Manager) LenGroup

func (manager *Manager) LenGroup() uint

当前组个数

func (*Manager) RegisterClient

func (manager *Manager) RegisterClient(client *Client)

注册

func (*Manager) Send

func (manager *Manager) Send(cxt context.Context, id string, group string, message []byte)

向指定的 client 发送数据

func (*Manager) SendAll

func (manager *Manager) SendAll(message []byte)

广播

func (*Manager) SendAllService

func (manager *Manager) SendAllService()

处理广播数据

func (*Manager) SendGroup

func (manager *Manager) SendGroup(group string, message []byte)

向指定的 Group 广播

func (*Manager) SendGroupService

func (manager *Manager) SendGroupService()

处理 group 广播数据

func (*Manager) SendService

func (manager *Manager) SendService()

处理单个 client 发送数据

func (*Manager) Start

func (manager *Manager) Start()

启动 websocket 管理器

func (*Manager) UnRegisterClient

func (manager *Manager) UnRegisterClient(client *Client)

注销

func (*Manager) UnWsClient

func (manager *Manager) UnWsClient(c *gin.Context)

func (*Manager) WsClient

func (manager *Manager) WsClient(c *gin.Context)

gin 处理 websocket handler

type MessageData

type MessageData struct {
	Id, Group string
	Context   context.Context
	Message   []byte
}

messageData 单个发送数据信息