wsx

Documentation

Overview

Package wsx Create on 2023/8/5 @author xuzhuoxi

Index

• Variables
• type IWebSocketClient
  • func NewWebSocketClient() IWebSocketClient
• type IWebSocketServer
  • func NewWebSocketServer() IWebSocketServer
• type WSConnAdapter
  • func (rw *WSConnAdapter) ReadBytes(bytes []byte) (n int, address string, err error)
  • func (rw *WSConnAdapter) RemoteAddress() string
  • func (rw *WSConnAdapter) WriteBytes(bytes []byte, rAddress ...string) (n int, err error)
• type WebSocketClient
  • func (c *WebSocketClient) CloseClient() error
  • func (c *WebSocketClient) OpenClient(params netx.SockParams) error
• type WebSocketServer
  • func (s *WebSocketServer) CloseConnection(address string) (err error, ok bool)
  • func (s *WebSocketServer) Connections() int
  • func (s *WebSocketServer) FindConnection(address string) (conn netx.IServerConn, ok bool)
  • func (s *WebSocketServer) SendBytesTo(bytes []byte, rAddress ...string) error
  • func (s *WebSocketServer) SendPackTo(pack []byte, rAddress ...string) error
  • func (s *WebSocketServer) SetMaxConn(max int)
  • func (s *WebSocketServer) StartServer(params netx.SockParams) error
  • func (s *WebSocketServer) StopServer() error
• type WsSockConn
  • func (o *WsSockConn) ClientAddress() string
  • func (o *WsSockConn) CloseConn() error
  • func (o *WsSockConn) SendBytes(bytes []byte) error
  • func (o *WsSockConn) SendPack(data []byte) error

Variables

var WsDataBlockHandler = bytex.NewDefaultDataBlockHandler()

Types

type IWebSocketClient

type IWebSocketClient interface {
	netx.ISockClient
}

func NewWebSocketClient

func NewWebSocketClient() IWebSocketClient

type IWebSocketServer

type IWebSocketServer interface {
	netx.ISockServer
	eventx.IEventDispatcher
}

func NewWebSocketServer

func NewWebSocketServer() IWebSocketServer

type WSConnAdapter

type WSConnAdapter struct {
	Reader io.Reader
	Writer io.Writer
	// contains filtered or unexported fields
}

func (*WSConnAdapter) ReadBytes

func (rw *WSConnAdapter) ReadBytes(bytes []byte) (n int, address string, err error)

func (*WSConnAdapter) RemoteAddress

func (rw *WSConnAdapter) RemoteAddress() string

func (*WSConnAdapter) WriteBytes

func (rw *WSConnAdapter) WriteBytes(bytes []byte, rAddress ...string) (n int, err error)

type WebSocketClient

type WebSocketClient struct {
	netx.SockClientBase
}

func (*WebSocketClient) CloseClient

func (c *WebSocketClient) CloseClient() error

func (*WebSocketClient) OpenClient

func (c *WebSocketClient) OpenClient(params netx.SockParams) error

type WebSocketServer

type WebSocketServer struct {
	eventx.EventDispatcher
	netx.SockServerBase
	// contains filtered or unexported fields
}

func (*WebSocketServer) CloseConnection

func (s *WebSocketServer) CloseConnection(address string) (err error, ok bool)

func (*WebSocketServer) Connections

func (s *WebSocketServer) Connections() int

func (*WebSocketServer) FindConnection

func (s *WebSocketServer) FindConnection(address string) (conn netx.IServerConn, ok bool)

func (*WebSocketServer) SendBytesTo

func (s *WebSocketServer) SendBytesTo(bytes []byte, rAddress ...string) error

func (*WebSocketServer) SendPackTo

func (s *WebSocketServer) SendPackTo(pack []byte, rAddress ...string) error

func (*WebSocketServer) SetMaxConn

func (s *WebSocketServer) SetMaxConn(max int)

func (*WebSocketServer) StartServer

func (s *WebSocketServer) StartServer(params netx.SockParams) error

func (*WebSocketServer) StopServer

func (s *WebSocketServer) StopServer() error

type WsSockConn

type WsSockConn struct {
	Address string
	SRProxy netx.IPackSendReceiver
	Conn    *websocket.Conn
}

func (*WsSockConn) ClientAddress

func (o *WsSockConn) ClientAddress() string

func (*WsSockConn) CloseConn

func (o *WsSockConn) CloseConn() error

func (*WsSockConn) SendBytes

func (o *WsSockConn) SendBytes(bytes []byte) error

func (*WsSockConn) SendPack

func (o *WsSockConn) SendPack(data []byte) error