class Message:
«»»
Класс-Сообщение. Представляет сообщения,

которые будут приходить от клиентов.
«»»

def __init__(self, status_code: str = ‘200’, **data):
# Распаковываем кортеж именованных аргументов в параметры класса.
# Паттерн Builder
for param, value in data.items():
setattr(self, param, value)
self.status_code = status_code  # код ответа сообщения
# время получения сообщения.
self.curr_time = time.strftime(«%Y-%m-%d-%H.%M.%S»,
time.localtime())

def to_json(self):
«»»
Возвращает атрибуты класса и их значения в виде json.
Использует стандартный модуль python — json.
«»»
return json.dumps(self, default=lambda o: o.__dict__, sort_keys=True,
indent=4)

current_connection = None  # текущее соединение

def _add_connection(self, name: str, addr: str):
«»» Добавляет новое соединения в словарь clients»»»
self.current_connection = addr  # адрес, с которого пришло сообщение
self.clients[name] = addr  # добавление клиента

def get_and_register_message(self, data: bytes, addr: str):
«»»
Сохраняет адрес запроса пользователя,
записывается в атрибут data данные из json в виде словаря,
добавляет имя пользователя и адрес в словарь чтобы у нас был
доступ к адресу по имени пользователя который обратился к серверу

:param data — полученные «сырые» данные в виде bytes
:param addr — адрес отправителя данных
:return Message(status_code=’200′, **data) — объект сообщения
«»»
data = dict(json.loads(data.decode(‘utf-8’))) # декодируем данные
self._add_connection(name=data.get(‘sender_name’,
‘Unknown’),
addr=addr) # добавляем/обновляем список клиентов
return Message(status_code=’200′, **data)

def send_message(self, sock, message_obj: Message):
«»»
Отправляет сообщение по всем адресам в словаре
кроме адреса отправившего запрос (эхо)
:param sock — серверный сокет
:param message_obj — объект сообщения
«»»
data = message_obj.to_json() # закодированное в json сообщение
# Отправляем сообщение всем клиентам, кроме текущего:
for client in self.clients.values():
if self.current_connection != client:
sock.sendto(data.encode(‘utf-8’), client)

# Основной цикл работы сервера.
while not quit_server:
try:
# Получаем данные из буфера сокета
recv_data, recv_addr = s.recvfrom(1024)
# Логируем информацию в консоль
sys.stdout.write(recv_data.decode(‘utf-8’))

# Регистрируем сообщение
message = data_handler.get_and_register_message(recv_data,
recv_addr)
# Посылаем сообщение в чат (эхо)
data_handler.send_message(s, message)

except Exception as ex:
# Если произошла ошибка, останавливаем работу сервера.
print(f»Server stopped, because {ex}»)
quit_server = True
# Закрываем серверное соединение.
s.close()

import threading
# Стандартный модуль threading.
# Подробнее: https://docs.python.org/3/library/threading.html

# Глобальная переменная, отвечающая за остановку клиента.
shutdown = False

class Message:
«»»
Класс-Сообщение. Представляет сообщения,
которые будут приходить от клиентов.
«»»

def __init__(self, **data):
# Устанавливаем дополнительные атрибуты сообщения.
self.status = ‘online’
if ‘join’ not in data:
self.join = False

# Распаковываем кортеж именованных аргументов в параметры класса.
# Паттерн Builder
for param, value in data.items():
setattr(self, param, value)

# время получения сообщения:
self.curr_time = time.strftime(«%Y-%m-%d-%H.%M.%S»,
time.localtime())

def to_json(self):
«»»
Возвращает атрибуты класса и их значения в виде json.
Использует стандартный модуль python — json.
«»»
return json.dumps(self, default=lambda o: o.__dict__, sort_keys=True,
indent=4)

Напишем класс Обработчик (ClientHandler), который будет отвечать за получение  и отправку клиентских сообщений.

class ClientHandler:
«»»
Класс-Обработчик с бизнес-логикой клиента.
Реализует методы получения и отображения сообщений
«»»

def __init__(self, server_addr=(‘localhost’, 8888),
client_addr=(‘localhost’, 0)):
global shutdown
# Флаг сигнализирующий об успешном подключении
join = False
# Пытаемся создать соединение, если его еще нет или клиент не остановлен
while not shutdown and not join:
try:
# Имя клиента в чате:
self.name = input(«Name: «).strip()
# Адрес сервера (ip, port) к которому происходит подключение:
self.server_addr = server_addr
# Создание сокета:
self.socket = socket.socket(socket.AF_INET, socket.SOCK_DGRAM)
# Подключение сокета:
self.socket.connect(client_addr)
join = True
# Отправка сообщения о подключении:
connect_message = Message(
join=join,
message=f’User @{self.name} has joint to chat\n’,
sender_name=self.name
)
connect_message_data = connect_message.to_json()
self.socket.sendto(connect_message_data.encode(‘utf-8’),
self.server_addr)
except Exception as ex:
print(f»ClientHandler.__init__: Что-то пошло не так: {ex}»)
shutdown = True

@staticmethod
def show_message(message_obj: Message):
«»»
Выводит полученное сообщение в стандартный поток вывода (консоль)
«»»
if message_obj.join:
# Если сообщение о подключении, то выводим только его:
sys.stdout.write(message_obj.message)
else:
# Иначе, добавляем имя отправителя в вывод:
sys.stdout.write(f’@{message_obj.sender_name}: ‘
f'{message_obj.message}\n’)

def receive(self):
«»»
Получает сообщение из сокета и передает его в обработчик
«»»
global shutdown
# Пока клиент не остановлен
while not shutdown:
try:
# Получаем данные и адрес отправителя
data, addr = self.socket.recvfrom(1024)
data = dict(json.loads(data.decode(‘utf-8’)))
# Создаем объект сообщения из полученных данных:
message = Message(**data)
# Вызываем обработчик показа сообщения:
self.show_message(message)
time.sleep(0.2)
except Exception as ex:
print(f»ClientHandler.receive: Что-то пошло не так: {ex}»)
shutdown = True

def send(self):
«»»
Принимает сообщение из потока ввода консоли,
отправляет его в обработчик и посылает на сервер.
«»»
global shutdown
# Пока клиент не остановлен
while not shutdown:
try:
# Ожидаем ввод данных
input_data = input(«»).strip()
if input_data:
# Создаем объект сообщения из введенных данных:
message = Message(message=input_data,
sender_name=self.name)
# Отправляем данные на сервер:
data = message.to_json()
self.socket.sendto(data.encode(‘utf-8’), self.server_addr)
time.sleep(0.2)
except Exception as ex:
print(f»ClientHandler.send: Что-то пошло не так: {ex}»)
shutdown = True