首先，咱们来拆解你遇到的 OSError: [Errno 98] Address already in use 问题：

错误根源分析 #

1. 初始代码问题：你的初始多线程代码里，所有线程都尝试绑定同一个固定端口 5060。UDP套接字绑定端口后，同一机器上其他进程/线程不能再绑定这个端口，这直接导致了冲突报错。
2. 修改后代码的不足：你改成循环绑定6000-7000的端口，但这段代码是串行执行的，一次只运行一个客户端，根本没达到并行模拟多客户端的目的。而且每个socket用完后没有显式关闭，可能导致端口没有及时释放，后续循环仍可能碰到占用问题。

正确的实现思路 #

要在同一机器上模拟大量UDP客户端，你需要：

• 每个客户端（线程/进程）使用独立的套接字，要么让系统自动分配临时端口（不需要手动bind），要么手动绑定唯一的端口（确保端口不重复）。
• 用多线程/多进程实现并行运行，同时模拟多个客户端。
• 每个套接字使用完毕后显式关闭，避免端口泄漏。

可行代码示例 #

方案1：让系统自动分配端口（推荐，无需手动管理端口） #

这种方式不需要手动绑定端口，系统会为每个客户端套接字自动分配一个空闲的临时端口，完全避免端口冲突：

import threading
import socket
import time

def udp_client(server_host, server_port, client_id):
    # 创建UDP套接字，不手动绑定端口，系统自动分配
    sock = socket.socket(socket.AF_INET, socket.SOCK_DGRAM)
    try:
        # 发送连接请求（UDP无连接，这里只是发送测试数据）
        msg = f"Client {client_id} connection request".encode()
        sock.sendto(msg, (server_host, server_port))
        print(f"[{time.ctime()}] Client {client_id} sent request")
        
        # 接收服务器回复
        data, server_addr = sock.recvfrom(4096)
        print(f"[{time.ctime()}] Client {client_id} received: {data.decode()}")
    except Exception as e:
        print(f"Client {client_id} error: {e}")
    finally:
        # 确保套接字关闭，释放端口
        sock.close()

if __name__ == "__main__":
    SERVER_HOST = "192.168.1.cc"  # 替换为你的服务器IP
    SERVER_PORT = 4242
    CLIENT_COUNT = 10  # 要模拟的客户端数量，可修改为1000
    
    # 启动多个客户端线程
    threads = []
    for i in range(CLIENT_COUNT):
        t = threading.Thread(target=udp_client, args=(SERVER_HOST, SERVER_PORT, i))
        threads.append(t)
        t.start()
    
    # 等待所有线程完成
    for t in threads:
        t.join()
    
    print("All clients finished")

方案2：手动绑定指定范围的端口 #

如果你必须手动指定客户端端口范围，需要确保每个线程绑定唯一的端口，并且处理可能的端口冲突（比如端口被其他进程占用）：

import threading
import socket
import time

def udp_client_with_port(server_host, server_port, client_port, client_id):
    sock = socket.socket(socket.AF_INET, socket.SOCK_DGRAM)
    try:
        # 绑定指定的客户端端口
        sock.bind(("0.0.0.0", client_port))
        print(f"[{time.ctime()}] Client {client_id} bound to port {client_port}")
        
        # 发送请求
        msg = f"Client {client_id} (port {client_port}) connection request".encode()
        sock.sendto(msg, (server_host, server_port))
        
        # 接收回复
        data, server_addr = sock.recvfrom(4096)
        print(f"[{time.ctime()}] Client {client_id} received: {data.decode()}")
    except OSError as e:
        if e.errno == 98:
            print(f"Client {client_id}: Port {client_port} already in use, skipping")
        else:
            print(f"Client {client_id} error: {e}")
    finally:
        sock.close()

if __name__ == "__main__":
    SERVER_HOST = "192.168.1.cc"
    SERVER_PORT = 4242
    START_PORT = 6000
    END_PORT = 7000  # 模拟1000个客户端（6000-7000共1001个端口）
    
    threads = []
    for port in range(START_PORT, END_PORT + 1):
        client_id = port - START_PORT
        t = threading.Thread(target=udp_client_with_port, args=(SERVER_HOST, SERVER_PORT, port, client_id))
        threads.append(t)
        t.start()
        # 可选：添加短暂延迟，避免瞬间创建大量线程导致系统资源紧张
        # time.sleep(0.01)
    
    for t in threads:
        t.join()
    
    print("All clients finished")

关键注意事项 #

• UDP无连接特性：UDP不需要像TCP那样建立连接，sendto直接发送数据即可，客户端不需要提前绑定端口（除非你需要固定客户端端口）。
• 端口释放：一定要在finally块中关闭套接字，确保端口被及时释放，避免泄漏。
• 线程数量：如果要模拟上千个客户端，建议使用线程池（比如concurrent.futures.ThreadPoolExecutor）来管理线程，避免创建过多线程导致系统资源耗尽。

内容的提问来源于stack exchange，提问作者KSp