You need to enable JavaScript to run this app.
优惠活动
大模型
产品
解决方案
定价
更多

Python客户端遇OSError: [WinError 10038]错误,求解决方案

错误原因及解决办法

错误原因

  1. 连接条件判断逻辑错误:connect_to_server方法中,if self.nickname_text != ""是将TextInput控件实例与空字符串比较,而非控件的文本内容,这个判断永远为真。即使用户未输入昵称,代码也会执行连接逻辑,导致服务器收到空昵称后可能主动断开连接,后续调用send_message时操作的是已关闭的socket,触发10038错误。
  2. 异常后未同步UI状态:receive线程捕获到异常后会关闭socket,但没有禁用发送按钮和消息输入框,用户仍可点击发送,此时操作的是已失效的socket对象,引发错误。
  3. 全局socket生命周期管理不当:socket作为全局变量,一旦被关闭后没有重新初始化,后续所有socket操作都是针对无效对象。

解决办法

1. 修正连接条件判断

将connect_to_server中的判断改为检查控件的文本内容:

def connect_to_server(self):
    # 改为判断文本内容是否为空(去除首尾空格避免空输入)
    if self.nickname_text.text.strip() != "":
        client.connect((self.ip_text.text, 9999))
        # 后续原有代码保持不变

2. 异常处理后禁用发送功能

Kivy的UI操作必须在主线程执行,因此需要用Clock.schedule_once切换线程更新UI状态:
首先导入Clock模块:

from kivy.clock import Clock

然后修改receive方法并新增状态重置函数:

def receive(self):
    stop = False
    while not stop:
        try:
            message = client.recv(1024).decode("utf-8")
            self.chat_text.text += message + "\n"
        except:
            print("ERROR")
            client.close()
            # 切换到主线程更新UI
            Clock.schedule_once(lambda dt: self.reset_connection_state())
            stop = True

def reset_connection_state(self):
    self.send_btn.disabled = True
    self.message_text.disabled = True
    # 可选:恢复连接控件状态,允许重新连接
    self.connect_btn.disabled = False
    self.ip_text.disabled = False

3. 优化socket生命周期(可选)

将全局socket改为类成员变量,每次重新连接时创建新实例,避免无效对象复用:

class MyRoot(BoxLayout):
    def __init__(self):
        super(MyRoot, self).__init__()
        self.client = None  # 用类成员存储socket实例

    def connect_to_server(self):
        if self.nickname_text.text.strip() != "":
            # 每次连接创建新的socket
            self.client = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
            self.client.connect((self.ip_text.text, 9999))
            message = self.client.recv(1024).decode("utf-8")
            if message == "NICK":
                self.client.send(self.nickname_text.text.encode("utf-8"))
                # 后续原有代码保持不变

    def send_message(self):
        # 使用类成员的socket对象发送消息
        self.client.send(f"{self.nickname_text.text}: {self.message_text.text}".encode("utf-8"))

    def receive(self):
        stop = False
        while not stop:
            try:
                message = self.client.recv(1024).decode("utf-8")
                self.chat_text.text += message + "\n"
            except:
                print("ERROR")
                self.client.close()
                Clock.schedule_once(lambda dt: self.reset_connection_state())
                stop = True

内容的提问来源于stack exchange,提问作者Amadou Traore

相关产品推荐
方舟 Agent Plan

超全模态模型 × Harness 升级,最新支持 Deepseek-V4.1-Flash、GLM-5.3 系列、Doubao-Seedream-5.0-pro、Kimi-K3 (部分), 限时 9.9 元起

最近更新时间:2026.08.24 20:46:04