嗨我有一个简单的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!")
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
在大量用户负载下运行时会导致相同的错误.
解决方法
版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。