websocket

Documentation

Index

• Constants
• Variables
• func Check(fd uint64) (ok bool)
• func Disconnect(fd uint64, data []byte)
• func Push(fd uint64, data any)
• func RemoveServer(ser *WsServer)
• func Start()
• type ConnWriteChanParams
• type Sender
• type WsServer
  • func SetServer(ctx *types.RequestCtx) (ser *WsServer)
  • func (s *WsServer) Check() bool
  • func (s *WsServer) Disconnect(data []byte)
  • func (s *WsServer) OnClose()
  • func (s *WsServer) Ping(data []byte, deadline time.Time)
  • func (s *WsServer) Pong(data []byte, deadline time.Time)
  • func (s *WsServer) Push(data any)

Constants

const (
	WsServerStatusClose     = 0 //连接关闭
	WsServerStatusOpen      = 1 //连接开启
	WsServerStatusBeClosing = 2 //连接正在关闭
)

Variables

var (
	DataFramesDefault []byte
)

Functions

func Check

func Check(fd uint64) (ok bool)

func Disconnect

func Disconnect(fd uint64, data []byte)

断开连接

func Push

func Push(fd uint64, data any)

推送消息

func RemoveServer

func RemoveServer(ser *WsServer)

func Start

func Start()

Types

type ConnWriteChanParams

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

type Sender

type Sender struct {
	sync.Map
}

type WsServer

type WsServer struct {
	Ctx                   *types.RequestCtx
	Conn                  *websocket.Conn
	ConnWriteChan         chan *ConnWriteChanParams
	Fd                    uint64
	MessageType           int
	LastResponseTimestamp int64
	Status                byte
}

func SetServer

func SetServer(ctx *types.RequestCtx) (ser *WsServer)

func (*WsServer) Check

func (s *WsServer) Check() bool

func (*WsServer) Disconnect

func (s *WsServer) Disconnect(data []byte)

主动断开连接

func (*WsServer) OnClose

func (s *WsServer) OnClose()

连接断开事件处理

func (*WsServer) Ping

func (s *WsServer) Ping(data []byte, deadline time.Time)

func (*WsServer) Pong

func (s *WsServer) Pong(data []byte, deadline time.Time)

func (*WsServer) Push

func (s *WsServer) Push(data any)