Python使用flask框架与前端建立websocket链接，并进行数据交互
后端采用的框架为flask，前端用的flask自带的html编写，实现的功能为：前后端建立websocket链接并进行数据交互
一、编写一个flask后端服务
常规创建方式就可以，创建一个flask服务。声明一个websocket实例，以websocket的方式启动这个服务。
- 安装相关依赖：
pip install flask
pip install flask_socketio
- 声明应用和websocket实例
from flask import Flask, request, render_template
from flask_socketio import SocketIO, emit
# 声明应用
app = Flask(__name__)
# 为通讯添加一个密钥
app.config['SECRET_KEY'] = 'secret_key'
# 创建websocket实例
my_socket = SocketIO(app)
- 项目目录下新建temlpates文件夹，然后文件夹里新建index.html文件，内容信息，我们稍后补充，先有这个东西就行。
- 编写接口信息。编写接口信息的时候要添加websocket通讯的相关方法。
# 声明访问页面信息
@app.route('/')
def index():
# 这里是进行了flask前端模板的渲染，文件就是我们上面建的那个，只写文件名称就可以，框架内部是默认访问temlpates目录的
return render_template('index.html')
新建一个websocket推送接口，使用 emit() 方法推送信息到到前端。然后声明几个websocket建立过程中用到的方法。关于 emit() 的使用，后面讲。
# 数据推送接口，后面调这个接口模拟数据发送
@app.route('/send_msg', methods=['post'])
def receive_source():
"""
推送数据
:return:
"""
try:
my_socket.emit('date', request.json, namespace='/')
return 'success'
except Exception as e:
log.error(f'数据处理错误：{
str(e)}')
return 'failed'
# 当websocket链接建立的时候，会调用这个
@my_socket.on('connect')
def handle_connect():
print('WebSocket 链接已经建立')
# 关闭用
@my_socket.on('disconnect')
def handle_disconnect():
print('WebSocket 链接已经关闭')
# 发送信息用
@my_socket.on('message')
def handle_message(data):
emit('msg', data, namespace='/')
- 以websocket的方式启动服务（填写完后面的html代码后启动）
if __name__ 
