我正在使用使用eventlet用Python编写的服务器端端点和用JavaScript编写的客户端起点在websocket上工作:
var ws = new WebSocket("ws://192.168.1.25:16081/some_url");
ws.onopen = function()
{
console.log("Transmitting " + data)
ws.send(data)
};
ws.onmessage = function (evt)
{
console.log(evt.data)
// Do stuff with evt.data
};
和Python代码:
import eventlet
eventlet.sleep()
from eventlet import wsgi
from eventlet import websocket
from eventlet.support import six
@websocket.WebSocketWSGI
def game_room(ws):
print(ws)
try:
while True:
time.sleep(1)
#Do stuff, some server-pushing
except Exception,e:
#Disconnect, do stuff
def dispatch(environ, start_response):
""" This resolves to the web page or the websocket depending on
the path."""
if environ['PATH_INFO'] == '/some_url':
return game_room(environ, start_response)
if __name__ == "__main__":
# run an example app from the command line
listener = eventlet.listen(('0.0.0.0', 16081))
wsgi.server(listener, dispatch, debug=True)
为了简洁起见,我删节了一些代码。如果我使用JavaScript转到该页面,则效果很好。运行wsgi服务器的控制台报告说,已从客户端计算机的正确IP建立了连接。问题是,如果我使用手机导航到同一页面,则套接字不报告任何内容。如果关闭机器上的卡舌并重新加载套接字服务器,则可以连接手机。它似乎无法处理并发连接。
我不知道从哪里开始。运行服务器时可以编辑一些选项吗?
最佳答案
请将测试代码减至最少,然后将其完整粘贴。不要隐藏部分代码。 chop 的代码将我们引向神秘猜测的道路。
我的第一个猜测是您有类似以下内容的东西:
import time
import eventlet
def fun(name):
while True:
print('{0} tick'.format(name))
time.sleep(1)
eventlet.spawn(fun, 'f1')
eventlet.spawn(fun, 'f2')
eventlet.sleep(10)
这只允许一个协程运行,因为
time.sleep
阻止了所有程序。请识别使用两个不同的
sleep
函数的代码味道。始终了解原因,并有充分的理由这样做。eventlet.sleep
。 sleep
,您宁愿对数据流而不是时间流使用react。 eventlet.import_patched
拥有所需模块的绿色版本,其中所有针对协程的阻塞函数均已修复。 eventlet.tpool.execute
使它在单独的OS线程中运行。 不幸的是,如果您 chop 了诸如
from eventlet.green import time
之类的东西,而问题却有所不同,则此答案可能完全无关紧要。