Documentation ¶
Overview ¶
Websocket Network version 1.0 beta by koangel email: jackliu100@gmail.com 2017/8/3
Index ¶
- Constants
- Variables
- type WSConn
- func (c *WSConn) Close()
- func (c *WSConn) CloseSocket()
- func (c *WSConn) GetConn() *ws.Conn
- func (c *WSConn) GetNetConn() net.Conn
- func (c *WSConn) GetUserData() interface{}
- func (c *WSConn) InitData()
- func (c *WSConn) RemoteAddr() string
- func (c *WSConn) RemoveData()
- func (c *WSConn) Send(data []byte) int
- func (c *WSConn) SendDirect(data []byte) int
- func (c *WSConn) SendPak(val interface{}) int
- func (c *WSConn) SendPakDirect(val interface{}) int
- func (c *WSConn) SetReadTimeout(t time.Duration)
- func (c *WSConn) SetUserData(user interface{})
- func (c *WSConn) SetWriteTimeout(t time.Duration)
- type WSNetwork
Constants ¶
View Source
const ( ReadWaitPing = 120 * time.Second WriteTicker = 2 * time.Minute )
View Source
const ( BinaryMsg = websocket.BinaryMessage TextMsg = websocket.TextMessage )
Variables ¶
View Source
var (
HandlerProc = 1
)
Functions ¶
This section is empty.
Types ¶
type WSConn ¶
type WSConn struct { cm.Conn WConn *ws.Conn UserData interface{} // 用户对象 LastPing time.Time CryptKey []byte IsClosed int32 RMData sync.Once // contains filtered or unexported fields }
func (*WSConn) CloseSocket ¶
func (c *WSConn) CloseSocket()
func (*WSConn) GetNetConn ¶
func (*WSConn) GetUserData ¶
func (c *WSConn) GetUserData() interface{}
func (*WSConn) RemoteAddr ¶
func (*WSConn) RemoveData ¶
func (c *WSConn) RemoveData()
func (*WSConn) SendDirect ¶
func (*WSConn) SendPakDirect ¶
func (*WSConn) SetReadTimeout ¶
func (*WSConn) SetUserData ¶
func (c *WSConn) SetUserData(user interface{})
//////////////////////////////////////////// 成员函数
func (*WSConn) SetWriteTimeout ¶
type WSNetwork ¶
type WSNetwork struct { Origin string ChkOrigin bool NetCM *cm.ConnManager /// 所有的callBack函数 // 创建用户DATA CreateUserData func() interface{} // 通知连接 OnAccept func(conn *WSConn) // 数据包进入 OnHandler func(conn *WSConn, ownerPak []byte) // 连接关闭 OnClose func(conn *WSConn) // 连接成功 OnConnected func(conn *WSConn) // 连接安全性检测 server only OnUpgrade func(req *http.Request) bool // 打包以及加密行为 Package func(val interface{}) (data []byte, err error) Unpackage func(conn *WSConn, spak *stream.BufferIO) (data [][]byte, err error) // 输出panic数据 Panic func(conn *WSConn, src string) Encrypt func(data, key []byte) []byte Decrypt func(data, key []byte) []byte HttpHome func(w http.ResponseWriter, r *http.Request) MsgType int // contains filtered or unexported fields }
func NetEmptyWS ¶
//////////////////////////////////// 新建函数
func NewWebsocket ¶
func (*WSNetwork) RemoveSession ¶
func (*WSNetwork) SetBinaryMessage ¶
func (c *WSNetwork) SetBinaryMessage()
func (*WSNetwork) SetTextMessage ¶
func (c *WSNetwork) SetTextMessage()
//////////////////////////////////// 成员函数
Click to show internal directories.
Click to hide internal directories.