Flask websocker

来源:https://www.cnblogs.com/py-web/archive/2019/12/10/12016495.html

群聊版 安裝 pipinstallgevent-websocket 視圖 #-*-coding:utf-8-*- importjson fromflaskimportFlask,request,render_template fromgeventwebsocket.handlerimportWebS... ...


群聊版

安裝

pip install gevent-websocket  

 

視圖

  1. # -*- coding: utf-8 -*-  
  2. import json  
  3. from flask import Flask, request, render_template  
  4. from geventwebsocket.handler import WebSocketHandler  # 導入websocker的方法  
  5. from gevent.pywsgi import WSGIServer  
  6.     
  7. app = Flask(__name__)  
  8.     
  9. user_socker_list = []  # 保存所有的websocker對象  
  10.     
  11. @app.route('/ws')  
  12. def ws():  
  13.     # print(request.headers)  
  14.     user_socker = request.environ.get('wsgi.websocket')  # type  WebSocket  
  15.     
  16.     """  
  17.     readyState: 3  連接正常,然後斷開  
  18.     readyState: 1  表示正常連接  
  19.     """  
  20.     if user_socker:  
  21.         user_socker_list.append(user_socker)  
  22.         while 1:  
  23.             msg = user_socker.receive()  # 接收消息  
  24.             print(msg)  # 接受完信息後斷開,所有加迴圈變成長連接  
  25.             for u_socker in user_socker_list:  
  26.                 if u_socker == user_socker:  
  27.                     continue  
  28.                 try:  
  29.                     u_socker.send(msg)  
  30.                 except:  
  31.                     continue  
  32.     
  33.     return render_template('ws.html')  
  34.     
  35.     
  36. if __name__ == '__main__':  
  37.     # app.run(host='0.0.0.'debug=True)  
  38.     http_serv = WSGIServer(('0.0.0.0', 5000), app, handler_class=WebSocketHandler)  
  39.     http_serv.serve_forever()  

 

前端

  1. <!DOCTYPE html>  
  2. <html lang="en">  
  3. <head>  
  4.     <meta charset="UTF-8">  
  5.     <title>ws</title>  
  6. </head>  
  7. <body>  
  8. <input type="text" id="msg"> <button onclick="snd_msm()">發送</button>  
  9.     
  10. <div id="chat_list" style="width: 500px; height: 500px;">  
  11.     
  12. </div>  
  13.     
  14. </body>  
  15.     
  16. <script type="application/javascript">  
  17.     var ws = new WebSocket('ws://192.168.32.71:5000/ws');  {# 設置websocker連接 #}  
  18.     ws.onmessage = function (data) {  
  19.         console.log(data.data);  {# 數據在datadata裡面 #}  
  20.         var ptag = document.createElement('p');  
  21.         ptag.innerText = data.data;  
  22.         document.getElementById('chat_list').appendChild(ptag)  
  23.     
  24.     }; {# 列印收到的數據 #}  
  25.         
  26.     function snd_msm() {  
  27.         var msg = document.getElementById('msg').value;  
  28.         ws.send(msg)  
  29.     }  
  30. </script>  
  31. </html>  

 

一對一單機版

視圖

  1. # -*- coding: utf-8 -*-  
  2. import json  
  3. from flask import Flask, request, render_template  
  4. from geventwebsocket.handler import WebSocketHandler  # 導入websocker的方法  
  5. from gevent.pywsgi import WSGIServer  
  6.     
  7. app = Flask(__name__)  
  8.     
  9. user_socker_dict = {}  # 這裡仿照flask上下文的方式  
  10.     
  11. """  
  12. 借用  
  13. flask 上下文  
  14.     
  15. {  
  16. "線程id": 偏函數,  
  17. "線程id": 偏函數,  
  18. }  
  19. """  
  20.     
  21. @app.route('/ws2/<usename>')  
  22. def ws2(usename):  
  23.     # print(request.headers)  
  24.     user_socker = request.environ.get('wsgi.websocket')  # type  WebSocket  
  25.     
  26.     """  
  27.     readyState: 3  連接正常,然後斷開  
  28.     readyState: 1  表示正常連接  
  29.     """  
  30.     print(user_socker)  
  31.     if user_socker:  
  32.         user_socker_dict[usename] = user_socker  
  33.         print(user_socker_dict)  
  34.         while 1:  
  35.             msg = user_socker.receive()  # 接收人,消息,發送人  
  36.             msg_dict = json.loads(msg)  
  37.             msg_dict['from_user'] = usename  
  38.             to_user = msg_dict.get('to_user')  
  39.             u_socker = user_socker_dict.get(to_user)  # type  WebSocket  
  40.             u_socker.send(json.dumps(msg_dict))  
  41.     
  42.     return render_template('ws2.html')  
  43.     
  44.     
  45. if __name__ == '__main__':  
  46.     # app.run(host='0.0.0.'debug=True)  
  47.     http_serv = WSGIServer(('0.0.0.0', 5000), app, handler_class=WebSocketHandler)  
  48.     http_serv.serve_forever()  

 

前端

  1. <!DOCTYPE html>  
  2. <html lang="en">  
  3. <head>  
  4.     <meta charset="UTF-8">  
  5.     <title>ws</title>  
  6. </head>  
  7. <body>  
  8. <input type="text" id="username"> <button onclick="login()">登陸聊天室</button>  
  9.     
  10. <input type="text" id="to_user">發送:<input type="text" id="msg"> <button onclick="snd_msm()">發送</button>  
  11.     
  12. <div id="chat_list" style="width: 500px; height: 500px;">  
  13.     
  14. </div>  
  15.     
  16. </body>  
  17.     
  18. <script type="application/javascript">  
  19.     var ws = null;  {# 為什麼設置null, 被其他函數執行 #}  
  20.     
  21.     function login() {  
  22.         var username = document.getElementById('username').value;  
  23.         ws = new WebSocket('ws://192.168.32.71:5000/ws2/' + username);  {# 設置websocker連接 #}  
  24.         ws.onmessage = function (data) {  
  25.             var recv_msg = JSON.parse(data.data);  
  26.             var ptag = document.createElement('p');  
  27.             ptag.innerText = recv_msg.from_user + ":" + recv_msg.msg;  
  28.             document.getElementById('chat_list').appendChild(ptag)  
  29.         }; {# 列印收到的數據 #}  
  30.     
  31.     }  
  32.     
  33.     function snd_msm() {  
  34.         var to_user = document.getElementById('to_user').value;  
  35.         var msg = document.getElementById('msg').value;  
  36.         send_msg = {  
  37.             "to_user" : to_user,  
  38.             "msg": msg  
  39.         };  
  40.         ws.send(JSON.stringify(send_msg));  
  41.     }  
  42. </script>  
  43. </html>  

 

Websocker

視圖

  1. import time  
  2. from django.shortcuts import render  
  3. from dwebsocket.decorators import accept_websocket  
  4.     
  5.     
  6. @accept_websocket  
  7. def test(request):  
  8.     if request.is_websocket():  
  9.         print('websocket connection....')  
  10.         msg = request.websocket.wait()  # 接收前端發來的消息  
  11.         print(msg, type(msg), json.loads(msg))  # b'["1","2","3"]' <class 'bytes'> ['1', '2', '3']  
  12.         while 1:  
  13.             if msg:  
  14.                 # 你要返回的結果  
  15.                 for i in range(10):  
  16.                     request.websocket.send(str(i).encode())  # 向客戶端發送數據  
  17.                 request.websocket.close()  
  18.     else:  # 如果是普通的請求返回頁面  
  19.         return render(request, 'test.html')  

前端

  1. <!DOCTYPE html>  
  2. <html lang="en">  
  3. <head>  
  4.     <meta charset="UTF-8">  
  5.     <meta http-equiv="x-ua-compatible" content="IE=edge">  
  6.     <meta name="viewport" content="width=device-width, initial-scale=1">  
  7.     <title>test</title>  
  8. </head>  
  9. <body>  
  10. <div></div>  
  11.     
  12. </body>  
  13. <input type="text" id="message" value="Hello, World!"/>  
  14. <button type="button" id="send_message">發送 message</button>  
  15.     
  16. <!-- 首先引入 jQuery -->  
  17. <script src="https://cdn.bootcss.com/jquery/3.4.1/jquery.js"></script>  
  18. <script>  
  19.     // 判斷瀏覽器是否支持WebSocket,目前應該所有的瀏覽器都支持了.....  
  20.     if ('WebSocket' in window) {  
  21.         console.log('你的瀏覽器支持 WebSocket')  
  22.     }  
  23.     $('#send_message').click(function () {  
  24.         // 創建一個WebSocket對象:sk,並且建立與服務端的連接(服務端程式要跑著哦)  
  25.         var sk = new WebSocket('ws://' + window.location.host + '/asset/test/');  
  26.         // 向服務端發送消息  
  27.         sk.onopen = function () {  
  28.             console.log('websocket connection successful...');  
  29.             var datas = $('#message').val();  
  30.             sk.send(JSON.stringify(datas));  
  31.         };  
  32.         // 接收服務端的消息,主要的業務邏輯也在這裡完成  
  33.         sk.onmessage = function (msg) {  
  34.             // 業務邏輯  
  35.             html = "<p>" + msg.data + "</p>";  
  36.             $("div").append(html);  
  37.             console.log('from service message: ', msg.data);  
  38.             // 由於服務端主動斷開連接,這裡也斷開WebSocket連接  
  39.             if (sk.readyState == WebSocket.CLOSED) sk.close();  
  40.         };  
  41.         // 完事就關閉WebSocket連接  
  42.         sk.onclose = function (msg) {  
  43.             console.log('websocket connection close...');  
  44.             sk.close()  
  45.         };  
  46.         // WebSocket連接創建成功後,我們就可以向服務端發送數據了  
  47.         if (sk.readyState == WebSocket.OPEN) sk.onopen();  
  48.     
  49.     });  
  50.     
  51. </script>  
  52. </html>  

您的分享是我們最大的動力!

更多相關文章
  • 基於HTML5 canvas 獲取文本占用的像素寬度 by:授客 QQ:1033553122 直接上代碼 // 獲取單行文本的像素寬度 getTextPixelWith(text, fontStyle) { var canvas = document.createElement("canvas"); ...
  • 引言 在開發中台過程中 我們的原型中有很多表單,antd有表單組件,但是粒度比較細,就單純組件而言,無可厚非,但是在開發過程中,可能會造成代碼不夠聚合,有些表單公共邏輯無法提取,copy paste比較多,所以可以加以封裝,搞一個相容性和擴展性都契合項目本身的組件。 主要思路 我簡單查閱了一番資料, ...
  • 1:利用DOM獲取該 div 的 ID,然後清空該DIV的內容(如果你需要接著裡面的內容添加可不要清空);需要註意點是清空最好用“ empty() ”; 2: 把 async設成true ,否則又一條警告的錯誤,這條錯誤導致你的內容顯示不出來;下麵就是警告的錯誤 3:就是添加HTML了。 具體代碼如 ...
  • 註:本文非本人原著;原文作者: 黃卉 《js去除空格12種方法》 ...
  • css3 實現右箭頭→ <!DOCTYPE html> <html lang="en"> <head> <meta charset="UTF-8"> <title>Document</title> </head> <style> .divtest{ position: absolute; top: ...
  • 1. 綁定事件的相容 function addEventListener(element,type,fn) { if(element.addEventListener){ element.addEventListener(type,fn,false); }else if(element.attach ...
  • 解綁事件 註意:用什麼方式綁定事件, 就應該用對應的方式解綁事件 1.解綁事件 對象.on事件名字=事件處理函數 >綁定事件 對象.on事件名字=null; //1 對象.on事件名字=事件處理函數 綁定事件 my$("btn").onclick = function () { console.lo ...
  • 總結綁定事件的區別: addEventListener(); attachEvent() 相同點: 都可以為元素綁定事件 不同點: 1.方法名不一樣 2.參數個數不一樣addEventListener三個參數,attachEvent兩個參數 3.addEventListener 谷歌,火狐,IE11 ...
一周排行
  • " 返回《C 併發編程》" "1. 概念介紹" "2. 非同步編程" "2.1. async運行過程" "2.2. async運行中同步上下文簡介" "2.3. 創建Task實例" "2.4. 捕獲非同步異常類型" "3. 並行編程" "3.1. Parallel" "3.2. 異常處理" "3.3. ...
  • 我們先看看兩個特效,感受一下,有沒有學習的動力? 核心API:Texture2D.SetPixel(int x, int y, Color color),Texture2D.Apply() 實現原理:對象池 思路: 第一幀繪製前:遍歷瓦片上所有活著的粒子對象並且進行數據操作(或運動,死亡),發生運動 ...
  • 原來的導出方式比較適用於比較簡單的導出,每一條數據在一行,數據列雖然自定義程度比較高,如果要一條數據對應多行就做不到了,於是就想支持根據模板導出,在 1.8.0 版本中引入了根據模板導出的功能 ...
  • 創建一個bat腳本, 裡面寫上: reg delete HKEY_CURRENT_USER\Software\JetBrains\dotMemory /freg delete HKEY_CURRENT_USER\Software\Microsoft\Windows\CurrentVersion\Ex ...
  • Linux下有vsyscall來優化一些例如time(NULL), gettimeofday這種調用的消耗; 但是Windows下, 沒有類似的東西, 但是思路還是有的 1. 程式啟動的時候, 獲取一下準確的時間戳 2. 然後每次需要獲取時間的時候, 獲取一下流逝的時間, 可以通過獲取CPU的tic ...
  • 當用戶按下鍵盤上的一個鍵時,就會發生一系列事件。下表根據他們的發生順序列出了這些事件: 表 所有元素的鍵盤事件(按順序) 鍵盤處理永遠不會像上面看到的這麼簡單。一些控制項可能會掛起這些事件中的某些事件,從而可執行自己更特殊的鍵盤處理。最明顯的例子是TextBox控制項,它掛起了TextInput事件。對 ...
  • static void LocalMethod() { Cube(100); void Cube(int x) => Console.WriteLine($"The cube of {x} is {x * x * x}"); } static void GoToDemo() { int i = 1; ...
  • 滑鼠事件執行幾個關聯的任務。當滑鼠移到某個元素上時,可通過最基本的滑鼠事件進行響應。這些事件是MouseEnter(當滑鼠指針移到元素上時引發該事件)和MouseLeave(當滑鼠指針離開元素時引發該事件)。這兩個事件都是直接事件,這意味著他們不使用冒泡和隧道過程,而是源自一個元素並且只被該元素引發 ...
  • 反射這個詞聽起來就很牛逼是吧? 嗯的確,反射是比較高級的特性,只有語言基礎很扎實的Dev們才應該使用它。 搞點反射,可以提高程式的靈活性、可擴展性、耦合度。 反射這東西,是為了動態地運行時載入,相比於靜態代碼。編譯的時候就是板上釘釘了。 就是說,如果你的程式需要在運行時搞一些晚綁定,動態載入或檢查對 ...
  • 眾所周知,微服務架構是由一眾微服務組成,項目中調用其他微服務介面更是常見的操作。為了便於調用外部介面,我們的常用思路一般都是封裝一個外部介面的客戶端,使用時候直接調用相應的方法。webservice或WCF的做法就是引用服務,自動生成客戶端。在webapi2.0里,我們都會手動封裝一個靜態類。那麼在 ...
x