socket

Documentation

Index

• type Connection
  • func InitSocket(ctx context.Context, w http.ResponseWriter, r *http.Request) (*Connection, error)
  • func (c *Connection) WebsocketClose()
  • func (c *Connection) WebsocketRead() (*Message, error)
  • func (c *Connection) WebsocketWrite(msgType int, data []byte) error
• type Message

Types

type Connection

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

Connection websocket 链接

func InitSocket

func InitSocket(ctx context.Context, w http.ResponseWriter, r *http.Request) (*Connection, error)

func (*Connection) WebsocketClose

func (c *Connection) WebsocketClose()

WebsocketClose 关闭 websocket 通道

func (*Connection) WebsocketRead

func (c *Connection) WebsocketRead() (*Message, error)

WebsocketRead 从前端读消息

func (*Connection) WebsocketWrite

func (c *Connection) WebsocketWrite(msgType int, data []byte) error

WebsocketWrite 写消息到前端

type Message

type Message struct {
	Type int    // websocket 消息类型, 就是 websocket 管道中传输的是什么类型的数据
	Data []byte // websocket 消息体, 需要根据消息的类型进行解析
}

Message web socket message