一、介紹
# websocket是給瀏覽器新建一套協議。協議規定:瀏覽器和服務端連接之后不斷開,以此可以完成:服務端向客戶端主動推送消息。 # websocket協議額外做的一些前天操作: # - 握手,連接前進行校驗 # - 發送數據加密 # pip3 install gevent-websocket from geventwebsocket.handler import WebSocketHandler from gevent.pywsgi import WSGIServer from flask import Flask,render_template,request import pickle app = Flask(__name__) app.secret_key = 'xfsdfqw'
@app.route('/index') def index(): return render_template('index.html')
WS_LIST = [] @app.route('/test') def test(): ws = request.environ.get('wsgi.websocket') if not ws: return '請使用WebSocket協議' # websocket連接已經成功 WS_LIST.append(ws) while True: # 等待用戶發送消息,並接受 message = ws.receive() # 關閉:message=None if not message: WS_LIST.remove(ws) break for item in WS_LIST: item.send(message) return "asdfasdf"
if __name__ == '__main__': http_server = WSGIServer(('0.0.0.0', 5000,), app, handler_class=WebSocketHandler) http_server.serve_forever()
<!DOCTYPE html> <html lang="zh-cn"> <head> <meta charset="UTF-8"> <meta http-equiv="X-UA-Compatible" content="IE=edge"> <meta name="viewport" content="width=device-width, initial-scale=1"> <title>Title</title> <style> .msg-item{ padding: 5px; border: 1px; margin: 0 5px; } </style> </head> <body> <h1>首頁</h1> <div> <h2>發送消息</h2> <input id="msg" type="text" /> <input type="button" value="發送" onclick="sendMsg()"> <h2>接收消息</h2> <div id="container"> </div> </div> <script src="/static/jquery-3.3.1.min.js"></script> <script> ws = new WebSocket('ws://192.168.12.42:5000/test'); ws.onmessage = function (event) { var tag = document.createElement('div'); tag.className = 'msg-item'; tag.innerText = event.data; $('#container').append(tag); } function sendMsg() { ws.send($('#msg').val()); } </script> </body> </html>
轉於:https://www.cnblogs.com/ltyc/p/14449181.html