socketio.emit() 收到 UDP 数据包时

Question

我有一个 flask-socketio 服务器，它提供在网页上显示接收到的消息的索引。服务器在自己的线程中通过 ZMQ 或基本 UDP 接收消息。在相同的线程中，它向网页发送消息，但只接收 ZMQ 线程消息。你能告诉我为什么 UDP 线程 eimtting 不起作用吗？

from flask import Flask, request
from flask_socketio import SocketIO, emit
from threading import Thread
import socket
import time, zmq, pmt

HTTP_PORT = 5000
ZMQ_PORT = 5001
UDP_IP = "127.0.0.1"
UDP_PORT = 5005

app = Flask(__name__, static_url_path="")
# app.config["SECRET_KEY"] = "secret!"
socketio = SocketIO(app)


def background_thread():
    sock = socket.socket(socket.AF_INET,  # Internet
                         socket.SOCK_DGRAM)  # UDP
    sock.bind((UDP_IP, UDP_PORT))

    while True:
        data, addr = sock.recvfrom(1024)  # buffer size is 1024 bytes
        message = 'hello'
        socketio.emit('gnu radio', (message,))
        time.sleep(0.10)
        print "received message:", data


def background_thread_2():
    # Establish ZMQ context and socket
    context = zmq.Context()
    socket = context.socket(zmq.SUB)
    socket.setsockopt(zmq.SUBSCRIBE, "")
    socket.connect("tcp://0.0.0.0:%d" % (ZMQ_PORT))

    while True:
        # Receive decoded ADS-B message from the decoder over ZMQ
        pdu_bin = socket.recv()
        pdu = str(pmt.deserialize_str(pdu_bin)).decode('utf-8', 'ignore').encode("utf-8")
        message = 'hello2'
        socketio.emit('gnu radio', (message,))
        time.sleep(0.10)


@app.route("/")
def index():
    return app.send_static_file("index.html")


@socketio.on("connect")
def connect():
    print("Client connected", request.sid)


@socketio.on("disconnect")
def disconnect():
    print("Client disconnected", request.sid)


if __name__ == "__main__":
    thread = Thread(target=background_thread)
    thread.daemon = True
    thread.start()
    thread = Thread(target=background_thread_2)
    thread.daemon = True
    thread.start()

    socketio.run(app, host="0.0.0.0", port=HTTP_PORT, debug=True)

只收到Hello2。

Answer 1

问题实际上在于 Flask 的重新加载器。

当您启用调试模式时，默认情况下，Flask 将使用重新加载器 - 一个监控应用程序文件并在文件更改时重新启动服务器的进程。因此，当 Flask 运行 socketio.run 行并确定应该启用调试模式时，它重新运行脚本。

这意味着您的后台线程将重新启动。但是您已经有一个绑定到 UDP 127.0.0.1:5005 的正在运行的线程。第二次尝试这样做会失败：

Exception in thread Thread-1:
Traceback (most recent call last):
  File "C:\Users\matejcik\AppData\Local\Programs\Python\Python37\lib\threading.py", line 917, in _bootstrap_inner
    self.run()
  File "C:\Users\matejcik\AppData\Local\Programs\Python\Python37\lib\threading.py", line 865, in run
    self._target(*self._args, **self._kwargs)
  File ".\app.py", line 23, in background_thread
    sock.bind((UDP_IP, UDP_PORT))
OSError: [WinError 10048] Only one usage of each socket address (protocol/network address/port) is normally permitted

旧的 UDP 线程仍然存在，将接收 UDP 消息并将它们打印到控制台。 但是该线程在重启之前仍然引用旧的 Python 环境，因此 socketio 实例是陈旧的，正在向 void 发送消息。

这也是ZMQ接收消息正常的原因：因为ZMQ订阅不是独占的，所以新旧线程都可以启动，新线程可以毫无问题地将消息中继到新的socketio。

一般来说，线程和reloader的交互比较混乱，另见https://github.com/miguelgrinberg/Flask-SocketIO/issues/567

如果指定debug=False 或debug=True, use_reloader=False，则可以避免此问题。