您好:
我想问一下如何在某些事件触发的情况下,发送消息给客户端,比如有关于客户端的新的消息到来时
,再发送消息。同时又能实时监听recv_frame得到的数据,另外recv_frame 应该是阻塞直到收到消息才能继续往下执行的吧
我想用您的这套代码做一个实时聊天系统,同时server可以存储聊天记录,期待您的回复。谢谢!
local server = require "resty.websocket.server"
local wb, err = server:new{
timeout = 5000, -- in milliseconds
max_payload_len = 65535,
}
if not wb then
ngx.log(ngx.ERR, "failed to new websocket: ", err)
return ngx.exit(444)
end
local data, typ, err = wb:recv_frame()
bytes, err = wb:send_text("Hello world")
if not bytes then
ngx.log(ngx.ERR, "failed to send a text frame: ", err)
return ngx.exit(444)
end