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

Новые блоги и статьи Все статьи Все блоги /
Изучаю kubernetes lagorue 13.01.2026 А пригодятся-ли мне знания kubernetes в России?	Сукцессия микоризы: основная теория в виде двух уравнений. anaschu 11.01.2026 https:/ / rutube. ru/ video/ 7a537f578d808e67a3c6fd818a44a5c4/	WordPad для Windows 11 Jel 10.01.2026 WordPad для Windows 11 — это приложение, которое восстанавливает классический текстовый редактор WordPad в операционной системе Windows 11. После того как Microsoft исключила WordPad из. . .	Classic Notepad for Windows 11 Jel 10.01.2026 Old Classic Notepad for Windows 11 Приложение для Windows 11, позволяющее пользователям вернуть классическую версию текстового редактора «Блокнот» из Windows 10. Программа предоставляет более. . .
Почему дизайн решает? Neotwalker 09.01.2026 В современном мире, где конкуренция за внимание потребителя достигла пика, дизайн становится мощным инструментом для успеха бренда. Это не просто красивый внешний вид продукта или сайта — это. . .	Модель микоризы: классовый агентный подход 3 anaschu 06.01.2026 aa0a7f55b50dd51c5ec569d2d10c54f6/ O1rJuneU_ls https:/ / vkvideo. ru/ video-115721503_456239114	Owen Logic: О недопустимости использования связки «аналоговый ПИД» + RegKZR ФедосеевПавел 06.01.2026 Owen Logic: О недопустимости использования связки «аналоговый ПИД» + RegKZR ВВЕДЕНИЕ Введу сокращения: аналоговый ПИД — ПИД регулятор с управляющим выходом в виде числа в диапазоне от 0% до. . .	Модель микоризы: классовый агентный подход 2 anaschu 06.01.2026 репозиторий https:/ / github. com/ shumilovas/ fungi ветка по-частям. коммит Create переделка под биомассу. txt вход sc, но sm считается внутри мицелия. кстати, обьем тоже должен там считаться. . . .

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

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

Решение