import socket
import threading

# 保存已連接的客戶端
clients = []

# 處理客戶端消息
def handle_client(client_socket, client_address):
    print(f"[連接成功] {client_address}")
    while True:
        try:
            # 接收消息
            message = client_socket.recv(1024).decode('utf-8')
            if message:
                print(f"[收到消息] {client_address}: {message}")
                # 廣播消息給其他客戶端
                broadcast(message, client_socket)
            else:
                remove_client(client_socket)
                break
        except:
            remove_client(client_socket)
            break

# 廣播消息
def broadcast(message, sender_socket):
    for client in clients:
        if client != sender_socket:
            try:
                client.send(message.encode('utf-8'))
            except:
                remove_client(client)

# 移除客戶端
def remove_client(client_socket):
    if client_socket in clients:
        clients.remove(client_socket)
        print(f"[斷開連接] {client_socket.getpeername()}")

# 服務(wù)端主程序
def server_program():
    server = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
    server.bind(('0.0.0.0', 12345))  # 監(jiān)聽所有 IP，端口號(hào) 12345
    server.listen(5)
    print("[服務(wù)器啟動(dòng)] 正在監(jiān)聽連接...")

    while True:
        client_socket, client_address = server.accept()
        clients.append(client_socket)
        threading.Thread(target=handle_client, args=(client_socket, client_address)).start()

if __name__ == "__main__":
    server_program()

import socket
import threading
import tkinter as tk
from tkinter import scrolledtext

class ChatClient:
    def __init__(self, host='127.0.0.1', port=12345):
        self.client_socket = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
        self.client_socket.connect((host, port))

        # 創(chuàng)建主窗口
        self.root = tk.Tk()
        self.root.title("IM 聊天工具")
        self.root.geometry("400x500")

        # 消息顯示區(qū)域
        self.chat_area = scrolledtext.ScrolledText(self.root, wrap=tk.WORD, state='disabled')
        self.chat_area.pack(padx=10, pady=10, fill=tk.BOTH, expand=True)

        # 消息輸入框
        self.message_entry = tk.Entry(self.root)
        self.message_entry.pack(padx=10, pady=5, fill=tk.X)
        self.message_entry.bind("<Return>", self.send_message)

        # 發(fā)送按鈕
        self.send_button = tk.Button(self.root, text="發(fā)送", command=self.send_message)
        self.send_button.pack(padx=10, pady=5)

        # 啟動(dòng)接收線程
        threading.Thread(target=self.receive_messages, daemon=True).start()

        # 運(yùn)行主窗口
        self.root.mainloop()

    def send_message(self, event=None):
        message = self.message_entry.get()
        if message:
            self.client_socket.send(message.encode('utf-8'))
            self.message_entry.delete(0, tk.END)

    def receive_messages(self):
        while True:
            try:
                message = self.client_socket.recv(1024).decode('utf-8')
                self.display_message(message)
            except:
                break

    def display_message(self, message):
        self.chat_area.config(state='normal')
        self.chat_area.insert(tk.END, message + '\n')
        self.chat_area.yview(tk.END)
        self.chat_area.config(state='disabled')

if __name__ == "__main__":
    ChatClient()

python server.py

python client.py