如何让基于customTkinter的GUI向Socket服务器发送多条消息？

我在尝试让线程与customTkinter GUI配合时遇到了问题：普通客户端可以连续发送多条消息而无需等待响应，但GUI做不到这点。我试过用线程，但似乎和customTkinter不兼容，现在已经把GUI代码恢复到尝试线程之前的版本。我曾在send_message函数里加过线程代码，但陷入了困境，不知道怎么实现让Socket服务器接收来自这个GUI的多条消息，以下是我的GUI代码：

import customtkinter as ctk
import socket
import threading


SERVER_ADDRESS = '10.0.36.9'
SERVER_PORT = 1234

chat = ctk.CTk()
chat.geometry('900x600')
ctk.set_appearance_mode('light')


chat.columnconfigure(0, weight=1)
chat.columnconfigure(1, weight=1)
chat.columnconfigure(2, weight=1)

chat.rowconfigure(0, weight=0)
chat.rowconfigure(1, weight=2)
chat.rowconfigure(2, weight=1)
chat.rowconfigure(3, weight=0)


def send_message():
    message = message_entry.get()

    client_socket = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
    client_socket.connect((SERVER_ADDRESS, SERVER_PORT))
    client_socket.send(message.encode('utf-8'))
    response = client_socket.recv(1234).decode('utf-8')

    return response

def GUI():
    chat.columnconfigure(0, weight=1)
    chat.columnconfigure(1, weight=1)
    chat.columnconfigure(2, weight=1)

    chat.rowconfigure(0, weight=0)
    chat.rowconfigure(1, weight=2)
    chat.rowconfigure(2, weight=1)
    chat.rowconfigure(3, weight=0)

    send_button = ctk.CTkButton(chat, text="send", command=send_message, hover=True, width=100)
    send_button.grid(row=3, column=3, columnspan=1, padx=20, pady=20, sticky="ew")

    message_entry = ctk.CTkEntry(master=chat, placeholder_text="Message Here...", width=300)
    message_entry.grid(row=3, column=2, columnspan=1, sticky="ew", pady=20)

while True:
    # insert code for receiving new network messages
    server_socket = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
    server_socket.listen(5)
    chat.update_idletasks()
    chat.update()
# chat.mainloop()

你的核心问题是GUI线程被网络阻塞操作卡住，加上Socket使用逻辑错误（每次发消息新建连接、客户端错误监听端口）。下面是修复后的可运行实现：

关键修复点 #

• 网络操作（连接、收发消息）全部放到后台线程，不阻塞主GUI线程
• 保持一个长连接，避免重复创建Socket
• 用chat.after()在主线程更新GUI，符合customTkinter的线程安全要求

修复后的完整代码 #

import customtkinter as ctk
import socket
import threading

SERVER_ADDRESS = '10.0.36.9'
SERVER_PORT = 1234

# 全局客户端Socket，维持长连接
client_socket = None

def init_client():
    """初始化服务器连接，启动接收消息线程"""
    global client_socket
    try:
        client_socket = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
        client_socket.connect((SERVER_ADDRESS, SERVER_PORT))
        # 后台线程持续接收服务器消息，daemon=True随GUI关闭自动结束
        threading.Thread(target=receive_messages, daemon=True).start()
    except Exception as e:
        print(f"连接失败：{e}")

def receive_messages():
    """后台线程接收服务器消息，通过after回调更新GUI"""
    while True:
        try:
            if client_socket:
                response = client_socket.recv(1024).decode('utf-8')
                if response:
                    # 回到主线程处理GUI更新（示例：打印到控制台，可替换为更新聊天框）
                    chat.after(0, lambda msg=response: print(f"服务器回复：{msg}"))
        except Exception as e:
            print(f"接收消息出错：{e}")
            break

def send_message():
    """发送消息逻辑，放到线程执行避免阻塞GUI"""
    message = message_entry.get().strip()
    if not message or not client_socket:
        return
    
    # 清空输入框
    message_entry.delete(0, ctk.END)
    
    # 单独线程处理发送操作
    def send_task():
        try:
            client_socket.send(message.encode('utf-8'))
        except Exception as e:
            print(f"发送失败：{e}")
    
    threading.Thread(target=send_task, daemon=True).start()

# 初始化GUI
chat = ctk.CTk()
chat.geometry('900x600')
ctk.set_appearance_mode('light')

# 布局配置
chat.columnconfigure(0, weight=1)
chat.columnconfigure(1, weight=1)
chat.columnconfigure(2, weight=1)
chat.columnconfigure(3, weight=0)

chat.rowconfigure(0, weight=0)
chat.rowconfigure(1, weight=2)
chat.rowconfigure(2, weight=1)
chat.rowconfigure(3, weight=0)

# 创建组件
send_button = ctk.CTkButton(chat, text="发送", command=send_message, hover=True, width=100)
send_button.grid(row=3, column=3, padx=20, pady=20, sticky="ew")

message_entry = ctk.CTkEntry(master=chat, placeholder_text="输入消息...", width=300)
message_entry.grid(row=3, column=2, sticky="ew", pady=20)

# 启动客户端连接
init_client()

# 启动GUI主循环
chat.mainloop()

代码说明 #

1. 长连接初始化：启动GUI时通过init_client()创建一次Socket连接，同时启动后台接收线程
2. 接收线程：在后台持续监听服务器消息，收到后用chat.after()通知主线程更新GUI（customTkinter不允许非主线程操作组件）
3. 发送逻辑：点击发送按钮时，把消息发送操作放到线程中执行，GUI不会被阻塞，可连续发送多条消息
4. 移除错误监听：原代码中客户端创建server_socket.listen()是错误逻辑，客户端只需连接服务器，不需要监听端口

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