В современных веб-приложениях общение в реальном время становилось все более важным, а WebSocket стал обычным общение в режиме реального соглашение о времени. Python предоставляет несколько мощных библиотек, которые делают подключение WebSocket относительно простым. В этом блоге рассказывается, как использовать библиотеку WebSocket в Python для создания и управления WebSocketсоединять, а также как включить общение в режиме реального времени。

Что такое вебсокет?

WebSocket — это протокол полнодуплексной связи через одно соединение TCP, который обеспечивает двустороннюю связь в реальном времени между клиентом и сервером. По сравнению с традиционными HTTP-запросами WebSocket обеспечивает меньшую задержку и более высокую эффективность, что делает его идеальным выбором для обработки данных в реальном времени.

Установите библиотеку WebSocket.

перед началом,Сначала вам нужно установитьPythonизWebSocketБиблиотека。Можно использоватьpipустановитьwebsocketsБиблиотека：

pip install websockets

Установить соединение WebSocket

использоватьwebsocketsБиблиотека,Установить соединение WebSocket очень просто. Вот простой пример,Продемонстрируйте, как создать WebSocketсервер в Python:

import asyncio

import websockets

async def handle_connection(websocket, path):

# Обработка соединений

    while True:

        message = await websocket.recv()

        print(f"Received message: {message}")

#Добавьте здесь пользовательскую логику обработки

        await websocket.send(f"Received: {message}")

# Запускаем сервер WebSocket

start_server = websockets.serve(handle_connection, "localhost", 8765)

#Запуск цикла событий

asyncio.get_event_loop().run_until_complete(start_server)

asyncio.get_event_loop().run_forever()

В приведенном выше примере,handle_connectionфункция для обработки каждогосоединять,получить и Отправить сообщение。websockets.serveиспользуется для началаWebSocketсервер。

Создание клиента WebSocket

Аналогично, создать клиент WebSocket довольно просто. Вот простой пример:

import asyncio

import websockets

async def connect_to_server():

    uri = "ws://localhost:8765"

    async with websockets.connect(uri) as websocket:

​ ​ # Отправить сообщение

        message = "Hello, WebSocket!"

        await websocket.send(message)

        print(f"Sent message: {message}")

​ ​ ​ # Получаем ответ от сервера

        response = await websocket.recv()

        print(f"Received response: {response}")

#Запуск цикла событийсоединятьприезжатьWebSocketсервер

asyncio.get_event_loop().run_until_complete(connect_to_server())

В приведенном выше примере клиента,websockets.connectиспользуется длясоединятьприезжатьWebSocketсервер,тогда пройдиawait websocket.sendОтправить сообщение,и пройтиawait websocket.recvперениматьсерверизответ。

Включите общение в режиме реального времени

Через WebSocket вы можете общаться с другими, например, с помощью приложений чата в реальном времени, обновляемых данных в реальном времени и т. д. Полнодуплексный канал связи, установленный между сервером и клиентом, обеспечивает мгновенную передачу информации.

Коллекция | 0 лайков | 0 подсказок