From 823855e73741c808ec400489069615bceeaccc9c Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=D0=94=D0=BC=D0=B8=D1=82=D1=80=D0=B8=D0=B9?= Date: Wed, 4 Feb 2026 17:11:31 +0300 Subject: [PATCH] add files --- chat_udp.py | 49 +++++++++++++++++++++++++++++++++++++++++++++++++ client_tcp.py | 8 ++++++++ server_tcp.py | 21 +++++++++++++++++++++ server_udp.py | 10 ++++++++++ 4 files changed, 88 insertions(+) create mode 100644 chat_udp.py create mode 100644 client_tcp.py create mode 100644 server_tcp.py create mode 100644 server_udp.py diff --git a/chat_udp.py b/chat_udp.py new file mode 100644 index 0000000..981edf2 --- /dev/null +++ b/chat_udp.py @@ -0,0 +1,49 @@ +import socket +import threading + +BROADCAST_IP = "255.255.255.255" +PORT = 10000 +BUFFER_SIZE = 1024 + +# Функция для отправки сообщений +def send_messages(sock, username): + while True: + message = input() + if message.startswith("/pm"): + # Личное сообщение в формате /pm <сообщение> + try: + _, target_ip, private_message = message.split(" ", 2) + sock.sendto(f"PM {username}: {private_message}".encode(), (target_ip, PORT)) + except ValueError: + print("Неверный формат команды. Используйте: /pm <сообщение>") + else: + # Отправка сообщения в общий чат + sock.sendto(f"BC {username}: {message}".encode(), (BROADCAST_IP, PORT)) + +# Функция для приема сообщений +def receive_messages(sock): + while True: + data, addr = sock.recvfrom(BUFFER_SIZE) + message = data.decode() + if addr[0] != socket.gethostbyname(socket.gethostname()): + print(f"[{addr[0]}] {message}") + +# Настройка сокета +sock = socket.socket(socket.AF_INET, socket.SOCK_DGRAM) +sock.setsockopt(socket.SOL_SOCKET, socket.SO_BROADCAST, 1) + +# Привязка к порту +sock.bind(("", PORT)) + +# Имя пользователя +username = input("Введите имя пользователя: ") + +# Запуск потоков для отправки и получения сообщений +send_thread = threading.Thread(target=send_messages, args=(sock, username)) +receive_thread = threading.Thread(target=receive_messages, args=(sock,)) + +send_thread.start() +receive_thread.start() + +send_thread.join() +receive_thread.join() diff --git a/client_tcp.py b/client_tcp.py new file mode 100644 index 0000000..b0b51fd --- /dev/null +++ b/client_tcp.py @@ -0,0 +1,8 @@ +import socket + +client = socket.socket(socket.AF_INET, socket.SOCK_STREAM) +client.connect(('172.20.10.11', 10000)) +client.sendall(b'hello server') +data = client.recv(1024) +print(f"Ответ от сервера: {data.decode()}") +client.close() diff --git a/server_tcp.py b/server_tcp.py new file mode 100644 index 0000000..8f14be6 --- /dev/null +++ b/server_tcp.py @@ -0,0 +1,21 @@ +import socket + +server = socket.socket(socket.AF_INET, socket.SOCK_STREAM) +server.bind(("0.0.0.0", 10000)) +server.listen(1) +print("TCP сервер запущен") + +while True: + + conn, addr = server.accept() + print(f"Подключение от {addr}") + + data = conn.recv(1024) + if not data: + break + conn.sendall(data.upper()) + + conn.close() + + if data.upper() == b'EXIT': + break \ No newline at end of file diff --git a/server_udp.py b/server_udp.py new file mode 100644 index 0000000..6d0dc06 --- /dev/null +++ b/server_udp.py @@ -0,0 +1,10 @@ +import socket + +server = socket.socket(socket.AF_INET, socket.SOCK_DGRAM) +server.bind(('0.0.0.0', 10001)) +print("UDP сервер запущен") + +while True: + data, addr = server.recvfrom(1024) + print(f"Сообщение от {addr}: {data.decode()}") + server.sendto(data.upper(), addr) \ No newline at end of file