是不是有点low，但功能还是实现了。
2. 前端网页使用websocket建立连接，实时从服务器接收日志。
目前使用第二种方法通过使用flask来实现。
以下简单演示实现过程，从服务器中实时显示日志，可根据实际情况进行修改。
配图，代码参考往下内容1.测试环境python3 使用pip安装以下库Flask==1.1.2gevent==20.9.0gevent-websocket==0.10.12.服务端代码import osimport timeimport loggingfrom gevent import monkeymonkey.patch_all()from gevent.pywsgi import WSGIServerfrom geventwebsocket.handler import WebSocketHandlerfrom geventwebsocket.exceptions import WebSocketErrorfrom flask import Flask, request, render_templatefrom multiprocessing import cpu_count, Processapp = Flask(__name__)def tailf(filename, websocket): """打开文件并把读取内容发给websocket""" with open(filename) as f: # 输出已经存在的文件内容 websocket.send(''.join(f.readlines())) # 移动到了文件EOF处 f.seek(0, 2) while True: line = f.readline() if line: websocket.send(line) else: time.sleep(1)@app.route('/tailf/')def tailf_log(): websocket = request.environ['wsgi.websocket'] # 演示功能这里写死，实际使用可自定义 filename = '/data/ops/20201117/test.log' if os.path.exists(filename): try: tailf(filename, websocket) except WebSocketError as e: logging.info('error {} websocket Closed!'.format(e)) websocket.close() return 'ok' else: websocket.send('<h3>查看的文件不存在!</h3>')@app.route('/')def index(): return render_template('index.html')# 日志配置logging.basicConfig( filename='logs.log', format='%(asctime)s %(levelname)s: %(message)s', level='INFO')# 实例化 这里包括监听端口ws_server = WSGIServer( ('0.0.0.0', 5000), app, log=logging, handler_class=WebSocketHandler,)ws_server.start()def serve_forever(): try: ws_server.start_accepting() ws_server._stop_event.wait() except KeyboardInterrupt: ws_server.stop()if __name__ == "__main__": # 用multiprocessing配合gevent来启动多进程 for i in range(cpu_count()): p = Process(target=serve_forever) p.start()3.前端代码（需要引入jquery.min.js）<!doctype html><html lang="en"><head> <title>实时日志查看</title> <!-- jQuery 3 --> <script src="{{ url_for('static', filename='jquery/dist/jquery.min.js') }}"></script></head><body><div class="container"> <div id="log_id" style="height: 95vh; overflow-y: scroll;padding: 10px;"> <pre></pre> </div></div><script> var ws_scheme = window.location.protocol === "https:" ? "wss" : "ws"; var socket = new WebSocket(ws_scheme + '://' + "192.168.209.222:5000/tailf/"); var log_id = $("#log_id"); var log_pre_id = $("#log_id pre"); socket.onopen = function () { socket.onmessage = function (msg) { log_pre_id.append(msg.data); // 滚动条滚动到最低部 log_id.scrollTop(log_pre_id.height() - log_id.height()); }; }; socket.onerror = function () { log_pre_id.innerHTML = '<h3>连接websocket失败!</h3>'; }; window.onbeforeunload = function (event) { console.log("关闭WebSocket连接！"); socket.close(); }</script></body></html>4.运行代码进行测试在服务器上模拟定时输出信息到日志文件for i in $(seq 1 1000);do echo -e “$i —————-” >> /data/ops/20201117/test.log;sleep 1;done在浏览器打开网页实时查看PS： 我比较好奇在头条发这一类文章有没有流量的，毕竟在这里的大部分以手机端娱乐为主
欢迎分享，转载请注明来源：内存溢出
微信扫一扫
支付宝扫一扫
评论列表（0条）