flask + websocket消息訂閱
Flask-SocketIO使Flask應(yīng)用程序能夠在客戶端clients 和服務(wù)器server之間實(shí)現(xiàn)低延遲的全雙工通信。 客戶端應(yīng)用程序可以使用JavaScript，C ++，Java和Swift中的任何SocketIO官方客戶端庫或任何兼容的客戶端來建立到服務(wù)器的永久連接。
安裝
pip install flask-socketio
flask項(xiàng)目接入步驟
1、flask啟動文件中 添加websocket配置
方便個人我直接配置在了啟動文件中，大家可以將配置單獨(dú)提出去，規(guī)范代碼結(jié)構(gòu)，當(dāng)前僅做參考。
代碼中 <code># websocket配置內(nèi)容 .... # websocket</code>
from datetime import timedelta
# websocket配置內(nèi)容
from flask import Flask, render_template, request
from flask_socketio import SocketIO, emit
# websocket
from flask_script import Manager
from apps import create_cms_app
from apps.model import db
# 配置初始化文件
app = create_cms_app("apps.settings.DevCMSConfig")
app.permanent_session_lifetime = timedelta(minutes=60 * 24)
# websocket配置內(nèi)容
socketio = SocketIO()
socketio.init_app(app)
name_space = '/io'
@socketio.on('recevice message', namespace=name_space)
def test_message(message):
print('recevice message', message)
# emit('message', {'data': message['data']})
@socketio.on('connect', namespace=name_space)
def connected_msg():
"""客戶端連接"""
print('client connected!', request.sid)
socketio.emit('abcde', 'hello', namespace=name_space)
@socketio.on('disconnect', namespace=name_space)
def disconnect_msg():
"""客戶端離開"""
print('client disconnected!')
@app.route('/push')
def push_once():
event_name = request.args.get("name")
data = request.args.get("msg")
broadcasted_data = {'data': data}
print("publish msg==>", broadcasted_data)
socketio.emit(event_name, broadcasted_data, broadcast=True, namespace=name_space)
return 'send msg successful!'
# websocket
@app.route('/monitor')
def monitor():
"""加載接收消息頁面"""
return render_template('monitor.html')
if __name__ == '__main__':
socketio.run(app)
2、前端數(shù)據(jù)接收 <code>monitor.html</code>
<!DOCTYPE html>
<html lang="en">
<head>
<meta charset="UTF-8">
<title>Socket Demo</title>
<meta name="renderer" content="webkit">
<meta http-equiv="X-UA-Compatible" content="IE=edge,chrome=1">
<meta name="viewport"
content="width=device-width,user-scalable=yes, minimum-scale=0.4, initial-scale=0.8,target-densitydpi=low-dpi"/>
<script type="text/javascript" src="http://cdn.bootcss.com/jquery/3.1.1/jquery.min.js"></script>
<script type="text/javascript" src="http://cdn.bootcss.com/socket.io/1.5.1/socket.io.min.js"></script>
</head>
<body>
<div id='monit'>
</div>
<div id='monit1'>
</div>
</body>
<script>
$(document).ready(function () {
namespace = '/io';
var socket = io.connect(location.protocol + '//' + document.domain + ':' + location.port + namespace);
socket.on('message', function (res) {
console.log(res.data)
var t = res.data;
if (t) {
{#$("#t").append(t).append('<br/>');#}
$("#monit").html(t);
}
});
socket.on('message2', function (res) {
console.log(res.data)
var t = res.data;
if (t) {
{#$("#t").append(t).append('<br/>');#}
$("#monit1").html(t);
}
});
});
</script>
</html>
3、Python腳本接入-- <code>模擬消息推送</code>
import requests, time, random
from multiprocessing import Process
def push_msg(msg, name):
html = requests.get("http://127.0.0.1:5000/push?msg=%s&name=%s" % (msg, name))
print(html.text)
if __name__ == '__main__':
# 模擬推送多條消息
re = []
re2 = []
for i in range(1, 100):
p1 = Process(target=push_msg, args=('--------------' + str(i), 'message'))
re.append(p1)
for i in range(1, 100):
p2 = Process(target=push_msg, args=('--------------' + str(i), 'message2'))
re2.append(p2)
e = re + re2
random.shuffle(e)
for i in e:
time.sleep(1)
i.start()
