带有 uWSGI 本机异步 websockets 和 redis 的错误文件描述符

Posted 2023-02-16

【中文标题】带有 uWSGI 本机异步 websockets 和 redis 的错误文件描述符

【英文标题】：Bad File descriptor with uWSGI native async websockets and redis

【发布时间】：2014-02-28 16:12:19

【问题描述】：

您好，我有一个简单的 websocket 服务器，它正在向客户端推送消息，代码如下

    uwsgi.websocket_handshake(env['HTTP_SEC_WEBSOCKET_KEY'], env.get('HTTP_ORIGIN', ''))
    print("websockets...")
    r = redis.StrictRedis(host='localhost', port=6379, db=0)
    channel = r.pubsub()
    channel.subscribe('backchannel')

    websocket_fd = uwsgi.connection_fd()
    redis_fd = channel.connection._sock.fileno()

    while True:
        uwsgi.wait_fd_read(websocket_fd, 3)
        uwsgi.wait_fd_read(redis_fd)
        uwsgi.suspend()
        fd = uwsgi.ready_fd()
        if fd > -1:
            if fd == websocket_fd:
                msg = uwsgi.websocket_recv_nb()
                if msg:
                    r.publish('backchannel', msg)
            elif fd == redis_fd:
                msg = channel.parse_response() 
                print(msg)
                # only interested in user messages
                t = 'message'
                if sys.version_info[0] > 2:
                    t = b'message'
                if msg[0] == t:
                    uwsgi.websocket_send("[%s] %s" % (time.time(), msg))
        else:
            # on timeout call websocket_recv_nb again to manage ping/pong
            msg = uwsgi.websocket_recv_nb()
            if msg:
                r.publish('backchannel', msg)

        r.publish('backchannel', "Resistence is Futile!")

此代码在推送大约 500 条左右消息后执行时会导致以下错误。

epoll_ctl(): Bad file descriptor [core/event.c line 520]
Traceback (most recent call last):
  File "SocketServer.py", line 71, in application
    uwsgi.wait_fd_read(redis_fd)
IOError: unable to fd 9 to the event queue
epoll_ctl(): Bad file descriptor [core/event.c line 635]

我知道我正在无限循环中发送最后一条消息，但我这样做是为了测试系统的限制。我想知道失败的原因，如果有什么我可以做的让系统在失败之前推送更多消息。

我正在使用以下命令在 ubuntu 12.04 上运行此代码 uwsgi --http :8080 --http-websockets --async=1000 --ugreen --wsgi-file SocketServer.py

运行示例异步聊天客户端应用程序https://github.com/unbit/uwsgi/blob/master/tests/websockets_chat_async.py 在重用户负载下运行时会导致相同的错误。

【参考方案1】：

Strace 和 Lsof 是你的朋友。 Strace 将为您提供正在运行的进程进行的系统调用列表。使用“strace -p”将其附加到正在运行的进程以查看系统调用列表，然后尝试重现该情况。希望您会在发生的事件流中找到有用的东西。 Lsof 将为您提供文件描述符到实际文件的映射。

【讨论】：

谢谢sharjeel，我认为问题的根源在于上面代码中调用redis的方式。我只是想不通它为什么会失败。

同样，strace 会有所帮助。