python - Flask socket IO 从另一个模块发出
问题描述
我几乎阅读了互联网上的每一篇文章,但似乎对我的情况没有任何帮助。我已经安装了 flask-socketio 并且一切正常,直到我从 app.py 以外的模块发出消息。
我已经尝试了几种方法来实现这一点,并且我还通过使用 Redis 在文档中阅读了它,但它也对我不起作用。这是我拥有的代码片段。
应用程序.py
from flask import Flask
from flask import request
from flask_socketio import send, SocketIO, emit, join_room
app = Flask(__name__)
# This is to stop force sorting in response, by default jsonify sorts the response keys alphabetically
app.config["JSON_SORT_KEYS"] = False
socketio = SocketIO(app, cors_allowed_origins="*")
@socketio.on('join')
def client_join_room(data):
print(type(data))
room = data['room']
join_room(room)
send('you have entered the room.', room=room)
@app.route('/msg')
def send_message():
socketio.emit("message", "Server message", room='my_room')
return "I got you."
if __name__ == '__main__':
socketio.run(host="0.0.0.0", port=5001, debug=True, app=app)
我的模块.py
def some_method():
import app
app.socketio.emit("message", "Some information about process", room='my_room', broadcast=True)
请注意,我在方法中导入了应用程序,因为app.py
也导入了my_module.py
我可以加入房间。
当我调用 localhost:5001/msg 时,它确实会发送到“my_room”。
发射在 my_module.py 中不起作用,我不知道为什么。
我正在安慰从前端服务器收到的消息,因此我可以确定收到哪些消息,哪些没有收到。
此外,some_method()
此处由来自 app.py 的 API 请求调用。以防万一是否相关。
我设置了 logger=True ,然后每次发出调用都会在终端上打印此消息。即使里面有一个some_method()
向 my_room [/] 发送事件“消息”
这是否意味着实际发送了消息?如果是,那么为什么我没有在前端的 jquery 中得到它。
这就是我在 html 页面中所做的
$(document).ready(function () {
// start up the SocketIO connection to the server
var socket = io.connect('http://localhost:5001/');
// this is a callback that triggers when the "message" event is emitted by the server.
socket.on('message', function(msg){
console.log(msg)
});
socket.emit('join', {room: 'my_room'});
});
解决方案
请尝试安装 Redis 和 eventlet 以进行异步调用并从其他模块发送消息。如文档中所述,您可以将 app.py 中的行更改为
socketio = SocketIO(app, cors_allowed_origins="*", message_queue='redis://', async_mode='eventlet')
推荐阅读
- javascript - 当 Vue.js 中我的对象中存在属性时有条件地显示块?
- microsoft-edge-extension - 将浏览器扩展上传到 Microsoft 合作伙伴中心
- javascript - 在 Safari IOS 上滚动时更新 scrollLeft / scrollTop 不起作用
- python - Python 计时器类:跟踪状态?
- python - 在python的多线程中,如何产生结果并返回线程值?
- image - 如何从谷歌驱动器 url 获取图片文件名?
- javascript - 数字越大的二叉树在树中越高
- c# - 使用 async/await 和 ContinueWith 时捕获异常
- wordpress - 如何摆脱导致我的域错误的firebase证书?
- qt - 如何使用 QAction 正确添加 QMenu(和子菜单)