一、自动发消息
Flask-SocketIO 可以自动将消息推送给所有已连接的客户端。需要使用 emit() 函数，并在客户端打开 SocketIO 时，使用 socket.on() 函数来监听消息。示例代码如下：
from flask_socketio import SocketIO, emit
from flask import Flask, render_template
app = Flask(__name__)
app.config['SECRET_KEY'] = 'mysecret'
socketio = SocketIO(app)
@app.route('/')
def index():
return render_template('index.html')
@socketio.on('message')
def handle_message(msg):
emit('response', msg, broadcast=True)
if __name__ == '__main__':
socketio.run(app)
在客户端中，需要使用 SocketIO 的 on() 函数监听服务器发送的消息，并使用 emit() 函数向服务器发送消息。示例代码如下：
var socket = io.connect('http://' + document.domain + ':' + location.port);
socket.on('response', function(msg) {
console.log('Got a message:', msg);
});
socket.emit('message', 'Hello, World!');
二、单独聊天
除了向所有已连接的客户端广播消息之外，Flask-SocketIO 还支持单独聊天功能，这就意味着服务器和客户端之间可以私密聊天。示例代码如下：
@socketio.on('private_message')
def handle_private_message(msg):
emit('response', msg['message'], room=msg['room'], include_self=False)
@socketio.on('join')
def handle_join(room):
join_room(room)
emit('response', 'In rooms: ' + ', '.join(list(rooms())), room=room)
@socketio.on('leave')
def handle_leave(room):
leave_room(room)
emit('response', 'In rooms: ' + ', '.join(list(rooms())), room=room)
上面代码中，handle_private_message() 函数接收一个带有目标房间和消息的字典，使用 room 参数指定目标房间，使用 include_self 参数指定是否向自己推送消息。
除此之外，还有两个监听函数，handle_join() 和 handle_leave()，一个是加入房间，一个是离开房间。示例代码如下：
socket.emit('join', room='room1');
socket.emit('private_message', { 'room': 'room1', 'message': 'hello' });
socket.emit('leave', room='room1');
三、连接多个客户端
Flask-SocketIO 可以连接多个客户端。需要使用 Connection() 函数，并在客户端打开 SocketIO 时，使用 namespace 参数指定房间名称。示例代码如下：
from flask_socketio import SocketIO, Connection
from flask import Flask, render_template
app = Flask(__name__)
app.config['SECRET_KEY'] = 'mysecret'
socketio = SocketIO(app)
@app.route('/')
def index():
return render_template('index.html')
@socketio.on_namespace('/chat')
class ChatNamespace(Connection):
def on_connect(self):
print('Connected: ', self.sid)
def on_disconnect(self):
print('Disconnected: ', self.sid)
def on_message(self, data):
self.emit('response', 'You said: ' + data)
if __name__ == '__main__':
socketio.run(app)
在客户端中，需要使用 io() 函数指定房间名称，并使用 namespace 参数指定命名空间。示例代码如下：
var socket = io('http://' + document.domain + ':' + location.port + '/chat');
socket.on('connect', function() {
console.log('Connected:', socket.id);
});
socket.on('disconnect', function() {
console.log('Disconnected:', socket.id);
});
socket.on('response', function(msg) {
console.log('Got a message:', msg);
});
socket.emit('message', 'Hello, World!');
四、Flask-SocketIO 的坑
使用 Flask-SocketIO 的过程中，可能会遇到一些坑，需要注意。比如说：
- 不能使用 Flask 的
request对象，而应该使用 Flask-SocketIO 提供的socketio对象，如：socketio.emit('response', {'data': 'your data'}, namespace='/chat') - 事件名称要正确，不要拼写错误或大小写错误，事件名称大小写敏感。
- Vues.js 绑定事件时必须使用
v-on指令绑定，而不能使用@缩写。
五、多个主机
Flask-SocketIO 允许多个主机之间进行实时通信。需要使用 emit() 函数，并在客户端打开 SocketIO 时，使用 socketIO() 函数指定主机地址。示例代码如下：
from flask_socketio import SocketIO, emit
from flask import Flask, render_template
app = Flask(__name__)
app.config['SECRET_KEY'] = 'mysecret'
socketio = SocketIO(app)
@app.route('/')
def index():
return render_template('index.html')
@socketio.on('message')
def handle_message(msg):
emit('response', msg, broadcast=True)
if __name__ == '__main__':
socketio.run(app, host='0.0.0.0', port=5000)
在客户端中，需要使用 socketIO() 函数指定主机地址。示例代码如下：
var socket = io.connect('http://192.168.1.100:5000');
六、Vue 框架中使用 Flask-SocketIO
在 Vue 框架中使用 Flask-SocketIO，需要先安装 vue-socket.io 包，通过 $ npm install vue-socket.io --save 命令安装。
接下来，在 main.js 中使用 Vue.use() 将其挂载到 Vue 实例中，然后在组件中使用 this.$socket.emit() 向服务器发送消息，并使用 this.$socket.on() 函数监听服务器发送的消息。示例代码如下：
import VueSocketIO from 'vue-socket.io';
import Vue from 'vue';
Vue.use(new VueSocketIO({
debug: true,
connection: 'http://localhost:5000',
}));
export default {
data() {
return {
message: '',
response: '',
}
},
mounted() {
this.$socket.on('response', (msg) => {
this.response = msg;
});
},
methods: {
sendMessage() {
this.$socket.emit('message', this.message);
this.message = '';
}
}
}
七、Flask-SocketIO 反应慢问题
在使用 Flask-SocketIO 过程中，如果出现反应慢的情况，可能是因为服务器配置不够，可以考虑使用异步模式。
使用异步模式需要使用 eventlet 包，并使用 monkey_patch() 函数进行补丁。示例代码如下：
from flask_socketio import SocketIO, emit
from flask import Flask, render_template
import eventlet
app = Flask(__name__)
app.config['SECRET_KEY'] = 'mysecret'
socketio = SocketIO(app, async_mode='eventlet')
eventlet.monkey_patch()
@app.route('/')
def index():
return render_template('index.html')
@socketio.on('message')
def handle_message(msg):
emit('response', msg, broadcast=True)
if __name__ == '__main__':
socketio.run(app)
八、Flask-SocketIO 可以用于客户端服务器架构吗
Flask-SocketIO 可以用于客户端服务器架构，可以帮助开发者搭建实时通信的系统。在服务端，使用 Flask-SocketIO 处理客户端请求，将客户端发送的消息实时推送到其他客户端；在客户端，使用 SocketIO 接受服务端的推送消息。
基于 Flask-SocketIO 的客户端服务器架构可以用于多个场景，比如聊天室、实时数据可视化等。
总结
本文从多个方面对 Flask-SocketIO 进行了详细阐述，包括自动发消息、单独聊天、连接多个客户端、坑点、多个主机、Vue 框架中使用 Flask-SocketIO、反应慢问题以及应用于客户端服务器架构等。如果你对 Flask-SocketIO 还有不理解的地方，可以通过本文给出的示例代码进行深入学习。
