当前位置：首页 > news >正文

Python WebSocket 客户端教程

news 2026/2/10 15:40:02

WebSocket 是一种在客户端和服务器之间实现双向通信的协议，常用于实时聊天、实时数据更新等场景。Python 提供了许多库来实现 WebSocket 客户端，本教程将介绍如何使用 Python 构建 WebSocket 客户端。

什么是 WebSocket

WebSocket 是一种基于 TCP 协议的双向通信协议，它允许客户端和服务器之间进行实时的双向数据传输。相对于传统的 HTTP 请求，WebSocket 不仅能够从服务器接收数据，还可以向服务器发送数据，而且它是一种持久化的连接，可以保持长时间的通信。

WebSocket 协议的主要特点包括：

双向通信：客户端和服务器都可以发送和接收数据。
实时性：WebSocket 提供了实时的数据传输，可以快速地传递消息。
低延迟：WebSocket 的通信延迟相对较低，可以实现快速响应。
轻量级：WebSocket 的数据帧较小，协议本身非常轻量级。

Python WebSocket 客户端库

Python 提供了许多用于构建 WebSocket 客户端的库，包括：

websocket：Python 内置的 WebSocket 客户端库，支持 Python 3.6+ 版本。
websockets：一个基于 asyncio 的现代化 WebSocket 客户端和服务器库，支持 Python 3.5+ 版本。
tornado.websocket：Tornado 框架提供的 WebSocket 客户端库，适用于 Tornado 项目。
autobahn：一个全功能的 WebSocket 客户端和服务器库，支持 WebSocket 协议的各种功能和扩展。

本教程将以 websockets 作为示例，因为它是一个简单且功能强大的 WebSocket 客户端库，适用于大多数项目。

安装 websockets

首先，需要安装 websockets 库。使用 pip 命令可以方便地进行安装：

pip install websockets

安装完成后，我们可以开始编写 WebSocket 客户端的代码。

编写 WebSocket 客户端

以下是一个简单的示例，展示了如何使用 websockets 构建一个 WebSocket 客户端，连接到服务器并发送和接收数据：

import asyncio
import websocketsasync def connect():async with websockets.connect("ws://localhost:8000") as websocket:print("已连接到服务器")# 发送消息到服务器await websocket.send("Hello, Server!")# 接收服务器发送的消息message = await websocket.recv()print(f"接收到消息：{message}")# 关闭连接await websocket.close()print("连接已关闭")# 运行客户端
asyncio.get_event_loop().run_until_complete(connect())

在上述代码中，我们使用 websockets.connect 方法来建立与服务器之间的 WebSocket 连接。我们使用 async with 上下文管理器来自动处理连接的打开和关闭。

在连接建立之后，我们可以使用 await websocket.send 方法向服务器发送消息。在本例中，我们发送了一条简单的消息 “Hello, Server!”。

接下来，我们使用 await websocket.recv 方法来接收服务器发送的消息。在本例中，我们打印出接收到的消息。

最后，我们使用 await websocket.close 方法来关闭与服务器的连接。

运行 WebSocket 客户端

要运行 WebSocket 客户端，我们需要执行以下命令：

python client.py

其中 client.py 是我们编写的客户端代码所在的文件。

当客户端运行时，它将连接到指定的服务器，并发送和接收消息。您可以将 WebSocket 服务器的地址和端口替换为实际的值。
当然，下面给出三个使用Python WebSocket客户端的案例和代码。

案例

案例一：实时聊天室

这个案例演示了如何使用Python WebSocket客户端来实现一个实时聊天室。客户端将连接到服务器，发送和接收消息。

import asyncio
import websocketsasync def chat_client():async with websockets.connect("ws://localhost:8000/chat") as websocket:print("已连接到聊天室")while True:message = input("输入消息: ")await websocket.send(message)response = await websocket.recv()print(f"接收到消息: {response}")# 运行聊天客户端
asyncio.get_event_loop().run_until_complete(chat_client())

在此代码中，我们使用了一个 while 循环，以便用户可以不断输入聊天消息。用户输入的消息会通过 WebSocket 客户端发送到服务器，然后等待接收服务器的响应。接收到的消息将被打印出来。

案例二：实时股票价格更新

这个案例演示了如何使用Python WebSocket客户端来获取实时的股票价格更新。客户端将连接到一个提供实时股票数据的WebSocket服务器，并接收服务器发送的股票价格。

import asyncio
import websocketsasync def stock_client():async with websockets.connect("wss://stockserver.com/stocks") as websocket:print("已连接到股票服务器")while True:message = await websocket.recv()print(f"接收到股票价格更新: {message}")# 运行股票客户端
asyncio.get_event_loop().run_until_complete(stock_client())

在此代码中，我们连接到一个 WebSocket 服务器，该服务器提供实时的股票价格更新。客户端通过 await websocket.recv() 方法接收服务器发送的消息，并将其打印出来。

案例三：实时数据可视化

这个案例演示了如何使用Python WebSocket客户端来获取实时数据，并将其可视化。客户端连接到一个WebSocket服务器，接收服务器发送的实时数据，并使用Matplotlib库进行实时绘图。

import asyncio
import websockets
import matplotlib.pyplot as plt# 初始化绘图
plt.ion()
fig, ax = plt.subplots()async def data_client():async with websockets.connect("wss://dataserver.com/data") as websocket:print("已连接到数据服务器")x = []y = []while True:message = await websocket.recv()value = float(message)x.append(len(x) + 1)y.append(value)# 更新绘图ax.plot(x, y, 'b-')plt.draw()plt.pause(0.001)# 运行数据客户端
asyncio.get_event_loop().run_until_complete(data_client())

在此代码中，我们使用了Matplotlib库来实时绘制数据。客户端连接到一个WebSocket服务器，接收服务器发送的实时数据，并将其添加到x和y列表中。然后，我们使用Matplotlib库来绘制x和y列表的折线图，并通过plt.draw()和plt.pause()方法实时更新图表。

这些案例展示了如何使用Python WebSocket客户端在不同的应用场景中实现实时通信，从而展示了WebSocket的强大功能和灵活性。在实际应用中，您可以根据自己的需求进行定制和扩展。

总结

本教程介绍了如何使用 Python 构建 WebSocket 客户端。我们使用 websockets 库作为示例，演示了如何连接到服务器、发送和接收消息，并关闭连接。

WebSocket 提供了一种实时、双向的通信方式，适用于许多场景，如实时聊天、实时数据更新等。Python 提供了多个库来实现 WebSocket 客户端，您可以根据项目的需求选择适合的库。

希望本教程对您有所帮助，祝您在使用 Python 构建 WebSocket 客户端时成功！