websocketPool

Documentation

Index

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

Variables

var (
	WebsocketPoolHelper   WebsocketPool
	WebsocketClientHelper WebsocketClient
)

Types

type WebsocketClient

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

WebsocketClient websocket客户端

func (WebsocketClient) New

func (WebsocketClient) New() *WebsocketClient

New 实例化：链接切片

type WebsocketPool

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

WebsocketPool websocket连接池

func (*WebsocketPool) Close

func (r *WebsocketPool) Close()

Close 关闭连接池

func (*WebsocketPool) Handle

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

Handle 消息处理

func (WebsocketPool) Once

func (WebsocketPool) Once() *WebsocketPool

Once 单例化：WebSocket连接池

func (*WebsocketPool) RegisterRouter

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

RegisterRouter 注册路由

func (*WebsocketPool) SendMessageByAccountOpenId

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

SendMessageByAccountOpenId 根据用户openId发送消息

func (WebsocketPool) SendMessageByWsConn

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

SendMessageByWsConn 通过链接发送消息

func (WebsocketPool) SendMessageByWsManyConn

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

SendMessageByWsManyConn 通过链接切片发送消息

func (WebsocketPool) SetOnCloseConnectionErr

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

SetOnCloseConnectionErr 设置关闭链接错误回调

func (WebsocketPool) SetOnConnect

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

SetOnConnect 设置链接成功后回调

func (WebsocketPool) SetOnConnectionErr

func (WebsocketPool) SetOnConnectionErr(onConnectionErr func(error)) *WebsocketPool

SetOnConnectionErr 设置链接失败后回调

func (WebsocketPool) SetOnMessage

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

SetOnMessage 设置接收消息回调

func (WebsocketPool) SetOnMessageErr

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

SetOnMessageErr 设置接收消息失败回调

func (WebsocketPool) SetOnRouterErr

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

SetOnRouterErr 路由失败回调

func (WebsocketPool) SetOnSendMessageErr

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

SetOnSendMessageErr 设置发送消息失败回调