flask 之 在flask中使用websocket


一、介紹

復制代碼
# 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


免責聲明!

本站轉載的文章為個人學習借鑒使用,本站對版權不負任何法律責任。如果侵犯了您的隱私權益,請聯系本站郵箱yoyou2525@163.com刪除。



 
粵ICP備18138465號   © 2018-2025 CODEPRJ.COM