我正在尝试在Flask框架下使用JQuery和Python进行长时间轮询。
在PHP中进行了长时间的轮询之后,我尝试以相同的方式进行处理:
具有while(true)循环的脚本/函数,定期检查更改,例如,数据库中每0.5秒更改一次,并在发生更改时返回一些数据。
因此,在我的ini .py文件中,我创建了一个到/ poll的app.route,以供JQuery调用。jQuery向其提供有关客户端当前状态的一些信息,并且poll()函数将其与数据库中当前的状态进行比较。当观察到更改时,循环结束并返回信息。
这是python代码:
@app.route('/poll') def poll(): client_state = request.args.get("state") #remove html encoding + whitesapce from client state html_parser = HTMLParser.HTMLParser() client_state = html_parser.unescape(client_state) client_state = "".join(client_state.split()) #poll the database while True: time.sleep(0.5) data = get_data() json_state = to_json(data) json_state = "".join(data) #remove whitespace if json_state != client_state: return "CHANGE"
问题是,当上面的代码开始轮询时,服务器似乎过载,并且其他Ajax调用以及其他请求(例如,使用JQuery将“加载”图像加载到html)均无响应且超时。
为了完整起见,我在此处包括了JQuery:
function poll() { queryString = "state="+JSON.stringify(currentState); $.ajax({ url:"/poll", data: queryString, timeout: 60000, success: function(data) { console.log(data); if(currentState == null) { currentState = JSON.parse(data); } else { console.log("A change has occurred"); } poll(); }, error: function(jqXHR, textStatus, errorThrown) { console.log(jqXHR.status + "," + textStatus + ", " + errorThrown); poll(); } }); }
是否需要多线程?还是有人知道为什么我会遇到这种现象?
flask应用程序只是重载。这是因为在运行时app.run(),flask应用默认情况下处于单线程模式,因此每次只能处理一个请求。
app.run()
你可以使用以下方法启动多线程:
if __name__ == '__main__': app.run(threaded=True)
或使用诸如gunicorn或uwsgi之类的WSGI服务器为烧瓶进行多重处理:
gunicorn -w 4 myapp:app
希望你喜欢使用Python和Flask!