ws

Documentation

Index

• type Client
  • func (c *Client) Close()
  • func (c *Client) Read(ch chan []byte)
  • func (c *Client) Write()
• type Message
• type SendMessage
• type WsManager
  • func NewMag() *WsManager
  • func (wsmag *WsManager) Reg(uuid string, conn *websocket.Conn) *Client
  • func (wsmag *WsManager) SendMain(code int, data interface{})
  • func (wsmag *WsManager) SetUp()

Types

type Client

type Client struct {
	Socket   *websocket.Conn
	Send     chan []byte
	OutClose chan bool
	Lock     sync.Mutex
	Status   bool
	// contains filtered or unexported fields
}

websocket 链接对象

func (*Client) Close

func (c *Client) Close()

func (*Client) Read

func (c *Client) Read(ch chan []byte)

func (*Client) Write

func (c *Client) Write()

type Message

type Message struct {
	Code    int         `json:"code,omitempty"`
	Message string      `json:"message,omitempty"`
	Content interface{} `json:"data,omitempty"`
}

消息结构提

type SendMessage

type SendMessage struct {
	Code int         `json:"code"`
	Msg  string      `json:"msg"`
	Data interface{} `json:"data"`
}

type WsManager

type WsManager struct {
	Clients    map[string]*Client
	Broadcast  chan []byte
	Register   chan *Client //链接
	Unregister chan *Client //断开链接
}

websocket管理器

var WsMag WsManager

func NewMag

func NewMag() *WsManager

func (*WsManager) Reg

func (wsmag *WsManager) Reg(uuid string, conn *websocket.Conn) *Client

注册ws链接

func (*WsManager) SendMain

func (wsmag *WsManager) SendMain(code int, data interface{})

func (*WsManager) SetUp

func (wsmag *WsManager) SetUp()