余晖落尽暮晚霞,黄昏迟暮远山寻
本站
当前位置:网站首页 > 编程知识 > 正文

Flask-SocketIO 简单使用指南(flask-socketio 开启多线程)

xiyangw 2022-12-03 12:56 68 浏览 0 评论

Flask-SocketIO 使 Flask 应用程序能够访问客户端和服务器之间的低延迟双向通信。客户端应用程序可以使用 Javascript,C ++,Java 和 Swift 中的任何 SocketIO 官方客户端库或任何兼容的客户端来建立与服务器的永久连接。

安装

直接使用 pip 来安装:

pip install flask-socketio

要求

Flask-SocketIO 兼容 Python 2.7 和 Python 3.3+。可以从以下三个选项中选择此程序包所依赖的异步服务:

  • eventlet 性能最佳,支持长轮询和 WebSocket 传输。

  • gevent 在许多不同的配置中得到支持。gevent 包完全支持长轮询传输,但与 eventlet 不同,gevent 没有本机 WebSocket 支持。要添加对 WebSocket 的支持,目前有两种选择:安装 gevent-websocket 包为 gevent 增加 WebSocket 支持,或者可以使用带有 WebSocket 功能的 uWSGI Web 服务器。gevent 的使用也是一种高性能选项,但略低于 eventlet。

  • 也可以使用基于 Werkzeug 的 Flask 开发服务器,但需要注意的是,它缺乏其他两个选项的性能,因此它只应用于简单的开发环境。此选项仅支持长轮询传输。

扩展会根据安装的内容自动检测要使用的异步框架。优先考虑 eventlet,然后是 gevent。对于 gevent 中的WebSocket 支持,首选 uWSGI,然后是 gevent-websocket。如果既未安装 eventlet 也未安装 gevent,则使用 Flask 开发服务器。

如果使用多个进程,则进程使用消息队列服务来协调诸如广播之类的操作。支持的队列是 Redis,RabbitMQ以及 Kombu 软件包支持的任何其他消息队列 。

在客户端,官方 Socket.IO Javascript 客户端库可用于建立与服务器的连接。还有使用 Swift,Java 和 C ++ 编写的官方客户端。非官方客户端也可以工作,只要它们实现 Socket.IO协议。

初始化

以下代码示例演示如何将 Flask-SocketIO 添加到 Flask 应用程序:

from flask import Flask, render_template
from flask_socketio import SocketIO

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

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

以上代码即完成了一个简单的 Web 服务器。

socketio.run()函数封装了 Web 服务器的启动,并替换了app.run()标准的 Flask 开发服务器启动。

当应用程序处于调试模式时,Werkzeug 开发服务器仍然在内部使用和配置正确socketio.run()。

在生产模式中,如果可用,则使用 eventlet Web 服务器,否则使用 gevent Web 服务器。如果未安装 eventlet 和gevent,则使用 Werkzeug 开发 Web 服务器。

基于 Flask 0.11 中引入的单击的命令行界面。此扩展提供了适用于启动 Socket.IO 服务器的新版本命令。用法示例:flask run

$ FLASK_APP=my_app.py flask run

或者直接使用下面方式,也可以启动项目:

$ python2.7 app.py

连接事件

Flask-SocketIO 调度连接和断开事件。以下示例显示如何为它们注册处理程序:

@socketio.on('connect', namespace='/test')
def test_connect():
 emit('my response', {'data': 'Connected'})

@socketio.on('disconnect', namespace='/test')
def test_disconnect():
 print('Client disconnected')

连接事件处理程序可以选择返回False以拒绝连接。这样就可以在此时对客户端进行身份验证。

请注意,连接和断开连接事件将在使用的每个命名空间上单独发送。

接收消息

使用 SocketIO 时,双方都会将消息作为事件接收。在客户端使用 Javascript 回调。使用 Flask-SocketIO,服务器需要为这些事件注册处理程序,类似于视图函数处理路由的方式。

以下示例为未命名的事件创建服务器端事件处理程序:

@socketio.on('message')
def handle_message(message):
 print('received message: ' + message)

上面的示例使用字符串消息。另一种类型的未命名事件使用 JSON 数据:

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

最灵活的方式是使用自定义事件名称,在开发过程中最常用的也是这种方式。

事件的消息数据可以是字符串,字节,整数或 JSON:

@socketio.on('my event')
def handle_my_custom_event(json):
 print('received json: ' + str(json))

自定义命名事件也可以支持多个参数:

@socketio.on('my event')
def handle_my_custom_event(arg1, arg2, arg3):
 print('received args: ' + arg1 + arg2 + arg3)

Flask-SocketIO 支持 SocketIO 命名空间,允许客户端在同一物理套接字上复用多个独立连接:

@socketio.on('my event', namespace='/test')
def handle_my_custom_namespace_event(json):
 print('received json: ' + str(json))

如果未指定名称空间,'/'则使用具有名称的默认全局名称空间 。

对于装饰器语法不方便的情况,on_event可以使用该方法:

def my_function_handler(data):
 pass

socketio.on_event('my event', my_function_handler, namespace='/test')

客户端可以请求确认回叫,确认收到他们发送的消息。处理函数返回的任何值都将作为回调函数中的参数传递给客户端:

@socketio.on('my event')
def handle_my_custom_event(json):
 print('received json: ' + str(json))
 return 'one', 2

在上面的示例中,将使用两个参数调用客户端回调函数,'one'和2。如果处理程序函数未返回任何值,则将调用客户端回调函数而不带参数。

发送消息

如上一节所示定义的 SocketIO 事件处理程序可以使用send()和emit() 函数将回复消息发送到连接的客户端。

以下示例将收到的事件退回给发送它们的客户端:

from flask_socketio import send, emit

@socketio.on('message')
def handle_message(message):
 send(message)

@socketio.on('json')
def handle_json(json):
 send(json, json=True)

@socketio.on('my event')
def handle_my_custom_event(json):
 emit('my response', json)

注意如何send()和emit()分别用于无名和命名事件。

当有命名空间的工作,send()并emit()默认使用传入消息的命名空间。可以使用可选namespace参数指定不同的命名空间:

@socketio.on('message')
def handle_message(message):
 send(message, namespace='/chat')

@socketio.on('my event')
def handle_my_custom_event(json):
 emit('my response', json, namespace='/chat')

要发送具有多个参数的事件,请发送元组:

@socketio.on('my event')
def handle_my_custom_event(json):
 emit('my response', ('foo', 'bar', json), namespace='/chat')

SocketIO 支持确认回调,确认客户端收到了一条消息:

def ack():
 print 'message was received!'

@socketio.on('my event')
def handle_my_custom_event(json):
 emit('my response', json, callback=ack)

使用回调时,Javascript 客户端会收到一个回调函数,以便在收到消息时调用。客户端应用程序调用回调函数后,服务器将调用相应的服务器端回调。如果使用参数调用客户端回调,则这些回调也作为服务器端回调的参数提供。

广播

SocketIO 的另一个非常有用的功能是广播消息。SocketIO 支持通过此功能broadcast=True可选参数send()和emit():

@socketio.on('my event')
def handle_my_custom_event(data):
 emit('my response', data, broadcast=True)

在启用广播选项的情况下发送消息时,连接到命名空间的所有客户端都会接收它,包括发件人。如果未使用名称空间,则连接到全局名称空间的客户端将收到该消息。请注意,不会为广播消息调用回调。

在此处显示的所有示例中,服务器响应客户端发送的事件。但对于某些应用程序,服务器需要是消息的发起者。这对于向客户端发送通知在服务器中的事件(例如在后台线程中)非常有用。socketio.send()和socketio.emit()方法可用于广播到所有连接的客户端:

def some_function():
 socketio.emit('some event', {'data': 42})

请注意,socketio.send()与socketio.emit()在上下文理解上和send()与emit()功能不同。另请注意,在上面的用法中没有客户端上下文,因此broadcast=True是默认的,不需要指定。

房间

对于许多应用程序,有必要将用户分组为可以一起寻址的子集。最好的例子是具有多个房间的聊天应用程序,其中用户从他们所在的房间接收消息,而不是从其他用户所在的其他房间接收消息。SocketIO 支持通过房间的概念join_room()和leave_room()功能:

from flask_socketio import join_room, leave_room

@socketio.on('join')
def on_join(data):
 username = data['username']
 room = data['room']
 join_room(room)
 send(username + ' has entered the room.', room=room)

@socketio.on('leave')
def on_leave(data):
 username = data['username']
 room = data['room']
 leave_room(room)
 send(username + ' has left the room.', room=room)

在send()和emit()函数接受一个可选room导致被发送到所有的都在定房客户端的消息的说法。

所有客户端在连接时都会被分配一个房间,以连接的会话ID命名,可以从中获取request.sid。给定的客户可以加入任何房间,可以给出任何名称。当客户端断开连接时,它将从其所在的所有房间中删除。无上下文socketio.send() 和socketio.emit()函数也接受一个room参数,以广播给房间中的所有客户端。

由于为所有客户端分配了个人房间,为了向单个客户端发送消息,客户端的会话 ID 可以用作房间参数。

错误处理

Flask-SocketIO还可以处理异常:

@socketio.on_error() # Handles the default namespace
def error_handler(e):
 pass

@socketio.on_error('/chat') # handles the '/chat' namespace
def error_handler_chat(e):
 pass

@socketio.on_error_default # handles all namespaces without an explicit error handler
def default_error_handler(e):
 pass

错误处理函数将异常对象作为参数。

还可以使用request.event变量检查当前请求的消息和数据参数,这对于事件处理程序外部的错误记录和调试很有用:

from flask import request

@socketio.on("my error event")
def on_my_event(data):
 raise RuntimeError()

@socketio.on_error_default
def default_error_handler(e):
 print(request.event["message"]) # "my error event"
 print(request.event["args"]) # (data,)

基于类的命名空间

作为上述基于装饰器的事件处理程序的替代,属于命名空间的事件处理程序可以创建为类的方法。flask_socketio.Namespace作为基类提供,用于创建基于类的命名空间:

from flask_socketio import Namespace, emit

class MyCustomNamespace(Namespace):
 def on_connect(self):
 pass

 def on_disconnect(self):
 pass

 def on_my_event(self, data):
 emit('my_response', data)

socketio.on_namespace(MyCustomNamespace('/test'))

使用基于类的命名空间时,服务器接收的任何事件都将调度到名为带有on_前缀的事件名称的方法。例如,事件my_event将由名为的方法处理on_my_event。如果收到的事件没有在命名空间类中定义的相应方法,则忽略该事件。基于类的命名空间中使用的所有事件名称必须使用方法名称中合法的字符。

为了方便在基于类的命名空间中定义的方法,命名空间实例包括类中的几个方法的版本,flask_socketio.SocketIO当namespace没有给出参数时,这些方法 默认为正确的命名空间。

如果事件在基于类的命名空间中具有处理程序,并且还有基于装饰器的函数处理程序,则仅调用修饰的函数处理程序。

测试

以上是作为官网文档的翻译,下面来说说写完了代码之后,应该怎么来调试。

<script type="text/javascript" src="//cdnjs.cloudflare.com/ajax/libs/socket.io/1.3.6/socket.io.min.js"></script>
<script type="text/javascript" charset="utf-8">
 var socket = io.connect('http://' + document.domain + ':' + location.port);
 socket.on('connect', function() {
 socket.emit('my event', {data: 'I\'m connected!'});
 });
</script>

使用 JavaScript 来连接服务端,这里说一个我遇到的问题,最开始使用的是 jsbin 来测试,但怎么都连不到后端,原因就是 jsbin 是 HTTPS 的,而我的请求是 HTTP,于是还是老老实实写了一个 HTML 文件,源码可以直接在 Github 下载。

<!DOCTYPE HTML>
<html>
<head>
 <title>Flask-SocketIO Test</title>
 <script type="text/javascript" src="//code.jquery.com/jquery-1.4.2.min.js"></script>
 <script type="text/javascript" src="//cdnjs.cloudflare.com/ajax/libs/socket.io/1.3.5/socket.io.min.js"></script>
 <script type="text/javascript" charset="utf-8">
 $(document).ready(function() {
 namespace = '/test';
 var socket = io.connect(location.protocol + '//' + document.domain + ':' + location.port + namespace);

 socket.on('connect', function() {
 socket.emit('my_event', {data: 'I\'m connected!'});
 });
 
 socket.on('my_response', function(msg) {
 $('#log').append('<br>' + $('<div/>').text('Received #' + msg.count + ': ' + msg.data).html());
 });

 $('form#emit').submit(function(event) {
 socket.emit('my_event', {data: $('#emit_data').val()});
 return false;
 });
 });
 </script>
</head>
<body>
 <h1>Flask-SocketIO Test</h1>
 <p>Async mode is: <b>{{ async_mode }}</b></p>
 <h2>Send:</h2>
 <form id="emit" method="POST" action='#'>
 <input type="text" name="emit_data" id="emit_data" placeholder="Message">
 <input type="submit" value="Echo">
 </form>
 <h2>Receive:</h2>
 <div id="log"></div>
</body>
</html>

有了这个页面之后,就可以直接在浏览器中输入 http://127.0.0.1:5000 访问服务端了,更多功能可以随意折腾。

相关文档:

https://github.com/miguelgrinberg/Flask-SocketIO

https://flask-socketio.readthedocs.io/en/latest/

http://windrocblog.sinaapp.com/?p=1628

https://zhuanlan.zhihu.com/p/31118736

https://letus.club/2016/04/10/python-websocket/


相关推荐

高效删除文件名中的指定内容,祛除烦恼

如何快速批量删除文件名中的指定字符?在电脑整理文件时,我们常常需要进行批量重命名操作。如果文件名中含有不必要或重复的字符,这将影响文件的识别和查找。因此,删除这些文字或字符是非常必要且有效的。本文将分...

你的手机是不是经常提示存储空间不足?Python帮你清理重复文件

  最近我的手机经常提示存储空间不足,主要是微信和QQ群里接收的文件太多了,平时也没怎么整理。我把这些文件从手机里拷出来,打算整理一下,把该删的文件都删掉,把要备份的文件分门别类存到电脑或网盘上。我突...

从零开始打造云端AI管理调度平台(四)如何设计主页_1

最近闲来无事,想着把自己工作正在做的一个项目做一个简单的分享与实战教程,该项目不困难但是由于涉及要素过多所以比较复杂。所以这里分享出来也是为了帮助新手小白能在实战当中快速了解python知识。主要内容...

「万能Python」-17-标准库OS_python2.7标准库

Python的库是指预先编写好的代码集合,可以用来处理特定的任务或实现特定的功能。Python的标准库提供了许多常用的标准库,无需安装引入使用。Python3的标准库提供了许多常用的功能,包括...

十多行代码生成原帖和临写对照图_几十行代码可以申请软著吗

介绍这个小工具把原帖和临写分解成多列对照的形式。输入原帖图片,和输入临写图片,生成对照图片。使用说明运行compare.py文件,输入参数为:原帖图片文件名,临写图片文件名,列数。python3co...

Python合集之目录操作(四)_python之文件操作大全

1.删除目录删除目录可以通过os模块提供的rmdir()函数实现。通过rmdir()函数删除目录时,只有当要删除的目录为空时才起作用。os.rmdir(path)path为要删除的目录,可以使用绝对路...

excel办公自动化,自动合并excel表格

平时时收到不同人反馈的excel表格,需要将其合并在一个excel中,每个excel打开复制粘贴会很慢,如下脚本可一键合并所有的exceldefauto_merge():try:print('...

批量打开一个文件夹下面所有的excel表格

如果现在有一个文件夹,名称叫做“练习表格”,路径名是'C:\Users\123\Desktop\练习表格',现在的要求是打开这个文件下面所有的excel表格,后缀名字为“xlsx”,我...

500行代码,教你用python写个微信飞机大战

这几天在重温微信小游戏的飞机大战,玩着玩着就在思考人生了,这飞机大战怎么就可以做的那么好,操作简单,简单上手。帮助蹲厕族、YP族、饭圈女孩在无聊之余可以有一样东西让他们振作起来!让他们的左手/右手...

python 日志写入_python日志文件写入

1.第一步,新建日志文件路径,如下图:2.日志模块封装,代码如下:importlogging,oslogs_path=os.path.join(os.path.dirname(__file...

Python os.path模块使用指南:轻松处理文件路径

前言在Python编程中,文件和目录的操作是非常重要的一部分。为了方便用户进行文件和目录的操作,Python标准库提供了os模块。其中,os.path子模块提供了一些处理文件路径的函数和方法。本文主要...

Python中获取当前路径之pathilb和os的区别

20230114星期六:1,直接在py脚本中,执行,没有区别;2,打包成exe文件以后,在本机执行,有区别,这时,不能使用os.path.dirname(__file__),只能使用pathlib.P...

Python(办公自动化编程系列)学习笔记1

1、获得当前程序工作目录importos#os.getcwd()函数可以取得当前工作路径的字符串print(os.getcwd())运行结果2、获得程序文件夹相对路径#相对路径都用/表示#../...

文件路径名Pathnames的操作_路径和文件名是什么意思

1.现象问题使用路径名来获取文件名,目录名,绝对路径等等2.原因分析无3.问题解决使用os.path模块中的函数来操作路径名importos.path#查看标准化的绝对路径print...

关于《Python入门:os常用函数》中复制文件(夹)函数从简到繁

基本考虑练习os模块及file读写操作:将给定的源路径的文件(夹)复制到目标路径简单实现#文件到文件的复制path_src='E:\src.txt'path_tar='D...

取消回复欢迎 发表评论: