Как реализовать чат между клиентом и сервером, используя 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

Новые блоги и статьи Все статьи Все блоги /
Валидация и контроль данных табличной части документа перед записью Maks 22.04.2026 Алгоритм из решения ниже реализован на примере нетипового документа, разработанного в КА2. Задача: контроль и валидация данных табличной части документа перед записью с учетом регламента компании. . .	Отчёт о затраченных материалах за определенный период с макетом печатной формы Maks 21.04.2026 Отчёт из решения ниже размещён в конфигурации КА2. Задача: разработка отчёта по затраченным материалам за определённый период, с возможностью вывода печатной формы отчёта с шапкой и подвалом. В. . .	Отчёт о спецтехнике находящейся в ремонте Maks 20.04.2026 Отчёт из решения ниже размещен в конфигурации КА2. Задача: отобразить спецтехнику, которая на данный момент находится в ремонте. Есть нетиповой документ "Заявка на ремонт спецтехники" который. . .	Памятка для бота и "визитка" для читателей "Semantic Universe Layer (Слой семантической вселенной)" Hrethgir 19.04.2026 Сгенерировано для краткого описания по случаю сборки и компиляции скелета серверного приложения. И пусть после этого скажут, что статьи сгенерированные AI - туфта и не интересно. И это не реклама -. . .
Запрет удаления строк ТЧ документа при определённом условии Maks 19.04.2026 Алгоритм из решения ниже реализован на примере нетипового документа "Аккумуляторы", разработанного в конфигурации КА2. У данного документа есть ТЧ, в которой в зависимости от прав доступа. . .	Модель заражения группы наркоманов alhaos 17.04.2026 Условия задачи сформулированы тут Суть: - Группа наркоманов из 10 человек. - Только один инфицирован ВИЧ. - Колются одной иглой. - Колются раз в день. - Колются последовательно через. . .	Мысли в слух. Про "навсегда". kumehtar 16.04.2026 Подумалось тут, что наверное очень глупо использовать во всяких своих установках понятие "навсегда". Это очень сильное понятие, и я только начинаю понимать край его смысла, не смотря на то что давно. . .	My Business CRM MaGz GoLd 16.04.2026 Всем привет, недавно возникла потребность создать CRM, для личных нужд. Собственно программа предоставляет из себя базу данных клиентов, в которой можно фиксировать звонки, стадии сделки, а также. . .

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

Опции темы

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

Решение