stdhttp

Documentation

Index

• Variables
• func NewWsClient(schema string, ip string, port string, path string, timeout time.Duration) *client
• func RegistDisconnectedHandler(handler func(connectSessionId string))
• func RegistMessageHandler(...)
• func SendRaw(sessionId string, data []byte) error
• func Start()
• type WebsocketConnection
  • func (conn *WebsocketConnection) Close()
  • func (conn *WebsocketConnection) Write(messageType int, data []byte) (err error)
• type WebsocketMessage

Variables

var WebsocketConnectionPool = make(map[string]*WebsocketConnection)

WebsocketConnectionPool connectsessionId与websocketconnection的映射

Functions

func NewWsClient

func NewWsClient(schema string, ip string, port string, path string, timeout time.Duration) *client

构造函数

func RegistDisconnectedHandler

func RegistDisconnectedHandler(handler func(connectSessionId string))

func RegistMessageHandler

func RegistMessageHandler(handler func(data []byte, remotePeerId string, clientId string, connectSessionId string, remoteAddr string) ([]byte, error))

* 注册读取原生数据的处理器

func SendRaw

func SendRaw(sessionId string, data []byte) error

* 主动发回信息，也是写入写出管道

func Start

func Start()

Types

type WebsocketConnection

type WebsocketConnection struct {
	Session   *session2.Session
	WsConnect *websocket.Conn
	// contains filtered or unexported fields
}

func (*WebsocketConnection) Close

func (conn *WebsocketConnection) Close()

func (*WebsocketConnection) Write

func (conn *WebsocketConnection) Write(messageType int, data []byte) (err error)

数据写入输出管道，然后通过无限循环的写出操作写出数据

type WebsocketMessage

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

自己实现的基于gorilla websocket的独立服务端，能够处理超大连接数