91超碰碰碰碰久久久久久综合_超碰av人澡人澡人澡人澡人掠_国产黄大片在线观看画质优化_txt小说免费全本

溫馨提示×

溫馨提示×

您好,登錄后才能下訂單哦!

密碼登錄×
登錄注冊×
其他方式登錄
點擊 登錄注冊 即表示同意《億速云用戶服務條款》

Python Websocket服務端通信的使用示例

發布時間:2020-10-16 08:35:26 來源:腳本之家 閱讀:228 作者:沙振宇 欄目:開發技術

1、嘮嘮叨叨

最近又回顧了下Websocket,發現已經忘的七七八八了。于是用js寫了客戶端,用python寫了服務端,來復習一下這方面的知識。

WebSocket 是一種標準協議,用于在客戶端和服務端之間進行雙向數據傳輸。但它跟 HTTP 沒什么關系,它是基于 TCP 的一種獨立實現。

以前客戶端想知道服務端的處理進度,要不停地使用 Ajax 進行輪詢,讓瀏覽器隔個幾秒就向服務器發一次請求,這對服務器壓力較大。另外一種輪詢就是采用 long poll 的方式,這就跟打電話差不多,沒收到消息就一直不掛電話,也就是說,客戶端發起連接后,如果沒消息,就一直不返回 Response 給客戶端,連接階段一直是阻塞的。

而 WebSocket 解決了 HTTP 的這幾個難題。當服務器完成協議升級后( HTTP -> WebSocket ),服務端可以主動推送信息給客戶端,解決了輪詢造成的同步延遲問題。由于 WebSocket 只需要一次 HTTP 握手,服務端就能一直與客戶端保持通信,直到關閉連接,這樣就解決了服務器需要反復解析 HTTP 協議,減少了資源的開銷。

2、先看一下效果吧

2.1、效果1(一個客戶端連上服務的并發送消息)

Python Websocket服務端通信的使用示例

2.2、效果2(另一個客戶端連上服務的并發送消息)

Python Websocket服務端通信的使用示例

2.3、效果3(服務的收到客戶端的全部消息并返回消息)

Python Websocket服務端通信的使用示例

2.4、效果4(一個客戶端掉線并不影響其它socket連接)

Python Websocket服務端通信的使用示例

2.5、效果5(列取全部連接客戶端對象和當前發消息的客戶端對象)

Python Websocket服務端通信的使用示例

3、核心代碼

3.1、Python

#! -*- coding: utf-8 -*-
"""
Author: ZhenYuSha
Create Time: 2019-1-14
Info: Websocket 的使用示例
"""
import asyncio
import websockets

websocket_users = set()


# 檢測客戶端權限,用戶名密碼通過才能退出循環
async def check_user_permit(websocket):
 print("new websocket_users:", websocket)
 websocket_users.add(websocket)
 print("websocket_users list:", websocket_users)
 while True:
  recv_str = await websocket.recv()
  cred_dict = recv_str.split(":")
  if cred_dict[0] == "admin" and cred_dict[1] == "123456":
   response_str = "Congratulation, you have connect with server..."
   await websocket.send(response_str)
   print("Password is ok...")
   return True
  else:
   response_str = "Sorry, please input the username or password..."
   print("Password is wrong...")
   await websocket.send(response_str)


# 接收客戶端消息并處理,這里只是簡單把客戶端發來的返回回去
async def recv_user_msg(websocket):
 while True:
  recv_text = await websocket.recv()
  print("recv_text:", websocket.pong, recv_text)
  response_text = f"Server return: {recv_text}"
  print("response_text:", response_text)
  await websocket.send(response_text)


# 服務器端主邏輯
async def run(websocket, path):
 while True:
  try:
   await check_user_permit(websocket)
   await recv_user_msg(websocket)
  except websockets.ConnectionClosed:
   print("ConnectionClosed...", path) # 鏈接斷開
   print("websocket_users old:", websocket_users)
   websocket_users.remove(websocket)
   print("websocket_users new:", websocket_users)
   break
  except websockets.InvalidState:
   print("InvalidState...") # 無效狀態
   break
  except Exception as e:
   print("Exception:", e)


if __name__ == '__main__':
 print("127.0.0.1:8181 websocket...")
 asyncio.get_event_loop().run_until_complete(websockets.serve(run, "127.0.0.1", 8181))
 asyncio.get_event_loop().run_forever()

3.2、Html(JS)

 <script>
  var socket;
  if ("WebSocket" in window) {
   var ws = new WebSocket("ws://127.0.0.1:8181/test");
   socket = ws;
   ws.onopen = function() {
    console.log('連接成功');
    alert("連接成功, 請輸入賬號和密碼");
   };
   ws.onmessage = function(evt) {
    var received_msg = evt.data;
    document.getElementById("showMes").value+=received_msg+"\n";
   };
   ws.onclose = function() {
    alert("斷開了連接");
   };
  } else {
   alert("瀏覽器不支持WebSocket");
  }
  function sendMeg(){
   var message=document.getElementById("name").value+":"+document.getElementById("mes").value;
   document.getElementById("showMes").value+=message+"\n\n";
   socket.send(message);
  }
 </script>

4、Github源碼分享

https://github.com/ShaShiDiZhuanLan/Demo_Socket_Python

到此這篇關于Python Websocket服務端通信的使用示例的文章就介紹到這了,更多相關Python Websocket服務端通信內容請搜索億速云以前的文章或繼續瀏覽下面的相關文章希望大家以后多多支持億速云!

向AI問一下細節

免責聲明:本站發布的內容(圖片、視頻和文字)以原創、轉載和分享為主,文章觀點不代表本網站立場,如果涉及侵權請聯系站長郵箱:is@yisu.com進行舉報,并提供相關證據,一經查實,將立刻刪除涉嫌侵權內容。

AI

甘南县| 黑山县| 郴州市| 宿松县| 灌阳县| 玉林市| 东丰县| 繁昌县| 饶河县| 宁南县| 开平市| 阿勒泰市| 钟祥市| 黎川县| 迁西县| 应城市| 博乐市| 延寿县| 松江区| 宜春市| 安化县| 四川省| 宁远县| 泌阳县| 永修县| 方正县| 凌源市| 申扎县| 永新县| 武清区| 临桂县| 宿迁市| 高陵县| 江津市| 农安县| 六盘水市| 枣庄市| 酒泉市| 通榆县| 岢岚县| 大田县|