​TCP/IP协议中的序号、确认与重传机制：深入理解与实践

import socket
import time

# 定义数据包的大小和超时时间
PACKET_SIZE = 1024
TIMEOUT = 1  # 秒

# 创建socket对象并连接到接收端
client_socket = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
client_socket.connect(('localhost', 8000))

# 发送数据并等待确认信号
for i in range(10):  # 发送10个数据包
    data = f"Packet {i}"
    client_socket.send(data.encode())
    start_time = time.time()
    while True:
        if time.time() - start_time > TIMEOUT:
            print(f"Timeout: Resending packet {i}")
            client_socket.send(data.encode())  # 重传数据包
            start_time = time.time()  # 重置超时计时器
        ack = client_socket.recv(PACKET_SIZE).decode()
        if ack == f"ACK {i}":  # 接收到正确的确认信号
            print(f"Packet {i} acknowledged")
            break

import socket
import threading

# 创建socket对象并监听连接请求
server_socket = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
server_socket.bind(('localhost', 8000))
server_socket.listen(1)
print("Server is listening...")

# 处理连接请求和数据接收的函数
def handle_connection(client_socket):
    for i in range(10):  # 接收10个数据包并发送确认信号
        data = client_socket.recv(PACKET_SIZE).decode()
        print(f"Received packet {i}: {data}")
        client_socket.send(f"ACK {i}".encode())  # 发送确认信号
    client_socket.close()

# 等待客户端连接并创建线程处理连接请求和数据接收
client_socket, address = server_socket.accept()
print(f"Accepted connection from {address}")
client_thread = threading.Thread(target=handle_connection, args=(client_socket,))
client_thread.start()
``` 六、总结与展望（续）