websocketPool

Documentation

Index

• Variables
• type ServerPool
  • func (r *ServerPool) Close()
  • func (r *ServerPool) Handle(writer http.ResponseWriter, req *http.Request, header http.Header, ...)
  • func (ServerPool) Once() *ServerPool
  • func (r *ServerPool) RegisterRouter(routerKey string, fn func(ws *websocket.Conn)) *ServerPool
  • func (r *ServerPool) SendMessageByAccountOpenId(accountOpenId string, message []byte) error
  • func (ServerPool) SendMessageByWsConn(ws *websocket.Conn, message []byte) error
  • func (r ServerPool) SendMessageByWsManyConn(wsList *array.AnyArray[*websocket.Conn], message []byte)
  • func (ServerPool) SetOnCloseConnectionErr(onCloseConnectionErr func(conn *websocket.Conn, err error)) *ServerPool
  • func (ServerPool) SetOnConnect(onConnect func(*websocket.Conn)) *ServerPool
  • func (ServerPool) SetOnConnectionErr(onConnectionErr func(error)) *ServerPool
  • func (ServerPool) SetOnMessage(onMessage func(*websocket.Conn, []byte) string) *ServerPool
  • func (ServerPool) SetOnMessageErr(onMessageErr func(*websocket.Conn, error)) *ServerPool
  • func (ServerPool) SetOnRouterErr(onRouterErr func(*websocket.Conn, error)) *ServerPool
  • func (ServerPool) SetOnSendMessageErr(onSendMessageErr func(conn *websocket.Conn, err error)) *ServerPool
• type WebsocketServer
  • func (WebsocketServer) New() *WebsocketServer

Variables

var (
	ServerPoolHelper      ServerPool
	WebsocketClientHelper WebsocketServer
)

Types

type ServerPool

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

ServerPool websocket连接池

func (*ServerPool) Close

func (r *ServerPool) Close()

Close 关闭连接池

func (*ServerPool) Handle

func (r *ServerPool) Handle(
	writer http.ResponseWriter,
	req *http.Request,
	header http.Header,
	condition func() (string, bool),
)

Handle 消息处理

func (ServerPool) Once

func (ServerPool) Once() *ServerPool

Once 单例化：服务端连接池

func (*ServerPool) RegisterRouter

func (r *ServerPool) RegisterRouter(routerKey string, fn func(ws *websocket.Conn)) *ServerPool

RegisterRouter 注册路由

func (*ServerPool) SendMessageByAccountOpenId

func (r *ServerPool) SendMessageByAccountOpenId(accountOpenId string, message []byte) error

SendMessageByAccountOpenId 根据用户openId发送消息

func (ServerPool) SendMessageByWsConn

func (ServerPool) SendMessageByWsConn(ws *websocket.Conn, message []byte) error

SendMessageByWsConn 通过链接发送消息

func (ServerPool) SendMessageByWsManyConn

func (r ServerPool) SendMessageByWsManyConn(wsList *array.AnyArray[*websocket.Conn], message []byte)

SendMessageByWsManyConn 通过链接切片发送消息

func (ServerPool) SetOnCloseConnectionErr

func (ServerPool) SetOnCloseConnectionErr(onCloseConnectionErr func(conn *websocket.Conn, err error)) *ServerPool

SetOnCloseConnectionErr 设置关闭链接错误回调

func (ServerPool) SetOnConnect

func (ServerPool) SetOnConnect(onConnect func(*websocket.Conn)) *ServerPool

SetOnConnect 设置链接成功后回调

func (ServerPool) SetOnConnectionErr

func (ServerPool) SetOnConnectionErr(onConnectionErr func(error)) *ServerPool

SetOnConnectionErr 设置链接失败后回调

func (ServerPool) SetOnMessage

func (ServerPool) SetOnMessage(onMessage func(*websocket.Conn, []byte) string) *ServerPool

SetOnMessage 设置接收消息回调

func (ServerPool) SetOnMessageErr

func (ServerPool) SetOnMessageErr(onMessageErr func(*websocket.Conn, error)) *ServerPool

SetOnMessageErr 设置接收消息失败回调

func (ServerPool) SetOnRouterErr

func (ServerPool) SetOnRouterErr(onRouterErr func(*websocket.Conn, error)) *ServerPool

SetOnRouterErr 路由失败回调

func (ServerPool) SetOnSendMessageErr

func (ServerPool) SetOnSendMessageErr(onSendMessageErr func(conn *websocket.Conn, err error)) *ServerPool

SetOnSendMessageErr 设置发送消息失败回调

type WebsocketServer

type WebsocketServer struct {
	Connections *array.AnyArray[*websocket.Conn]
}

WebsocketServer websocket服务端

func (WebsocketServer) New

func (WebsocketServer) New() *WebsocketServer

New 实例化：链接切片