from subprocess import Popen, CREATE_NEW_CONSOLE
import os

process_list = [] #сюда будут попадать все клиентские процессы

while True:
user = input("Запустить 10 клиентов (start) / Закрыть клиентов (close) / Выйти (quit) ")

if user == 'quit': #если пользователь ввел quit, то останавливаем цикл
break
elif user == 'start': #если пользователь ввел start, то запускаем процессы в консоли
for _ in range(10):
process_list.append(Popen('python client.py',
creationflags=CREATE_NEW_CONSOLE)) #CREATE_NEW_CONSOLE - открываем каждый процесс в новой консоли

print(' Запущено 10 клиентов')
elif user == 'close': #если пользователь ввел close, то дропаем процессы
for process in process_list:
process.kill()
process_list.clear() #очищаем список

# серверная часть (server.py)

import select
from socket import socket, AF_INET, SOCK_STREAM

def clients_read(r_clients, clientlist): # чтение клиентских запросов

responses = {} # Словарь ответов сервера вида {сокет: запрос}

#for sock in clients:
for sock in r_clients:
try:
data = sock.recv(1024).decode('utf-8')
responses[sock] = data #записываем ключ в словаре responses  в виде данных
except:
print('Клиент {} {} отключился'.format(sock.fileno(), sock.getpeername()))
clientlist.remove(sock)

return responses

def clients_write(requests, w_clients, all_clients): # ответы клиентам на их запросы

for sock in w_clients:
if sock in requests:
try:
# Подготовить и отправить ответ сервера
response = requests[sock].encode('utf-8')
# Ответ сделаем чуть непохожим на оригинал
sock.send(response.lower())
except: # Сокет недоступен, клиент отключился
print('Клиент {} {} отключился'.format(sock.fileno(), sock.getpeername()))
sock.close()
all_clients.remove(sock)

def mainserver():
address = ('localhost', 8888)
clients = []

s = socket(AF_INET, SOCK_STREAM)
s.bind(address)
s.listen(5)
s.settimeout(0.2) # Таймаут для операций с сокетом
while True:
try:
conn, addr = s.accept() # Проверка подключений
except OSError as e:
pass # timeout вышел
else:
print("Получен запрос на соединение от %s" % str(addr))
clients.append(conn)
finally:
# Проверить наличие событий ввода-вывода
wait = 10
r = []
w = []
try:
r, w, e = select.select(clients, clients, [], wait)
except:
pass # Ничего не делать, если какой-то клиент отключился

requests = clients_read(r, clients) # Принимаем запросы клиентов
if requests: #если есть запрос
clients_write(requests, w, clients) # то формируем ответ и отправляем его

print('Server is RUN')
mainserver()

# Клиентская часть (client.py)
from socket import *
#from select import select
import sys

PLACE = ('localhost', 8888) #куда подключаемся

def client():
with socket(AF_INET, SOCK_STREAM) as sock: # Создать сокет TCP # конструкция with (менеджер контекста) означает, что сокет будет автоматически закрыт
sock.connect(PLACE) # Коненктимся с сервером
while True:
message = input('Ваше сообщение: ')
sock.send(message.encode('utf-8')) # отправляем, кодировав в байты
receive = sock.recv(1024).decode('utf-8') # принимаем, декодировав в юнион
print('Ответ:', receive)

if __name__ == '__main__':
client()