Python套接字多客户端-聊天应用

import socket
import threading

HOST = '127.0.0.1'
PORT = 65432

clients = []

def handle_client(conn, addr):
    print(f"New connection from {addr}")
    while True:
        try:
            data = conn.recv(1024)
            if not data:
                break
            for client in clients:
                if client != conn:
                    client.sendall(data)
        except:
            break
    conn.close()
    clients.remove(conn)

with socket.socket(socket.AF_INET, socket.SOCK_STREAM) as s:
    s.bind((HOST, PORT))
    s.listen()
    print(f"Server started on {HOST}:{PORT}")
    while True:
        conn, addr = s.accept()
        clients.append(conn)
        threading.Thread(target=handle_client, args=(conn, addr)).start()

import socket
import threading

HOST = '127.0.0.1'
PORT = 65432

def receive_messages(sock):
    while True:
        try:
            data = sock.recv(1024)
            if not data:
                break
            print(f"\nReceived: {data.decode('utf-8')}")
        except:
            break

with socket.socket(socket.AF_INET, socket.SOCK_STREAM) as s:
    s.connect((HOST, PORT))
    threading.Thread(target=receive_messages, args=(s,)).start()
    while True:
        message = input("Enter message: ")
        s.sendall(message.encode('utf-8'))

lock = threading.Lock()

def handle_client(conn, addr):
    with lock:
        clients.append(conn)
    # ... 其他代码 ...