【发布时间】:2023-04-07 04:10:01
【问题描述】:
我正在使用 websockets 和 MQTT 进行项目。 Websocket 服务器从 mqtt 接收 4 条消息,我让它循环接收任何其他消息。但是,如果没有消息,Encoded_fixed_header = gen_tcp:recv(Socket, 0) 会给出错误,因为没有要接收的消息。我对 gen_tcp:recv 做了一些研究,它说它会无限等待一条消息,但似乎不是,它关闭了套接字。
recieve(Socket,WsPID) ->
Encoded_fixed_header = gen_tcp:recv(Socket, 0),
Length = gen_tcp:recv(Socket, 0)
Variable_Header = gen_tcp:recv(Socket, 0),
Playload=gen_tcp:recv(Socket, 0),
recieve(Socket,WsPID).
可能是什么问题?
【问题讨论】:
标签: sockets websocket erlang mqtt gen-tcp