websocket

Documentation

Index

• func SocketStart()
• type Client
  • func CreateClient(addr string, socket *websocket.Conn) *Client
  • func (c *Client) Read()
  • func (c *Client) Write()
• type ClientManager
  • func NewClientManager() *ClientManager

Functions

func SocketStart

func SocketStart()

Types

type Client

type Client struct {
	Addr   string
	Socket *websocket.Conn

	AppID         uint32
	UserID        uint
	FirstTime     time.Time
	HeartbeatTime time.Time
	LoginTime     time.Time
	// contains filtered or unexported fields
}

func CreateClient

func CreateClient(addr string, socket *websocket.Conn) *Client

func (*Client) Read

func (c *Client) Read()

func (*Client) Write

func (c *Client) Write()

type ClientManager

type ClientManager struct {
	Client      map[*Client]bool   //全部的连接
	ClientsLock sync.RWMutex       //读写锁
	Users       map[string]*Client //登陆的用户 //appID+uuid
	UsersLock   sync.RWMutex       //读写锁
	Connect     chan *Client       //连接处理
	Disconnect  chan *Client       //断开连接处理
	Login       chan *Client       //用户登录处理
	Broadcast   chan *Client       //广播 向全部成员发送数据
}

func NewClientManager

func NewClientManager() *ClientManager