7

我正在尝试创建一个“keepalive”websocket 线程，以便在有人连接到页面后每 10 秒向浏览器发送一次发射，但是我遇到了一个错误并且不知道如何解决它。

关于如何使这项工作的任何想法？

一旦发送“断开连接”，我将如何杀死该线程？

谢谢！

@socketio.on('connect', namespace='/endpoint')
def test_connect():
    emit('my response', {'data': '<br>Client thinks i\'m connected'})

    def background_thread():
        """Example of how to send server generated events to clients."""
        count = 0
        while True:
            time.sleep(10)
            count += 1
            emit('my response', {'data': 'websocket is keeping alive'}, namespace='/endpoint')

    global thread
    if thread is None:
        thread = Thread(target=background_thread)
        thread.start()
4

1 回答 1

10

您编写后台线程的方式要求它知道谁是客户，因为您正在向它发送直接消息。出于这个原因，后台线程需要访问请求上下文。copy_current_request_context在 Flask 中，您可以使用装饰器在线程中安装当前请求上下文的副本：

@copy_current_request_context
def background_thread():
    """Example of how to send server generated events to clients."""
    count = 0
    while True:
        time.sleep(10)
        count += 1
        emit('my response', {'data': 'websocket is keeping alive'}, namespace='/endpoint')

几点注意事项：

  • 发送回客户端时无需设置命名空间，默认情况下，emit调用将在客户端使用的同一命名空间上。当您在请求上下文之外广播或发送消息时，需要指定命名空间。
  • 请记住，您的设计需要为每个连接的客户端使用单独的线程。拥有一个向所有客户端广播的单一后台线程会更有效。有关示例，请参阅我在 Github 存储库中的示例应用程序：https ://github.com/miguelgrinberg/Flask-SocketIO/tree/master/example

要在客户端断开连接时停止线程，您可以使用任何多线程机制让线程知道它需要退出。例如，这可以是您在断开连接事件上设置的全局变量。一个不太容易实现的不太好的替代方案是等待emit客户端离开时引发异常并使用它来退出线程。

于 2014-12-01T08:32:35.180 回答