Сервер на python не хочет подключать больше 1 клиента

Я смог решить свою проблему, используя библиотеку threading. Я его использую для обработки одновременно нескольких клиентов. Когда клиент подключается к моему серверу, создается новый поток (thread), который обрабатывает взаимодействие с этим клиентом, позволяя серверу обрабатывать другие клиенты параллельно.

Однако, хочу предупредить сразу! Если вы захотите использовать мой способ, то нужно учесть, что хоть и библиотека threading позволяет обрабатывать несколько клиентов одновременно, но а так же увеличивает нагрузку на сервер!

Сейчас я буду пробовать правильно организовывать и управлять потоками. Если вы напишите совет, как это сделать лучше, то буду благодареy.

Как теперь выглядит сервер:

import socket
import random
import threading

server_socket = socket.socket(socket.AF_INET, socket.SOCK_STREAM)

host = "localhost"
port = 12345
server_socket.bind((host, port))

server_socket.listen(2)

print("Сервер запущен на порту", port)

clients = {}
lock = threading.Lock()

def handle_client(client_socket, client_address):
    id_value = str(random.randint(100000, 999999))

    with lock:
        clients[id_value] = 100

    client_socket.send(id_value.encode())

    while True:
        data = client_socket.recv(1024).decode()
        print("Получено от клиента:", data)

        if data == "quit":
            break

        if data == "/balance":
            with lock:
                response = "Ваши очки: {}".format(clients[id_value])
                client_socket.send(response.encode())
        elif data.startswith("/trade"):
            _, recipient_id, amount = data.split()
            amount = int(amount)

            with lock:
                if recipient_id in clients and amount <= clients[id_value]:
                    sender_score = clients[id_value]
                    sender_score -= amount
                    clients[id_value] = sender_score

                    recipient_score = clients[recipient_id]
                    recipient_score += amount
                    clients[recipient_id] = recipient_score

                    response = "Очки успешно отправлены"
                    client_socket.send(response.encode())
                else:
                    response = "Ошибка при отправке очков"
                    client_socket.send(response.encode())
        else:
            response = "Неверная команда"
            client_socket.send(response.encode())

    with lock:
        del clients[id_value]

    client_socket.close()

def start_server():
    while True:
        client_socket, client_address = server_socket.accept()
        print("Установлено соединение с клиентом", client_address)

        client_thread = threading.Thread(target=handle_client, args=(client_socket, client_address))
        client_thread.start()

start_server()

Как теперь выглядит код клиента:

import socket

host = "localhost"
port = 12345

client_socket = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
client_socket.connect((host, port))

client_id = client_socket.recv(1024).decode()
print("Подключено к серверу. Ваш идентификатор:", client_id)

while True:
    command = input("Введите команду: ")

    if command.lower() == 'quit':
        client_socket.send('quit'.encode())
        break
    elif command.lower() == '/balance':
        client_socket.send('/balance'.encode())
        response = client_socket.recv(1024).decode()
        print("Ваши очки:", response)
    elif command.startswith('/trade'):
        _, recipient_id, amount = command.split()
        trade_command = "/trade {} {}".format(recipient_id, amount)
        client_socket.send(trade_command.encode())
        response = client_socket.recv(1024).decode()
        print(response)
    else:
        print("Неверная команда")

client_socket.close()

Используйте Фреймворк, а не голый сокет. Например минимальный стандартный

https://docs.python.org/3/library/socketserver.html

Тред сервер чтоб обрабатывать блокирующие вещи одновременно, пример из доков:

import socket
import threading
import socketserver

class ThreadedTCPRequestHandler(socketserver.BaseRequestHandler):

    def handle(self):
        data = str(self.request.recv(1024), 'ascii')
        cur_thread = threading.current_thread()
        response = bytes("{}: {}".format(cur_thread.name, data), 'ascii')
        self.request.sendall(response)

class ThreadedTCPServer(socketserver.ThreadingMixIn, socketserver.TCPServer):
    pass

def client(ip, port, message):
    with socket.socket(socket.AF_INET, socket.SOCK_STREAM) as sock:
        sock.connect((ip, port))
        sock.sendall(bytes(message, 'ascii'))
        response = str(sock.recv(1024), 'ascii')
        print("Received: {}".format(response))

if __name__ == "__main__":
    # Port 0 means to select an arbitrary unused port
    HOST, PORT = "localhost", 0

    server = ThreadedTCPServer((HOST, PORT), ThreadedTCPRequestHandler)
    with server:
        ip, port = server.server_address

        # Start a thread with the server -- that thread will then start one
        # more thread for each request
        server_thread = threading.Thread(target=server.serve_forever)
        # Exit the server thread when the main thread terminates
        server_thread.daemon = True
        server_thread.start()
        print("Server loop running in thread:", server_thread.name)

        client(ip, port, "Hello World 1")
        client(ip, port, "Hello World 2")
        client(ip, port, "Hello World 3")

        server.shutdown()