我想使用 NodeMCU 作为 1 个或多个浏览器客户端的 websocket
。
幸运的是,这里有代码可以做到这一点: https:
(由@crea
tionix 和/或@moononournation 提供)
这按描述工作并且我能够将消息从客户端发送到 NodeMCU 服务器,然后服务器根据接收到的消息进行响应。伟大的。
我的问题是:
1:如何向客户端发送消息而不必将其作为对客户端请求的响应(独立发送数据)发送?当我尝试调用
时,找不到作为变量的套接字,我明白这一点,但不知道该怎么做!
也许是因为
是在本地声明的?
2:为什么
函数会输出
变量?这个是来做什么的?我假设它是因为数据包溢出,但无论我的消息长度如何,我似乎永远无法让它返回任何东西。
3:在listen方法中,为什么作者加了一个排队系统?这是必不可少的还是对于可能会同时接收多个消息的应用程序?理想情况下,我想删除它。
我已将代码简化如下:(
不包括
和
函数 - 请参阅上面的链接以获取完整脚本)
代码:
全选net.createServer(net.TCP):listen(80, function(conn)
local buffer = false
local socket = {}
local queue = {}
local waiting = false
local function onSend()
if queue[1] then
local data = table.remove(queue, 1)
return conn:send(data, onSend)
end
waiting = false
end
function socket.send(...)
local data = encode(...)
if not waiting then
waiting = true
conn:send(data, onSend)
else
queue[#queue + 1] = data
end
end
conn:on("receive", function(_, chunk)
if buffer then
buffer = buffer .. chunk
while true do
local extra, payload, opcode = decode(buffer)
if opcode==8 then
print("Websocket client disconnected")
end
--print(type(extra), payload, opcode)
if not extra then return end
buffer = extra
socket.onmessage(payload, opcode)
end
end
local _, e, method = string.find(chunk, "([A-Z]+) /[^\r]* HTTP/%d%.%d\r\n")
local key, name, value
for name, value in string.gmatch(chunk, "([^ ]+): *([^\r]+)\r\n") do
if string.lower(name) == "sec-websocket-key" then
key = value
break
end
end
if method == "GET" and key then
acceptkey=crypto.toBase64(crypto.hash("sha1", key.."258EAFA5-E914-47DA-95CA-C5AB0DC85B11"))
conn:send(
"HTTP/1.1 101 Switching Protocols\r\n"..
"Upgrade: websocket\r\nConnection: Upgrade\r\n"..
"Sec-WebSocket-Accept: "..acceptkey.."\r\n\r\n",
function ()
print("New websocket client connected")
function socket.onmessage(payload,opcode)
socket.send("GOT YOUR DATA", 1)
print("PAYLOAD = "..payload)
--print("OPCODE = "..opcode)
end
end)
buffer = ""
else
conn:send(
"HTTP/1.1 200 OK\r\nContent-Type: text/plain\r\nContent-Length: 12\r\n\r\nHello World!",
conn.close)
end
end)
end)