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 ...
一周排行
  • 比如要拆分“呵呵呵90909086676喝喝999”,下麵當type=0返回的是中文字元串“呵呵呵,喝喝”,type=1返回的是數字字元串“90909086676,999”, private string GetStrings(string str,int type=0) { IList<strin ...
  • Swagger一個優秀的Api介面文檔生成工具。Swagger可以可以動態生成Api介面文檔,有效的降低前後端人員關於Api介面的溝通成本,促進項目高效開發。 1、使用NuGet安裝最新的包:Swashbuckle.AspNetCore。 2、編輯項目文件(NetCoreTemplate.Web.c ...
  • 2020 年 7 月 30 日, 由.NET基金會和微軟 將舉辦一個線上和為期一天的活動,包括 微軟 .NET 團隊的演講者以及社區的演講者。本次線上大會 專註.NET框架構建微服務,演講者分享構建和部署雲原生應用程式的最佳實踐、模式、提示和技巧。有關更多信息和隨時瞭解情況:https://focu... ...
  • #abp框架Excel導出——基於vue #1.技術棧 ##1.1 前端採用vue,官方提供 UI套件用的是iview ##1.2 後臺是abp——aspnetboilerplate 即abp v1,https://github.com/aspnetboilerplate/aspnetboilerp ...
  • 前言 本文的文字及圖片來源於網路,僅供學習、交流使用,不具有任何商業用途,版權歸原作者所有,如有問題請及時聯繫我們以作處理。 作者:碧茂大數據 PS:如有需要Python學習資料的小伙伴可以加下方的群去找免費管理員領取 input()輸入 Python提供了 input() 內置函數從標準輸入讀入一 ...
  • 從12年到20年,python以肉眼可見的趨勢超過了java,成為了當今It界人人皆知的編程語言。 python為什麼這麼火? 網路編程語言搜索指數 適合初學者 Python具有語法簡單、語句清晰的特點,這就讓初學者在學習階段可以把精力集中在編程對象和思維方法上。 大佬都在用 Google,YouT ...
  • 在社會上存在一種普遍的對培訓機構的學生一種歧視的現象,具體表現在,比如:當你去公司面試的時候,一旦你說了你是培訓機構出來的,那麼基本上你就涼了,那麼你瞞著不說,然後又通過了面試成功入職,但是以後一旦在公司被髮現有培訓經歷,可能會面臨被降薪,甚至被辭退,培訓機構出來的學生,在用人單位眼裡就是能力低下的 ...
  • from typing import List# 這道題看了大佬寫的代碼,經過自己的理解寫出來了。# 從最外圍的四周找有沒有為O的,如果有的話就進入深搜函數,然後深搜遍歷# 判斷上下左右的位置是否為Oclass Solution: def solve(self, board: List[List[s ...
  • import requests; import re; import os; # 1.請求網頁 header = { "user-agent":'Mozilla/5.0 (Macintosh; Intel Mac OS X 10_15_5) AppleWebKit/537.36 (KHTML, li ...
  • import requests; import re; import os; import parsel; 1.請求網頁 header = { "user-agent":'Mozilla/5.0 (Macintosh; Intel Mac OS X 10_15_5) AppleWebKit/537. ...