Python 实现网络通信

导言

网络通信是现代计算机应用中的重要部分，可以实现不同计算机之间的数据传输和信息交流。Python 是一种简洁、易学的编程语言，提供了多种网络通信库，可用于实现不同的网络通信需求。本篇文章将介绍在 Python 中实现网络通信的基本概念和相关库函数，并给出一些代码示例。

一、TCP 通信

TCP（传输控制协议）是一种可靠的、面向连接的协议，提供了高可靠性和可靠的数据传输。在 Python 中，我们可以使用 socket 库来实现 TCP 通信。

创建 TCP 服务器

import socket

server_ip = '127.0.0.1'  # 服务器 IP 地址
server_port = 8888  # 服务器端口号

server_socket = socket.socket(socket.AF_INET, socket.SOCK_STREAM)  # 创建 socket 对象
server_socket.bind((server_ip, server_port))  # 绑定 IP 地址和端口号
server_socket.listen(5)  # 监听连接，最多可接受 5 个连接请求

print(f'TCP 服务器已启动，监听地址为 {server_ip}:{server_port} ...')

while True:
    client_socket, client_address = server_socket.accept()  # 接受一个客户端连接请求
    print(f'与客户端 {client_address} 建立连接！')

    message = '欢迎连接到 TCP 服务器！'  # 服务器发送给客户端的信息
    client_socket.send(message.encode())  # 发送消息给客户端

    client_socket.close()  # 关闭客户端连接

创建 TCP 客户端

import socket

server_ip = '127.0.0.1'  # 服务器 IP 地址
server_port = 8888  # 服务器端口号

client_socket = socket.socket(socket.AF_INET, socket.SOCK_STREAM)  # 创建 socket 对象
client_socket.connect((server_ip, server_port))  # 连接服务器

message = client_socket.recv(1024).decode()  # 接收来自服务器的消息
print(f'接收到来自服务器的消息：{message}')

client_socket.close()  # 关闭客户端连接

二、UDP 通信

UDP（用户数据报协议）是一种不可靠的、面向无连接的协议，适用于数据量较小但实时性要求较高的场景。在 Python 中，同样可以使用 socket 库来实现 UDP 通信。

创建 UDP 服务器

import socket

server_ip = '127.0.0.1'  # 服务器 IP 地址
server_port = 8888  # 服务器端口号

server_socket = socket.socket(socket.AF_INET, socket.SOCK_DGRAM)  # 创建 socket 对象
server_socket.bind((server_ip, server_port))  # 绑定 IP 地址和端口号

print(f'UDP 服务器已启动，监听地址为 {server_ip}:{server_port} ...')

while True:
    message, client_address = server_socket.recvfrom(1024)  # 接收来自客户端的消息
    print(f'接收到来自客户端 {client_address} 的消息：{message.decode()}')

    response = '已接收到消息！'  # 服务器发送给客户端的响应
    server_socket.sendto(response.encode(), client_address)  # 给客户端发送响应

创建 UDP 客户端

import socket

server_ip = '127.0.0.1'  # 服务器 IP 地址
server_port = 8888  # 服务器端口号

client_socket = socket.socket(socket.AF_INET, socket.SOCK_DGRAM)  # 创建 socket 对象

message = 'Hello, UDP Server!'  # 客户端发送给服务器的消息
client_socket.sendto(message.encode(), (server_ip, server_port))  # 发送消息给服务器

response, server_address = client_socket.recvfrom(1024)  # 接收来自服务器的响应
print(f'接收到来自服务器 {server_address} 的响应：{response.decode()}')

client_socket.close()  # 关闭客户端连接

三、WebSocket 通信

WebSocket 是一种基于 TCP 的网络通信协议，提供了全双工通信能力。Python 中可以使用 websockets 库来实现 WebSocket 通信。

创建 WebSocket 服务器

import asyncio
import websockets

async def handle_connection(websocket, path):
    message = await websocket.recv()  # 接收来自客户端的消息
    print(f'接收到来自客户端的消息：{message}')

    response = '已接收到消息！'  # 服务器发送给客户端的响应
    await websocket.send(response)  # 给客户端发送响应

server_ip = '127.0.0.1'  # 服务器 IP 地址
server_port = 8888  # 服务器端口号

start_server = websockets.serve(handle_connection, server_ip, server_port)

asyncio.get_event_loop().run_until_complete(start_server)
asyncio.get_event_loop().run_forever()

创建 WebSocket 客户端

import asyncio
import websockets

async def send_message():
    async with websockets.connect('ws://127.0.0.1:8888') as websocket:
        message = 'Hello, WebSocket Server!'  # 客户端发送给服务器的消息
        await websocket.send(message)  # 发送消息给服务器

        response = await websocket.recv()  # 接收来自服务器的响应
        print(f'接收到来自服务器的响应：{response}')

asyncio.get_event_loop().run_until_complete(send_message())