Class SocketMgr

Implements

INet

Constructors

constructor

new SocketMgr(): SocketMgr
Returns SocketMgr
- Defined in net/SocketMgr.ts:75

Properties

`Private` authErrCode

authErrCode: string | number = 0

`Private` cmdHandlerDic

cmdHandlerDic: Map<string, CbHandler> = ...

`Private` config

config: SocketConf = ...

`Private` errCode

errCode: string | number = 0

`Private` hbTimerId

hbTimerId: number = 0

`Private` lastRequestTime

lastRequestTime: number = 0

`Private` manualClose

manualClose: boolean = false

`Private` parsing

parsing: boolean = false

`Private` reconnecting

reconnecting: boolean = false

`Private` reconnetNum

reconnetNum: number = 0

`Private` reconnetTimerId

reconnetTimerId: number = 0

`Private` reqQueue

reqQueue: Queue<ReqData>

`Private` respQueue

respQueue: Queue<string | ArrayBuffer>

`Private` sending

sending: boolean = false

`Private` socket

socket: WebSocket

`Private` state

state: number

`Private` successCode

successCode: string | number = 0

Accessors

isConnected

get isConnected(): boolean
ws是否已连接上

Returns boolean
- Defined in net/SocketMgr.ts:91

`Static` inst

get inst(): SocketMgr
Returns SocketMgr
- Defined in net/SocketMgr.ts:71

Methods

`Private` arrayBufferToString

arrayBufferToString(buffer): string
将Int8Array的 ArrayBuffer 转换为字符串
Parameters
- buffer: ArrayBuffer
Returns string
- Defined in net/SocketMgr.ts:420

`Private` clearHeartBeatTimer

clearHeartBeatTimer(): void
Returns void
- Defined in net/SocketMgr.ts:452

`Private` clearReconnetTimer

clearReconnetTimer(): void
Returns void
- Defined in net/SocketMgr.ts:459

close

close(): void
Returns void
- Defined in net/SocketMgr.ts:125

connect

connect(force?, url?): void
开启ws连接
Parameters
- Optional force: boolean
  是否强制重连
- Optional url: string
  连接url，没有设置则取config中的url
Returns void
- Defined in net/SocketMgr.ts:99

`Private` destroy

destroy(): void
Returns void
- Defined in net/SocketMgr.ts:446

`Private` disposeSocket

disposeSocket(): void
Returns void
- Defined in net/SocketMgr.ts:376

`Private` heartBeat

heartBeat(): void
发送心跳

Returns void
- Defined in net/SocketMgr.ts:334

`Private` mergeArrayBuffer

mergeArrayBuffer(...arrayBuffers): ArrayBuffer
合并多个 ArrayBuffer 至同一个 ArrayBuffer 中.
Parameters
- Rest ...arrayBuffers: ArrayBuffer[]
Returns ArrayBuffer
- Defined in net/SocketMgr.ts:430

`Private` now

now(): number
Returns number
- Defined in net/SocketMgr.ts:466

`Protected` onClose

onClose(): void
Returns void
- Defined in net/SocketMgr.ts:358

`Private` onConnected

onConnected(): void
Returns void
- Defined in net/SocketMgr.ts:130

`Protected` onIOError

onIOError(e): void
Parameters
- e: Event
Returns void
- Defined in net/SocketMgr.ts:367

`Private` onMessage

onMessage(e): void
收到消息
Parameters
- e: MessageEvent<any>
Returns void
- Defined in net/SocketMgr.ts:247

`Private` onParseNextMsg

onParseNextMsg(): void
Returns void
- Defined in net/SocketMgr.ts:265

`Private` onSendNextMsg

onSendNextMsg(): void
Returns void
- Defined in net/SocketMgr.ts:196

onServerErr

onServerErr(code, msg): void
Parameters
- code: string | number
- msg: string
Returns void
Implementation of INet.onServerErr
- Defined in net/SocketMgr.ts:329

`Private` reconnect

reconnect(): void
Returns void
- Defined in net/SocketMgr.ts:146

regCMDHandler

regCMDHandler(cmd, handler): void
注册协议回调
Parameters
- cmd: string | string[]
  协议名
- handler: CbHandler
Returns void
- Defined in net/SocketMgr.ts:174

`Private` registerEvents

registerEvents(isRegister): void
Parameters
- isRegister: boolean
Returns void
- Defined in net/SocketMgr.ts:388

request

request<D>(api?, data?): Promise<D>
Type Parameters
- D
Parameters
- Optional api: string
- Optional data: RequestData<unknown>
Returns Promise<D>
Implementation of INet.request
- Defined in net/SocketMgr.ts:182

setConfig

setConfig(conf): void
Parameters
- conf: SocketConf
Returns void
Implementation of INet.setConfig
- Defined in net/SocketMgr.ts:84

`Private` stringToArrayBuffer

stringToArrayBuffer(content): ArrayBuffer
将字符串转换为基于 Int8Array 的 ArrayBuffer.
Parameters
- content: string
Returns ArrayBuffer
- Defined in net/SocketMgr.ts:410

`Private` updateState

updateState(state): void
Parameters
- state: SocketState
Returns void
- Defined in net/SocketMgr.ts:343

Class SocketMgr

Implements

Index

Constructors

Properties

Accessors

Methods

Constructors

constructor

Returns SocketMgr

Properties

Private authErrCode

Private cmdHandlerDic

Private config

Private errCode

Private hbTimerId

Private lastRequestTime

Private manualClose

Private parsing

Private reconnecting

Private reconnetNum

Private reconnetTimerId

Private reqQueue

Private respQueue

Private sending

Private socket

Private state

Private successCode

Accessors

isConnected

Returns boolean

Static inst

Returns SocketMgr

Methods

Private arrayBufferToString

Parameters

buffer: ArrayBuffer

Returns string

Private clearHeartBeatTimer

Returns void

Private clearReconnetTimer

Returns void

close

Returns void

connect

Parameters

Optional force: boolean

Optional url: string

Returns void

Private destroy

Returns void

Private disposeSocket

Returns void

Private heartBeat

Returns void

Private mergeArrayBuffer

Parameters

Rest ...arrayBuffers: ArrayBuffer[]

Returns ArrayBuffer

Private now

Returns number

Protected onClose

Returns void

Private onConnected

Returns void

Protected onIOError

Parameters

e: Event

Returns void

Private onMessage

Parameters

e: MessageEvent<any>

Returns void

Private onParseNextMsg

Returns void

Private onSendNextMsg

Returns void

onServerErr

Parameters

code: string | number

`Private` authErrCode

`Private` cmdHandlerDic

`Private` config

`Private` errCode

`Private` hbTimerId

`Private` lastRequestTime

`Private` manualClose

`Private` parsing

`Private` reconnecting

`Private` reconnetNum

`Private` reconnetTimerId

`Private` reqQueue

`Private` respQueue

`Private` sending

`Private` socket

`Private` state

`Private` successCode

`Static` inst

`Private` arrayBufferToString

`Private` clearHeartBeatTimer

`Private` clearReconnetTimer

`Optional` force: boolean

`Optional` url: string

`Private` destroy

`Private` disposeSocket

`Private` heartBeat

`Private` mergeArrayBuffer

`Rest` ...arrayBuffers: ArrayBuffer[]

`Private` now

`Protected` onClose

`Private` onConnected

`Protected` onIOError

`Private` onMessage

`Private` onParseNextMsg

`Private` onSendNextMsg

`Private` reconnect

`Private` registerEvents

`Optional` api: string

`Optional` data: RequestData<unknown>

`Private` stringToArrayBuffer

`Private` updateState