Python网络编程-EW帮帮网

全称：Transmission Control Protocol，传输控制协议。
特性
- 面向连接：数据传输前需通过三次握手建立连接，确保连接可靠。三次握手过程如下：
  1. 客户端向服务器发送 SYN（同步请求）报文，请求建立连接，此时客户端进入 SYN_SENT 状态。
  2. 服务器收到 SYN 报文后，向客户端发送 SYN+ACK（同步确认）报文，表示同意连接，服务器进入 SYN_RCVD 状态。
  3. 客户端收到 SYN+ACK 报文后，向服务器发送 ACK 报文，完成连接建立，客户端和服务器均进入 ESTABLISHED 状态。
- 可靠性：通过序列号、确认应答、重传机制保证数据可靠传输。发送方为每个数据段分配序列号，接收方收到数据后返回确认应答，若发送方未收到确认，会重新传输数据。
- 流量控制：利用滑动窗口技术控制数据传输速率，避免接收方处理不及。滑动窗口大小表示接收方当前可接收的数据量，发送方根据窗口大小调整发送速率。
- 有序性：确保数据包按序号顺序接收，接收方按序列号重组数据。
应用场景：适用于对数据可靠性和顺序性要求高的场景，如文件传输（FTP）、电子邮件（SMTP、POP3）、网页浏览（HTTP）等。

2. UDP 协议

全称：User Datagram Protocol，用户数据报协议。
特性
- 无连接：无需建立连接即可直接发送数据，通信双方无需握手，减少了连接建立和拆除的开销。
- 不可靠传输：不提供确认应答机制，不保证数据到达顺序，可能出现丢包或乱序。
- 速度快：由于无需处理连接和可靠性机制，传输速度较快，适合实时性要求高的场景。
- 支持广播和多播：可同时向多个接收方发送数据，适用于网络广播、多播通信等。
应用场景：适用于实时性要求高但对数据可靠性要求不高的场景，如在线游戏（实时交互数据）、视频会议（实时音视频流）、DNS 查询（快速获取域名解析结果）等。

3. TCP 与 UDP 协议对比

对比项	TCP	UDP
连接方式	面向连接	无连接
可靠性	可靠传输，保证数据有序、不丢失	不可靠传输，可能丢包、乱序
传输速度	较慢，因需建立连接和可靠性机制	较快
首部开销	较大（20 字节固定首部）	较小（8 字节首部）
应用场景	文件传输、电子邮件、网页浏览等	在线游戏、视频会议、DNS 查询等

（三）Socket 简介

定义：Socket 是网络通信的基础，是实现网络编程的抽象层，用于在不同主机之间建立通信连接，实现数据的发送和接收。
在 Python 中的实现：Python 通过socket模块封装了 Socket 功能，提供了丰富的接口用于实现网络通信，如创建 Socket、连接、发送 / 接收数据、关闭连接等操作。
关键参数
- 地址族（Address Family）：指定使用的 IP 协议版本，常见的有AF_INET（IPv4）和AF_INET6（IPv6）。
- 协议类型（Type）：指定使用的传输协议，SOCK_STREAM表示 TCP 协议，SOCK_DGRAM表示 UDP 协议。

二、TCP 编程

（一）TCP 通信流程

TCP 通信需要经过连接建立、数据传输和连接断开三个阶段。连接建立通过三次握手完成，连接断开通过四次挥手实现。

（二）TCP 客户端实现

1. 代码示例

import socket

def tcp_client():
    # 创建TCP客户端Socket，使用IPv4协议和TCP协议
    client_socket = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
    # 连接到服务器（IP地址和端口）
    client_socket.connect(("127.0.0.1", 12345))
    # 发送数据，需编码为字节流
    message = "Hello, Server"
    client_socket.send(message.encode('utf-8'))
    # 接收服务器响应，最多接收1024字节数据
    response = client_socket.recv(1024)
    print("Received from server:", response.decode('utf-8'))  # 对接收到的数据解码
    # 关闭连接
    client_socket.close()

if __name__ == "__main__":
    tcp_client()

2. 代码解释

socket.socket(socket.AF_INET, socket.SOCK_STREAM)：创建 TCP 客户端 Socket，指定使用 IPv4 地址族和 TCP 协议。
client_socket.connect(("127.0.0.1", 12345))：通过 IP 地址127.0.0.1（本地回环地址）和端口12345连接到服务器。
client_socket.send(message.encode('utf-8'))：将字符串数据编码为 UTF-8 字节流后发送到服务器。
client_socket.recv(1024)：接收服务器返回的数据，1024表示一次最多接收 1024 字节。
client_socket.close()：关闭客户端 Socket 连接，释放资源。

（三）TCP 服务器实现

1. 代码示例

import socket

def tcp_server():
    # 创建TCP服务器Socket
    server_socket = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
    # 绑定服务器地址和端口
    server_socket.bind(("127.0.0.1", 12345))
    # 开始监听连接，最大连接数为5
    server_socket.listen(5)
    print("Server is listening...")
    while True:
        # 接受客户端连接，返回客户端Socket和地址
        client_socket, client_address = server_socket.accept()
        print(f"Connection from {client_address}")
        # 接收客户端消息
        message = client_socket.recv(1024)
        # 发送响应消息，需编码为字节流
        client_socket.send(b'Hello, Client')
        # 关闭与客户端的连接
        client_socket.close()

if __name__ == "__main__":
    tcp_server()

2. 代码解释

server_socket.bind(("127.0.0.1", 12345))：将服务器 Socket 绑定到指定的 IP 地址和端口，以便客户端连接。
server_socket.listen(5)：开始监听客户端连接，5表示等待连接的最大队列长度，即最多允许 5 个客户端同时处于连接等待状态。
server_socket.accept()：阻塞式方法，等待客户端连接。当有客户端连接时，返回一个新的 Socket（client_socket）用于与该客户端通信，以及客户端的地址（client_address）。
client_socket.recv(1024)：接收客户端发送的数据。
client_socket.send(b'Hello, Client')：向客户端发送响应消息，b'...'表示字节字符串。
client_socket.close()：关闭与当前客户端的连接，但服务器 Socket 仍继续监听新的连接。

三、UDP 编程

（一）UDP 通信流程

UDP 通信无需建立连接，客户端和服务器可直接发送和接收数据，通信流程简单，实时性高。

（二）UDP 客户端实现

1. 代码示例

import socket

def udp_client():
    # 创建UDP客户端Socket
    client_socket = socket.socket(socket.AF_INET, socket.SOCK_DGRAM)
    # 发送数据到指定地址和端口，需编码为字节流
    message = "Hello, UDP Server"
    client_socket.sendto(message.encode('utf-8'), ("127.0.0.1", 12345))
    # 接收服务器响应，返回数据和服务器地址
    response, server_address = client_socket.recvfrom(1024)
    print("Received from server:", response.decode('utf-8'))
    # 关闭Socket
    client_socket.close()

if __name__ == "__main__":
    udp_client()

2. 代码解释

socket.socket(socket.AF_INET, socket.SOCK_DGRAM)：创建 UDP 客户端 Socket，指定使用 IPv4 地址族和 UDP 协议。
client_socket.sendto(message.encode('utf-8'), ("127.0.0.1", 12345))：向指定的 IP 地址和端口发送数据，sendto方法需同时指定目标地址。
client_socket.recvfrom(1024)：接收数据，返回接收到的数据（字节流）和发送方的地址（服务器地址）。
client_socket.close()：关闭 UDP 客户端 Socket。

（三）UDP 服务器实现

1. 代码示例

import socket

def udp_server():
    # 创建UDP服务器Socket
    server_socket = socket.socket(socket.AF_INET, socket.SOCK_DGRAM)
    # 绑定服务器地址和端口
    server_socket.bind(("127.0.0.1", 12345))
    print("Server is listening...")
    while True:
        # 接收客户端消息，返回数据和客户端地址
        message, client_address = server_socket.recvfrom(1024)
        print(f"Received message: {message.decode('utf-8')} from {client_address}")
        # 向客户端发送响应数据
        server_socket.sendto(b'Hello, UDP Client', client_address)

if __name__ == "__main__":
    udp_server()

2. 代码解释

server_socket.bind(("127.0.0.1", 12345))：绑定 UDP 服务器 Socket 到指定地址和端口，用于接收客户端发送的数据。
server_socket.recvfrom(1024)：接收客户端发送的数据，返回数据（字节流）和客户端地址。
server_socket.sendto(b'Hello, UDP Client', client_address)：根据客户端地址向其发送响应数据，sendto方法需指定目标地址。

四、小案例：简易 TCP 聊天应用

（一）案例概述

设计一个基于 TCP 协议的简易聊天应用，实现客户端和服务器之间的双向通信。客户端发送消息给服务器，服务器接收后返回响应，形成聊天交互。

（二）TCP 聊天客户端

1. 代码示例

import socket

def tcp_chat_client():
    # 创建TCP客户端Socket
    client_socket = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
    # 连接到服务器
    client_socket.connect(("127.0.0.1", 12345))
    while True:
        # 从用户输入获取消息
        message = input("You: ")
        if message.lower() == 'exit':  # 输入exit退出聊天
            break
        # 发送消息到服务器，需编码
        client_socket.send(message.encode('utf-8'))
        # 接收服务器响应
        response = client_socket.recv(1024)
        print("Server:", response.decode('utf-8'))  # 打印服务器响应
    # 关闭连接
    client_socket.close()

if __name__ == "__main__":
    tcp_chat_client()

2. 代码解释

循环获取用户输入的消息，若输入exit（不区分大小写），则退出循环，结束聊天。
每次发送消息后，等待接收服务器响应，并打印出来，实现双向通信。

（三）TCP 聊天服务器

1. 代码示例

import socket

def tcp_chat_server():
    # 创建TCP服务器Socket
    server_socket = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
    # 绑定IP地址和端口
    server_socket.bind(("127.0.0.1", 12345))
    # 开始监听连接
    server_socket.listen(5)
    print("Server is waiting for connection...")
    # 接受客户端连接
    client_socket, client_address = server_socket.accept()
    print(f"Connection established with {client_address}")
    while True:
        # 接收客户端消息
        message = client_socket.recv(1024)
        if not message:  # 若未接收到消息，退出循环
            break
        print("Client:", message.decode('utf-8'))  # 打印客户端消息
        # 从服务器端输入回应
        response = input("You: ")
        # 发送回应给客户端，需编码
        client_socket.send(response.encode('utf-8'))
    # 关闭客户端和服务器Socket
    client_socket.close()
    server_socket.close()

if __name__ == "__main__":
    tcp_chat_server()

2. 代码解释

服务器接受客户端连接后，进入循环，持续接收客户端消息。
若接收到空消息（客户端关闭连接），则退出循环，关闭相关 Socket。
服务器端输入回应消息后，发送给客户端，实现聊天交互。

五、总结

TCP 和 UDP 协议：TCP 面向连接、可靠传输，适用于需要可靠性的场景；UDP 无连接、不可靠但速度快，适用于实时性场景。
Socket 编程：通过 Python 的socket模块实现 TCP 和 UDP 通信，掌握客户端和服务器的创建、连接、数据收发及关闭等操作。
简易聊天应用：通过 TCP 协议实现客户端与服务器的双向通信，理解网络应用的基本设计思路。

六、TCP 与 UDP 编程关键细节对比

（一）Socket 创建差异

协议	创建 Socket 的函数参数	说明
TCP	`socket.socket(AF_INET, SOCK_STREAM)`	`SOCK_STREAM`表示流式协议，基于 TCP 实现可靠传输
UDP	`socket.socket(AF_INET, SOCK_DGRAM)`	`SOCK_DGRAM`表示数据报协议，基于 UDP 实现无连接传输

代码示例对比：

# TCP客户端创建
tcp_socket = socket.socket(socket.AF_INET, socket.SOCK_STREAM) 

# UDP服务器创建
ud{insert\_element\_0\_}p_socket = socket.socket(socket.AF_INET, socket.SOCK_DGRAM)

（二）数据10收发函数

1. TCP

发送：send(data)
- 需先通过connect()建立连接，数据通过已连接的 Socket 发送。
- 数据需编码为字节流（如encode('utf-8')），返回值为实际发送的字节数。
```
client_socket.send("Hello, Server".encode('utf-8')) 
```
*接收*：recv(bufsize)
- bufsize指定一次最多接收的字节数，返回值为接收到的字节流，需通过decode()解码。
```
response = client_socket.recv(1024) 
```

2.6 UDP

发送：sendto(data, address)
- 无需建立连接，直接指定目标地址（IP + 端口）发送数据。
```
client_socket.sendto("Hello, UDP Server".encode('utf-8'), ("127.0.0.1", 12345)) 
```
*接收*：recvfrom(bufsize)
- 返回值为元组(data, address)，包含接收到的数据和发送方地址。
```
message, client_address = server_socket.recvfrom(1024) 
```

（三）连接管理

1. TCP 的三次握手与四次挥手

三次握手（建立连接）：
1. 客户端发送 SYN 包（序列号seq=x），进入SYN_SENT状态。
2. 服务器回复 SYN+ACK 包（seq=y, ack=x+1），进入SYN_RCVD状态。
3. 客户端回复 ACK 包（ack=y+1），进入ESTABLISHED状态，连接建立完成。
四次挥手（断开连接）：
1. 客户端发送 FIN 包（seq=u），请求断开连接，进入FIN_WAIT_1状态。
2. 服务器回复 ACK 包（ack=u+1），进入CLOSE_WAIT状态，此时客户端不再发送数据，但仍可接收数据。
3. 服务器发送 FIN 包（seq=v），请求断开连接，进入LAST_ACK状态。
4. 客户端回复 ACK 包（ack=v+1），进入TIME_WAIT状态，一段时间后关闭连接；服务器收到 ACK 后立即关闭连接。

2. UDP 的无连接特性

无需握手或挥手，直接通过sendto()和recvfrom()收发数据，适合实时性场景（如视频流），但可能出现丢包。

七、网络编程中的3常见问题与解决方案

（一）端口占用问题

现象：启动服务器时提示 “Address already in use”。
原因：端口被其他进程占用或上次程序未正确关闭。
解决方案：
1. 修改端口号（如从12345改为12346）。
2. 在 Socket 绑定前设置SO_REUSEADDR选项，允许重用端口：
```
# TCP服务器示例中添加
server_socket.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR, 1) 
```

7（二）数据编码与解码

问题：发送或接收数据时出现乱码（如b'\xe4\xbd\xa0\xe5\xa5\xbd'）。
原因：编码与解码方式不一致（如发送时用utf-8，接收时用gbk）。

解决方案：

统一使用 UTF-8 编码（Python 默认字符串为 Unicode，网络传输需转为字节流）。

# 发送时编码
client_socket.send(message.encode('utf-8')) 
# 接收时解码
pr{insert\_element\_10\_}int(response.decode('utf-8'))

（三）UDP 的不可靠性处理

问题：UDP 通信中可能丢失数据或收到乱序数据。
解决方案：
1. 在应用层添加简单确认机制（如接收方收到数据后回复 ACK，发送方未收到则重传）。
2. 对数据添加序列号，接收方按序号重组数据（类似 TCP 的有序性机制）。

八、实战扩展：基于 UDP 的广播聊天

（一）需求分析

实现一个局域网内的广播聊天应用，客户端发送消息后，所有在线客户端均可接收，无需提前建立连接。

（二）关键实现步骤

1. 创建支持广播的 UDP Socket

# UDP广播客户端
client_socket = socket.socket(socket.AF_INET, socket.SOCK_DGRAM)
# 设置Socket为允许广播
client_socket.setsockopt(socket.SOL_SOCKET, socket.SO_BROADCAST, 1)

2. 发送广播消息

# 目标地址设为广播地址（如192.168.1.255），端口12345
client_socket.sendto("Hello, Broadcast".encode('utf-8'), ("192.168.1.255", 12345))

3. 接收广播消息

# UDP广播服务器
server_socket = socket.socket(socket.AF_INET, socket.SOCK_DGRAM)
server_socket.bind(("", 12345))  # 绑定所有接口的12345端口
while True:
    message, addr = server_socket.recvfrom(1024)
    print(f"Broadcast from {addr}: {message.decode('utf-8')}")

（三）注意事项

广播地址通常为子网的最后一个地址（如192.168.1.255），需根据实际网络配置调整。
部分路由器可能禁用 UDP 广播，需在防火墙或路由器设置中开启。

九、性能优化与最佳实践

（一）TCP 性能调优

增大接收缓冲区：

server_socket.setsockopt(socket.SOL_SOCKET, socket.SO_RCVBUF, 1024*1024)  # 设置接收缓冲区为1MB

使用 Nagle 算法：默认开启，通过合并小数据包减少网络开销；若需实时性（如游戏），可关闭：
```
client_socket.setsockopt(socket.IPPROTO_TCP, socket.TCP_NODELAY, 1)
```

（二）UDP 性能优化

设置合理的超时重传：在应用层实现超时机制，避免因丢包导致数据丢失。
限制数据包大小：确保单个 UDP 数据包不超过 MTU（通常为 1500 字节），避免分片。

（三）代码规范建议

使用上下文管理器（with语句）管理 Socket，自动释放资源：
```
with socket.socket(...) as s:
    s.connect(...)
    # 通信逻辑
```

对关键参数添加注释，如 IP 地址、端口号的含义：

SERVER_IP = "127.0.0.1"  # 本地回环地址，用于测试
SERVER_PORT = 12345      # 自定义通信端口

Python网络编程

一、网络编程基础

（一）网络编程概述

（二）网络协议

1. TCP 协议

2. UDP 协议

3. TCP 与 UDP 协议对比

（三）Socket 简介

二、TCP 编程

（一）TCP 通信流程

（二）TCP 客户端实现

1. 代码示例

2. 代码解释

（三）TCP 服务器实现

1. 代码示例

2. 代码解释

三、UDP 编程

（一）UDP 通信流程

（二）UDP 客户端实现

1. 代码示例

2. 代码解释

（三）UDP 服务器实现

1. 代码示例

2. 代码解释

四、小案例：简易 TCP 聊天应用

（一）案例概述

（二）TCP 聊天客户端

1. 代码示例

2. 代码解释

（三）TCP 聊天服务器

1. 代码示例

2. 代码解释

五、总结

六、TCP 与 UDP 编程关键细节对比

（一）Socket 创建差异

（二）数据10收发函数

1. TCP

2.6 UDP

（三）连接管理

1. TCP 的三次握手与四次挥手

2. UDP 的无连接特性

七、网络编程中的3常见问题与解决方案

（一）端口占用问题

7（二）数据编码与解码

（三）UDP 的不可靠性处理

八、实战扩展：基于 UDP 的广播聊天

（一）需求分析

（二）关键实现步骤

1. 创建支持广播的 UDP Socket

2. 发送广播消息

3. 接收广播消息

（三）注意事项

九、性能优化与最佳实践

（一）TCP 性能调优

（二）UDP 性能优化

（三）代码规范建议

网站公告

今日签到

热门文章

最新发布