еще не сделал но логика рабочая
import socket
from _thread import *
HEADER_SIZE = 10
sock_serv = socket.socket()
sock_serv.bind(('localhost', 444))
sock_serv.listen(5)
def client_handler(conn):
full_message = b''
while True:
data = conn.recv(10)
full_message += data
# когда приехал полный заголовок
if len(full_message) >= 10:
# декодирум длину из заголовка и получаем полный размер пакета
msg_len = HEADER_SIZE + int(full_message[:HEADER_SIZE])
# набежал ли полный пакет?
if len(full_message) >= msg_len:
# выдираем из него данные
payload = full_message[HEADER_SIZE:msg_len]
print(payload.decode('utf-8'))
# удаляем пакет из буфера и суем в него всё что после
full_message = full_message[msg_len:]
while True:
connection, address = sock_serv.accept()
print(f'Got connection from {address}')
start_new_thread(client_handler, (connection,))
где выход из потока?
ОКей
дальше, если после запуска сервера, с несколькими активными клиентами ты нажмешь Ctrl+C (или что там у вас под виндой), что произойдет?
оборвется соединение ?
я думаю он про то что у тебя нет обработки принудительной остановки сервера. https://blog.miguelgrinberg.com/post/how-to-kill-a-python-thread
Я понял 😂
Обсуждают сегодня