WebSocket原理及用Python实现的应用_python websocket客户端

WebSocket原理及用Python实现的应用

WebSocket原理

WebSocket是一种在单个TCP连接上进行全双工通信的协议。它通过在客户端和服务器之间建立持久连接来实现实时交互。相比传统的HTTP请求响应模式，WebSocket协议具有以下特点：

1. 全双工通信：WebSocket允许客户端和服务器同时发送和接收数据，实现了双向通信。
2. 持久连接：WebSocket连接在客户端和服务器之间始终保持打开状态，不需要重复建立和关闭连接。
3. 低延迟：由于WebSocket使用单个TCP连接，避免了HTTP的握手和头部开销，因此具有较低的延迟。
4. 跨域支持：WebSocket支持跨域通信，可以在不同域名或端口间进行通信。

WebSocket协议的工作原理如下：

1. 客户端发送一个HTTP请求到服务器，请求中包含Upgrade头部字段，指定协议为WebSocket。
2. 服务器收到请求后，如果支持WebSocket协议，则返回101 Switching Protocols响应，表示协议切换，同时建立持久连接。
3. 连接建立后，客户端和服务器可以通过发送帧（frame）来进行通信。帧包括数据和控制信息，可以用于发送和接收消息。
4. 客户端和服务器可以随时发送帧，数据可以是文本或二进制格式。
5. 连接关闭时，客户端或服务器发送一个带有关闭码的帧，表示关闭连接。

用Python实现WebSocket 服务端

Python提供了多个库和框架来实现WebSocket应用，其中最常用的是websocket和websockets库。以下是一个使用websockets库实现的简单示例：

pip install websockets
1

import asyncio
import websockets

# 定义WebSocket处理逻辑
async def websocket_handler(websocket, path):
    # 接收客户端消息
    async for message in websocket:
        # 处理消息
        response = process_message(message)

        # 发送响应给客户端
        await websocket.send(response)

# 处理消息的函数
def process_message(message):
    # 处理逻辑...
    return response

# 启动WebSocket服务器
start_server = websockets.serve(websocket_handler, 'localhost', 8000)

# 运行事件循环
asyncio.get_event_loop().run_until_complete(start_server)
asyncio.get_event_loop().run_forever()
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24

在上述示例中，使用websockets库创建了一个WebSocket服务器，监听在本地的8000端口。websocket_handler函数用于处理接收到的消息，process_message函数用于处理消息的逻辑。通过websocket.send()方法可以向客户端发送响应。

可以使用浏览器的WebSocket API或其他WebSocket客户端与该服务器进行通信，发送和接收消息。

使用Python实现WebSocket客户端

准备工作

在开始之前，确保已安装Python和WebSocket库。

pip install websocket-client
1

创建WebSocket客户端

首先，我们需要创建一个WebSocket客户端来连接服务器并进行通信。

import websocket

def on_open(ws):
    print("连接已建立")

def on_message(ws, message):
    print("收到消息：", message)

def on_close(ws):
    print("连接已关闭")

def on_error(ws, error):
    print("发生错误：", error)

# 创建WebSocket连接
ws = websocket.WebSocketApp("ws://localhost:8000/ws",
                            on_open=on_open,
                            on_message=on_message,
                            on_close=on_close,
                            on_error=on_error)

# 启动WebSocket客户端
ws.run_forever()
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23

在上面的代码中，我们定义了几个回调函数来处理不同的事件：

• on_open()：在连接建立时调用。
• on_message()：在收到消息时调用。
• on_close()：在连接关闭时调用。
• on_error()：在发生错误时调用。

然后，我们使用websocket.WebSocketApp类创建一个WebSocket连接，并指定回调函数。最后，调用run_forever()方法启动WebSocket客户端。

与服务器通信

现在我们已经创建了WebSocket客户端，接下来让我们尝试与服务器进行通信。

import websocket

def on_open(ws):
    print("连接已建立")

    # 发送消息给服务器
    ws.send("Hello, server!")

def on_message(ws, message):
    print("收到消息：", message)

def on_close(ws):
    print("连接已关闭")

def on_error(ws, error):
    print("发生错误：", error)

# 创建WebSocket连接
ws = websocket.WebSocketApp("ws://localhost:8000/ws",
                            on_open=on_open,
                            on_message=on_message,
                            on_close=on_close,
                            on_error=on_error)

# 启动WebSocket客户端
ws.run_forever()
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26

在上面的代码中，我们在on_open()函数中发送了一条消息给服务器。我们可以根据需要发送任意类型的消息。

完整示例

下面是一个完整的示例，展示了如何使用Python实现一个简单的WebSocket应用。

import websocket

def on_open(ws):
    print("连接已建立")

    # 发送消息给服务器
    ws.send("Hello, server!")

def on_message(ws, message):
    print("收到消息：", message)

def on_close(ws):
    print("连接已关闭")

def on_error(ws, error):
    print("发生错误：", error)

# 创建WebSocket连接
ws = websocket.WebSocketApp("ws://localhost:8000/ws",
                            on_open=on_open,
                            on_message=on_message,
                            on_close=on_close,
                            on_error=on_error)

# 启动WebSocket客户端
ws.run_forever()
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26

总结

WebSocket是一种实现全双工通信的协议，通过建立持久连接实现实时交互。Python提供了多个库和框架来实现WebSocket应用，如websockets，websocket-client库。使用WebSocket可以实现实时通信、聊天室、实时数据更新等功能。