Как реализовать чат между клиентом и сервером, используя UDP и ООП

@Alarih_ · Регистрация: 17.03.2021

Студворк — интернет-сервис помощи студентам

Добрый день, я новичок в изучении пайтона, пытаюсь реализовать клиент серверный обмен сообщениями по протоколу udp, проще говоря чат.
Сервер более-менее работает, за исключением того, что для получения возможности обратно ответить клиенту, сообщение клиент должен отослать несколько раз. А вот с кодом клиента у меня беда: клиент не видит полученное сообщение, понимаю, что в методе listen_server нужно указать адрес и порт отправителя, но я не понимаю где конкретно, а если тупо впихнуть client.bind() в метод, то получаю ошибку Обычно разрешается только одно использование адреса сокета (протокол/сетевой адрес/порт)
Ниже привожу код сервера:

Python
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
class Server:
    def __init__(self):
        self.server = socket.socket(socket.AF_INET, socket.SOCK_DGRAM)
 
    def set_up(self):
        self.server.bind(("127.0.0.1", 9099))
        print("Server is listening")
        self.listening_socket()
 
        listen_thread = threading.Thread(target=self.get_msgs)
        listen_thread.start()
 
        send_thread = threading.Thread(target=self.send_msgs)
        send_thread.start()
 
    def listening_socket(self):
        while True:
            data, addr = self.server.recvfrom(1024)
 
            self.get_msgs(data, addr)
            self.send_msgs(addr)
 
    def get_msgs(self, data, addr):
        get_msg = data.decode("utf-8")
        print(f"User <{addr[0]}> sent {get_msg}")
        if get_msg == 'q':
            print("Другой участник закончил чат, пока!")
 
    def send_msgs(self, addr):
        data, addr = self.server.recvfrom(1024)
        a = input("Ввдите сообщение:  ")
        send_to_client = a.encode("utf-8")
        self.server.sendto(send_to_client, addr)
 
 
if __name__ == "__main__":
    server = Server()
    server.set_up()

Код клиента:

Python
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
class Client:
    def __init__(self):
        self.client = socket.socket(socket.AF_INET, socket.SOCK_DGRAM)
        print("Client connection")
 
    def set_up(self):
        send_thread = Thread(target=self.send_data)
        send_thread.start()
 
        listen_thread = Thread(target=self.listen_server)
        listen_thread.start()
 
    def send_data(self):
        while True:
            msg = input("Введите сообщение:  ").encode("utf-8")
            self.client.sendto(msg, ("127.0.0.1", 9099))
            if msg.decode("utf-8") == 'q':
                print("Вы акончили чат!")
                break
 
    def listen_server(self):
        while True:
            back_msg = self.client.recv(1024).decode("utf-8")  # receive data from client
            print("Полученное сообщение: ", back_msg)
 
 
if __name__ == '__main__':
    client = Client()
    client.set_up()

Подскажите в чем ошибки, может быть я не правильно реализую принципы ООП?

@Welemir1 · 15.10.2021, 06:21

Alarih_, а что ты почитал по сокетам? например дальше 8 строчки в сервере код выполняться не будет, знаешь почему?

почему ты выбрал удп для чата? интересны твои аргументы

@Fudthhh · 15.10.2021, 09:07

Сервер:

Python
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
import asyncio
 
 
class ServerHandler(asyncio.Protocol):
 
    def connection_made(self, transport: asyncio.DatagramTransport) -> None:
        self.transport: asyncio.DatagramTransport = transport
        self.host, self.port = transport.get_extra_info("peername")
        self.on_connect(self.host, self.port)
    
    def data_received(self, response: bytes) -> None:
        self.on_message(self.host, self.port, response.decode("utf-8", "ignore"))
 
    def connection_lost(self, exception: Exception = None) -> None:
        self.on_disconnect(self.host, self.port, str(exception))
    
    def on_connect(self, host: str, port: str) -> None:
        print(f"CONNECTED CLIENT[{host}:{port}]")
    
    def on_message(self, host: str, port: str, message: str) -> None:
        print(f"MESSAGE: {message} FROM: {host}:{port}")
    
    def on_disconnect(self, host: str, port: int, reason: str = None) -> None:
        print(f"DISCONNECTED CLIENT[{host}:{port}] REASON - {reason}")
 
 
class Server:
    def __init__(self, host: str, port: int) -> None:
        self.host, self.port = host, port
 
    def start(self) -> None:
        asyncio.run(self.run())
    
    async def run(self) -> None:
        loop = asyncio.get_event_loop()
        server = await loop.create_server(
            lambda: ServerHandler(), self.host, self.port)
        async with server:
            await server.serve_forever()
 
 
if __name__ == "__main__":
    Server("127.0.0.1", 8888).start()

Проверка:

Python
1
2
3
4
5
6
import socket
 
client = socket.socket()
client.connect(("127.0.0.1", 8888))
client.send(b"Hello, world!")
client.close()

Результат:

Code
1
2
3
CONNECTED CLIENT[127.0.0.1:16124]
MESSAGE: Hello, world! FROM: 127.0.0.1:16124
DISCONNECTED CLIENT[127.0.0.1:16124] REASON - None

Новые блоги и статьи Все статьи Все блоги /
Жизнь в неопределённости kumehtar 23.03.2026 Жизнь — это постоянное существование в неопределённости. Например, даже если у тебя есть список дел, невозможно дойти до точки, где всё окончательно завершено и больше ничего не осталось. В принципе,. . .	Модель здравоСохранения: работники работают быстрее после её введения. anaschu 23.03.2026 geJalZw1fLo Корпорация до введения программа здравоохранения имела много невыполненных работниками заданий, после введения программы количество заданий выросло. Но на выплатах по больничным это. . .	1С: Контроль уникальности заводского номера Maks 23.03.2026 Алгоритм контроля уникальности заводского (или серийного) номера на примере документа выдачи шин для спецтехники с табличной частью. Данные берутся из регистра сведений, по которому настроено. . .	Хочу заставить корпорации вкладываться в здоровье сотрудников: делаю мат модель здравосохранения anaschu 22.03.2026 e7EYtONaj8Y Z4Tv2zpXVVo https:/ / github. com/ shumilovas/ med2. git
1С: Программный отбор элементов справочника по группе Maks 22.03.2026 Установка программного отбора элементов справочника "Номенклатура" из модуля формы документа. В качестве фильтра для отбора справочника служит группа номенклатуры. Отбор по наименованию группы. . .	Как я обхитрил таблицу Word Alexander-7 21.03.2026 Когда мигает курсор у внешнего края таблицы, и нам надо перейти на новую строку, а при нажатии Enter создается новый ряд таблицы с ячейками, то мы вместо нервных нажатий Энтеров мы пишем любые буквы. . .	Krabik - рыболовный бот для WoW 3.3.5a AmbA 21.03.2026 без регистрации и смс. Это не торговля, приложение не содержит рекламы. Выполняет свою непосредственную задачу - автоматизацию рыбалки в WoW - и ничего более. Однако если админы будут против -. . .	1С: Программный отбор элементов справочника по значению перечисления Maks 21.03.2026 Установка программного отбора элементов справочника "Сотрудники" из модуля формы документа. В качестве фильтра для отбора служит значение перечислений. / / Событие "НачалоВыбора" реквизита на форме. . .

@Welemir1 Автоматизируй это! 7392 / 4819 / 1246 Регистрация: 30.03.2015 Сообщений: 13,694 Записей в блоге: 29
	15.10.2021, 06:21
	Alarih_, а что ты почитал по сокетам? например дальше 8 строчки в сервере код выполняться не будет, знаешь почему? почему ты выбрал удп для чата? интересны твои аргументы 0

Как реализовать чат между клиентом и сервером, используя UDP и ООП

Решение