快捷導(dǎo)航

使用Python創(chuàng)建websocket服務(wù)端并給出不同客戶端的請(qǐng)求

更新時(shí)間：2023年01月18日 14:49:01 作者：虛壞叔叔

本文主要介紹了使用Python創(chuàng)建websocket服務(wù)端并給出不同客戶端的請(qǐng)求，文中通過(guò)示例代碼介紹的非常詳細(xì)，對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值，需要的朋友們下面隨著小編來(lái)一起學(xué)習(xí)學(xué)習(xí)吧

一、 WebSocket是啥

WebSocket 和HTTP一樣，也是一種通訊協(xié)議，允許服務(wù)端主動(dòng)向客戶端推送數(shù)據(jù)。
在 WebSocket API 中，瀏覽器和服務(wù)器只需要完成一次握手，兩者之間就直接可以創(chuàng)建持久性的連接，并進(jìn)行雙向數(shù)據(jù)傳輸。

有很多網(wǎng)站為了實(shí)現(xiàn)推送技術(shù)，所用的技術(shù)都是 Ajax 輪詢。輪詢是在特定的的時(shí)間間隔（如每1秒），由瀏覽器對(duì)服務(wù)器發(fā)出HTTP請(qǐng)求，然后由服務(wù)器返回最新的數(shù)據(jù)給客戶端的瀏覽器。這種傳統(tǒng)的模式帶來(lái)很明顯的缺點(diǎn)，即瀏覽器需要不斷的向服務(wù)器發(fā)出請(qǐng)求，然而HTTP請(qǐng)求可能包含較長(zhǎng)的頭部，其中真正有效的數(shù)據(jù)可能只是很小的一部分，顯然這樣會(huì)浪費(fèi)很多的帶寬等資源。

HTML5 定義的 WebSocket 協(xié)議，能更好的節(jié)省服務(wù)器資源和帶寬，并且能夠更實(shí)時(shí)地進(jìn)行通訊。

二、 WebSocket的C/S架構(gòu)

在服務(wù)端啟動(dòng)接收WebSocket請(qǐng)求的服務(wù)，客戶端建立Websocket連接并發(fā)送請(qǐng)求（Message），服務(wù)端接收后，就可以根據(jù)處理邏輯，按需向客戶端發(fā)送消息了，例如發(fā)送主動(dòng)推送。

三、依賴的三方庫(kù)

Python websockets是用于在Python中構(gòu)建WebSocket服務(wù)器和客戶端的庫(kù)，它基于asyncio異步IO建立，提供基于協(xié)程的API。
請(qǐng)盡量使用Python≥3.6以上版本來(lái)運(yùn)行websockets。

依賴的三方庫(kù)為： websocket, websocket-client.

pip install websocket  
pip3 install websocket-client
pip3 install websockets

主要用到的API有：

websockets.connect()
websockets.send()
websockets.recv()

四、簡(jiǎn)單例子

server.py，用于構(gòu)建websocket服務(wù)器，在本地8765端口啟動(dòng)，會(huì)將接收到的消息加上I got your message:返回回去。

import asyncio
import websockets


async def echo(websocket, path):
    async for message in websocket:
        message = "I got your message: {}".format(message)
        await websocket.send(message)


asyncio.get_event_loop().run_until_complete(websockets.serve(echo, 'localhost', 8765))
asyncio.get_event_loop().run_forever()

client.py和指定url建立websocket連接，并發(fā)送消息，然后等待接收消息，并將消息打印出來(lái)。

import asyncio
import websockets


async def hello(uri):
    async with websockets.connect(uri) as websocket:
        await websocket.send("Hello world!")
        recv_text = await websocket.recv()
        print(recv_text)


asyncio.get_event_loop().run_until_complete(
    hello('ws://localhost:8765'))

先執(zhí)行server.py，再執(zhí)行client.py，client.py的輸出結(jié)果如下：

I got your message: Hello world!

五主動(dòng)發(fā)消息

建立連接之后，客戶端可以隨時(shí)接收服務(wù)器發(fā)來(lái)的消息。服務(wù)器可以依據(jù)邏輯，給客戶端推送指定消息。
服務(wù)器和客戶端代碼會(huì)有一點(diǎn)變化，在服務(wù)器回完第一條消息之后，開始輪詢時(shí)間，當(dāng)秒數(shù)達(dá)到0的時(shí)候，會(huì)主動(dòng)給客戶端回一條消息。

server.py：

import asyncio
import websockets
import time


async def echo(websocket, path):
    async for message in websocket:
        message = "I got your message: {}".format(message)
        await websocket.send(message)

        while True:
            t = time.strftime("%Y-%m-%d %H:%M:%S", time.localtime())
            if str(t).endswith("0"):
                await websocket.send(t)
                break


asyncio.get_event_loop().run_until_complete(
    websockets.serve(echo, 'localhost', 8765))
asyncio.get_event_loop().run_forever()

client.py：

import asyncio
import websockets


async def hello(uri):
    async with websockets.connect(uri) as websocket:
        await websocket.send("Hello world!")
        print("< Hello world!")
        while True:
            recv_text = await websocket.recv()
            print("> {}".format(recv_text))


asyncio.get_event_loop().run_until_complete(
    hello('ws://localhost:8765'))

先執(zhí)行server.py，再執(zhí)行client.py，client.py的輸出結(jié)果如下：

< Hello world!
> I got your message: Hello world!
> 2020-05-29 15:11:50

最后一條消息則是服務(wù)端主動(dòng)給客戶端發(fā)送的。

六、在瀏覽器上使用

如何在前端發(fā)送websocket請(qǐng)求呢？
看這段代碼，先建立連接，然后向服務(wù)端發(fā)送Hello world，然后把接收到的所有消息依次展示出來(lái)。

<!DOCTYPE HTML>
<html>
<head>
    <meta charset="utf-8">
    <title>websocket通信客戶端</title>
    <script src="jquery-3.5.0.min.js"></script>
    <script type="text/javascript">
        function WebSocketTest() {
            if ("WebSocket" in window) {
                // 打開一個(gè) web socket
                var ws = new WebSocket("ws://127.0.0.1:8765");
                // 連接建立后的回調(diào)函數(shù)
                ws.onopen = function () {
                    // Web Socket 已連接上，使用 send() 方法發(fā)送數(shù)據(jù)
                    ws.send("Hello world!");
                    $("#main").append("<p>" + "<=" + "Hello world!" + "</p>")
                };

                // 接收到服務(wù)器消息后的回調(diào)函數(shù)
                ws.onmessage = function (evt) {
                    var received_msg = evt.data;
                    if (received_msg.indexOf("sorry") == -1) {
                        $("#main").append("<p>" + "=>" + received_msg + "</p>")
                    }
                };
                // 連接關(guān)閉后的回調(diào)函數(shù)
                ws.onclose = function () {
                    // 關(guān)閉 websocket
                    alert("連接已關(guān)閉...");
                };
            } else {
                // 瀏覽器不支持 WebSocket
                alert("您的瀏覽器不支持 WebSocket!");
            }
        }
    </script>
</head>
<body onload="WebSocketTest()">
<div id="main">
</div>
</body>
</html>

效果大概的這樣的：

可以在一開始的時(shí)候就抓websocket的包：

這里可以清晰的看到每一條消息。

到此這篇關(guān)于使用Python創(chuàng)建websocket服務(wù)端并給出不同客戶端的請(qǐng)求的文章就介紹到這了,更多相關(guān)Python創(chuàng)建websocket服務(wù)端內(nèi)容請(qǐng)搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家！

您可能感興趣的文章: