Flask-socketio不接收来自客户端的消息

我正在尝试编写一个基本的Socket.io程序,其中python客户端(python-socketio [asyncio_client] 4.6.0)向烧瓶服务器发出单个字符串消息(使用flask-SocketIO 4.3.1和eventlet)

客户端似乎可以正确连接并发送消息,但是在flask服务器上看不到任何输出。

服务器代码:

from flask import flask
from flask_socketio import SocketIO,emit

app = flask(__name__)
app.config['SECRET_KEY'] = 'secret!'
socketio = SocketIO(app)

@socketio.on('connect')
def test_connect():
    print('connected')


@socketio.on('disconnect')
def test_disconnect():
    print('Client disconnected')

@socketio.on('message')
def handle_message(msg):
    print('Recieved',msg)

@socketio.on('json')
def handle_json(json):
    print(str(json))

if __name__ == '__main__':
    socketio.run(app,debug=True)

客户代码:

    import asyncio
    import socketio
    
    sio = socketio.AsyncClient()
    
    @sio.event
    def connect():
        print('connection established')
    
    @sio.event
    def disconnect():
        print('disconnected from server')
    
    async def main():
        await sio.connect('http://localhost:5000')
        await sio.emit('message',data='detection')
        print('message sent')
        await sio.disconnect()
    
    if __name__ == '__main__':
        asyncio.run(main())

服务器输出:

PS C:\Users\daksh\sih\sihPython> python .\test_socketio.py
 * Restarting with stat
 * Debugger is active!
 * Debugger PIN: 101-561-255
(16664) wsgi starting up on http://127.0.0.1:5000
(16664) accepted ('127.0.0.1',59497)
connected
127.0.0.1 - - [23/Jul/2020 20:38:42] "GET /socket.io/?transport=polling&EIO=3&t=1595516920.71801 HTTP/1.1" 200 367 0.004934
Client disconnected
127.0.0.1 - - [23/Jul/2020 20:38:42] "GET /socket.io/?transport=websocket&EIO=3&sid=88790300120f4b899e019ae7cc16ee87&t=1595516922.7757218 HTTP/1.1" 200 0 0.010027

客户端输出:

PS C:\Users\daksh\sih\sihPython> python .\socketio-client.py
connection established
message sent

服务器输出中缺少handle_message()中的打印语句。

我已经在线阅读了多个教程,并且在有和没有命名空间的情况下都尝试过。一直无法找出问题所在。

感谢您的帮助。

(我在Windows 10上使用的是Python 3.8.3)

更新:如果我将客户端代码改为使用socketio.Client()而不是AsyncClient(),则可以使用,但是我需要客户端使用AsyncClient进行连接。 / p>

iCMS 回答:Flask-socketio不接收来自客户端的消息

问题是您的异步​​客户端显然是异步的,您不能只是发送和退出,因为您没有给支持Socket.IO协议的后台任务做时间。

这是客户端的更强大的版本,可让事件在退出前通过:

import asyncio
import socketio

sio = socketio.AsyncClient()

@sio.event
def connect():
    print('connection established')

@sio.event
def disconnect():
    print('disconnected from server')

async def done():
    await sio.disconnect()

async def main():
    await sio.connect('http://localhost:5000')
    await sio.emit('message',data='detection',callback=done)
    print('message sent')
    await sio.wait()

if __name__ == '__main__':
    asyncio.run(main())

这里的窍门是在发出时使用回调。调用回调后,您可以确定邮件已传递,因此可以安全地断开连接。

本文链接:https://www.f2er.com/1877663.html

大家都在问