SweetSea/Techmino
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

微调ws库的使用方法

Browse Source
This commit is contained in:
MrZ626
2021-02-14 18:50:30 +08:00
parent 2df8fa14e8
commit 74759e3e0d
1 changed files with 4 additions and 10 deletions
Download Patch File Download Diff File Expand all files Collapse all files

14
Zframework/websocket.lua
View File

@@ -17,7 +17,7 @@ local socket = require "socket"
local band, bor, bxor = bit.band, bit.bor, bit.bxor local band, bor, bxor = bit.band, bit.bor, bit.bxor
local shl, shr = bit.lshift, bit.rshift local shl, shr = bit.lshift, bit.rshift
OPCODES = { local OPCODES = {
CONTINUE = 0, CONTINUE = 0,
TEXT = 1, TEXT = 1,
BINARY = 2, BINARY = 2,
@@ -86,14 +86,8 @@ local function _send(SOCK, opcode, message)
-- debug_print("[encode] end") -- debug_print("[encode] end")
end end
function _M:send(message, type) function _M:send(type, message)
local tempType = OPCODES.BINARY _send(self.socket, OPCODES[type or "BINARY"] or OPCODES.BINARY, message)
for _, opcode in pairs(_M.OPCODES) do
if type == opcode then
tempType = type
end
end
_send(self.socket, tempType, message)
end end
function _M:read() function _M:read()
@@ -125,7 +119,7 @@ function _M:read()
-- data -- data
res = SOCK:receive(length) res = SOCK:receive(length)
local closeCode = nil local closeCode
if OPCODE == OPCODES.PING then if OPCODE == OPCODES.PING then
self:pong(res) self:pong(res)
elseif OPCODE == OPCODES.CLOSE then elseif OPCODE == OPCODES.CLOSE then