如何解决将MQTT与HTTP流服务器一起使用
我正在尝试使用MQTT来接收消息,同时使用流HTTP服务器将我的picamera流到同一文件中的5000端口上。这导致我的MQTT相当不稳定,并且无法及时接收消息。我可以知道有人对此有解决方案吗?谢谢。
MQTT代码
def on_connect(client,rc):
if rc == 0:
global Connected
Connected = True
client.subscribe("picam/show")
def on_message(client,userdata,message):
global capture_image
data = message.payload.decode("utf-8").replace("'",'"')
d = json.loads(data)
if d["action"] == "take pic":
try:
capture_image()
except Exception as e:
print(e)
client = mqttClient.Client("picam")
client.on_connect= on_connect
client.connect(broker_address,port=1884)
# edited here to change loop_forever to loop_start
client.loop_start()
流HTTP代码
output = StreamingOutput()
camera.start_recording(output,format='mjpeg')
try:
address = ('',5000)
server = StreamingServer(address,StreamingHandler)
server.serve_forever()
finally:
camera.stop_recording()
解决方法
设法通过使用线程来解决这个问题:)!万一有人也遇到这个问题
版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。