Python Socket多客户端实例出现'Bad file descriptor'错误及消息异常

1. 消息无法显示的根本原因 #

服务器的广播逻辑存在加密流程错误：客户端发送的是用服务器公钥加密后的密文，但服务器直接将这份密文当作明文，再次用接收方客户端的公钥加密后转发。客户端收到的是双重加密的乱码，自然无法解密显示正常内容。

2. "Bad file descriptor"错误诱因 #

• 客户端接收线程使用except:捕获所有异常，当解密失败（比如收到乱码密文）时，会直接关闭socket；而写入线程仍在循环尝试向已关闭的socket发送数据，触发文件描述符无效的错误。
• 服务器未清理客户端公钥字典：当客户端断开连接时，仅从clients列表移除，但client_public_keys中仍保留无效socket的条目，后续广播可能引发潜在错误。

• 分步验证通信链路：先跳过RSA加密，让客户端发送明文、服务器直接广播，确认基础socket通信正常，再逐步加入加密逻辑。
• 打印关键节点数据：服务器收到客户端消息后，先尝试用服务器私钥解密并打印明文；客户端收到消息后，先打印原始字节内容和长度，排查解密前的数据是否正确。
• 捕获具体异常：替换except:为except 具体异常类型 as e（如rsa.DecryptionError、OSError），打印异常详情，精准定位错误根源。

1. 修复加密解密核心逻辑 #

服务器端修改 #

修正handle_client和broadcast函数，先解密客户端消息再重新加密转发：

def handle_client(client):
    while True:
        try:
            encrypted_message = client.recv(1024)
            # 用服务器私钥解密客户端发来的密文，得到明文
            message = rsa.decrypt(encrypted_message, server_private_key).decode()
            broadcast(message, client)
        except Exception as e:
            print(f"客户端处理错误: {e}")
            with client_lock:
                if client in clients:
                    clients.remove(client)
                if client in client_public_keys:
                    del client_public_keys[client]
            client.close()
            break

def broadcast(message, sender_socket):
    for client in clients:
        if client != sender_socket:
            client_public_key = client_public_keys[client]
            # 用接收方公钥加密明文后发送
            encrypted_message = rsa.encrypt(message.encode(), client_public_key)
            client.send(encrypted_message)

客户端修改 #

细化异常捕获，避免误关闭socket：

def receive():
    while True:
        try:
            encrypted_message = client.recv(1024)
            decrypted_message = rsa.decrypt(encrypted_message, client_private_key).decode()
            print(decrypted_message)
        except rsa.DecryptionError:
            print("消息解密失败：无效的加密内容")
        except OSError as e:
            print(f"连接错误: {e}")
            client.close()
            break
        except Exception as e:
            print(f"未知错误: {e}")
            break

2. 线程安全优化 #

添加线程锁，避免多线程操作客户端列表和公钥字典时出现竞态条件：

# 服务器端新增锁对象
client_lock = threading.Lock()

# 在接收客户端连接时加锁
def receive():
    # ... 其他代码
    while True:
        client, address = server.accept()
        # ... 交换公钥代码
        with client_lock:
            clients.append(client)
            client_public_keys[client] = client_public_key
        thread = threading.Thread(target=handle_client, args=(client,))
        thread.start()

# 在移除客户端时加锁
def handle_client(client):
    while True:
        try:
            # ... 解密代码
        except Exception as e:
            print(f"客户端处理错误: {e}")
            with client_lock:
                if client in clients:
                    clients.remove(client)
                if client in client_public_keys:
                    del client_public_keys[client]
            client.close()
            break

3. 消息长度与加密方式优化 #

RSA加密存在消息长度限制（2048位密钥最多加密245字节数据），若消息过长会触发加密错误。优化方案：

• 限制客户端输入消息长度，比如设置最大字符数为200（转字节后约200字节）。
• 改用混合加密：客户端生成临时AES密钥，用服务器公钥加密AES密钥发送；服务器转发AES密钥给接收方，后续消息用AES加密，解决长消息传输问题。

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