python - 在烧瓶应用程序 socketIO 脚本期间服务器等待
问题描述
我正在尝试在烧瓶 Web 套接字应用程序的服务器端脚本中创建时间延迟。
最终,我希望服务器能够同时处理许多请求,并且能够以固定的时间间隔向客户端发送两个数据包。
当我time.sleep(x)
在两个flask_socketio.emit
语句之间使用时,客户端在睡眠完成后一起接收套接字发出事件。
如何Emit X; wait Y seconds; emit Z
在 python 烧瓶应用程序中实现?
服务器端代码摘录:
from flask import Flask, request
from flask_socketio import SocketIO, join_room, emit
app = Flask(__name__)
socketio = SocketIO(app)
@socketio.on('ping')
def ping(appState):
"""send 2 pings, between a time interval"""
room = appState["sessionID"]
emit('serverPingResponse', {'room': room, 'msg':"Ping Received by Server"})
time.sleep(5)
emit('serverPingResponse', {'room': room, 'msg':"2nd time-delayed ping"})
return
客户端代码摘录:
var socket = io.connect('http://' + document.domain + ':' + location.port);
socket.on("serverPingResponse", function(msg){
// listen to server ping and print the message to console
let d = new Date();
console.log("ping received at "+d.toLocaleTimeString(), msg)
});
控制台输出
pinging server...
ping received at 10:43:14 AM
Object { room: "wvdhj01f3p", msg: "Ping Received by Server" }
ping received at 10:43:14 AM
Object { room: "wvdhj01f3p", msg: "2nd time-delayed ping" }
期望的输出是第一个 ping 被接收,10:43:09
第二个ping10:43:14
解决方案
您正在使用该time.sleep()
功能,我猜它正在阻止您的服务器。尝试socketio.sleep()
改用,这将与您正在使用的异步框架(eventlet,gevent)兼容。
推荐阅读
- javascript - Why I cannot use an array with a set in javascript?
- javascript - 使用 Javascript 添加和显示列的内容
- ios - Ad Hoc iOS App 分发到数百台设备
- xml - Using PowerShell how do I overwrite existing data in an XML Node
- javascript - 如何使用 ES5 解构数组?
- highcharts - 图例项目图案旋转或镜像问题
- linux - 具有多个 OR 的 Linux 查找命令
- sql-server - SQL convert NVARCHAR from one date format to another
- mysql - SQL - values from one table column to another table column
- reactjs - useState 的时间是什么时候保存的?