# encoding:utf-8
# !/usr/bin/env python
import psutil
import time
from threadingimport Lock
from flaskimport Flask, render_template
from flask_socketioimport SocketIO
import pandasas pd
import MySQLdb
async_mode =None
app = Flask(__name__)
app.config['SECRET_KEY'] ='secret!'
socketio = SocketIO(app,async_mode=async_mode)
thread =None
thread_lock = Lock()
# 后台线程 产生数据，即刻推送至前端
def background_thread():
count =0
lastvalue=0
t=0
cpu=0
amount=0
while True:
count +=1
import numpyas np
t=t +1
n=np.random.randn()
cpu= n*10 if n>0 else 2
amount=amount + np.random.randn()*10 if np.random.randn()>0 else amount+13
socketio.emit('server_response',
{'data': [t,int(cpu),amount,lastvalue],'count': count},
namespace='/test')
socketio.emit('server_response2',
{'data': [0,int(cpu),amount],'count': count},
namespace='/test')
lastvalue = amount
socketio.sleep(2)
# 注意：这里不需要客户端连接的上下文，默认 broadcast = True
@app.route('/')
def index():
return render_template('index.html',async_mode=socketio.async_mode)
@socketio.on('connect',namespace='/test')
def test_connect():
global thread
with thread_lock:
if threadis None:
thread = socketio.start_background_task(target=background_thread)
if __name__ =='__main__':
socketio.run(app,debug=True,port=5028,host='0.0.0.0')
