Как исправить баг socket подключение к двум и более клиентам паралельно через Thread?

Question

[VizerViper]

Вот мой код, по какой-то причине он не принимает второго клиента когда подключен к первому.

https://pastebin.com/gzwJxnHh

Comments

[Модератор]

Код должен быть в вопросе, а не по ссылке на внешний ресурс.

Answer 1

[Vindicar]

Журналируй работу программы, выясняй, как она себя ведёт, и где останавливается.
Кроме того, я бы посоветовал сделать иначе - вызывай accept() в цикле в главном потоке, а новые потоки создавай только тогда, когда клиент подключится, и передавай им сокет клиента как параметр. Тогда не понадобится костыль с is_last_thread_busy.

Comments

[VizerViper]

но как тогда несколько accept() сделать? чтобы два клиента паралельно были подключены?

[Vindicar]

VizerViper, а в чём с этим проблема? accept() ожидает подключения клиента, и возвращает объект-сокет, ассоциированный с этим клиентом. На этом роль accept() заканчивается. Как ты дальше работаешь с этим сокетом - уже твоё дело. Хоть параллельно, хоть последовательно, хоть асинхронно.

[VizerViper]

Vindicar, А как мне вызвать accept() несколько раз? Мне цикл надо делать в отдельной функции?

[Vindicar]

VizerViper, ну можно прямо в теле программы.

def serve_client(client: socket.socket, addr):
    ...  # тут обслуживаешь одно соединение от начала до конца, включая закрытие

def main():
    addr = ("0.0.0.0", 10101)
    server = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
    server.bind(addr)
    server.listen()
    try:
        while True:
            client_sock, client_addr = server.accept()  # ждём соединения
            Thread(
                target=serve_client,  # какую функцию запускаем
                args=(client_sock, client_addr),  # передаём ей параметры
                daemon=True,  # чтобы по завершению главного потока эти потоки тоже завершились
                name=f'Serving_{client_addr}'  # имя особо не влияет, но для красоты можно
            ).start()
    finally:  # была ошибка, или нас закрыли по Ctrl-C
        server.close()  # закрываем сокет
        ...  # тут мы можем сделать ещё что-то перед закрытием

if __name__ == '__main__':
    main()