socket聊天室 linux

import socket
import threading

HOST = '0.0.0.0'
PORT = 12345

server = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
server.bind((HOST, PORT))
server.listen(5)

clients = []

def broadcast(message):
    for client in clients:
        client.send(message)

def handle_client(client):
    while True:
        try:
            message = client.recv(1024)
            broadcast(message)
        except:
            clients.remove(client)
            client.close()
            break

while True:
    client, addr = server.accept()
    clients.append(client)
    print(f"New connection from {addr}")
    client.send("Welcome to the chat room!".encode('utf-8'))
    thread = threading.Thread(target=handle_client, args=(client,))
    thread.start()

import socket
import threading

HOST = '服务器IP地址'
PORT = 12345

client = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
client.connect((HOST, PORT))

def receive():
    while True:
        try:
            message = client.recv(1024).decode('utf-8')
            print(f"\n{message}")
        except:
            print("An error occurred!")
            client.close()
            break

thread = threading.Thread(target=receive)
thread.start()

while True:
    message = input()
    client.send(message.encode('utf-8'))