diff --git a/UDP_broadcast.py b/UDP_broadcast.py new file mode 100644 index 0000000..3b148a0 --- /dev/null +++ b/UDP_broadcast.py @@ -0,0 +1,8 @@ +import socket + +client = socket.socket(socket.AF_INET, socket.SOCK_DGRAM) +client.setsockopt(socket.SOL_SOCKET, socket.SO_BROADCAST, 1) +client.sendto(b'hello server this is ivan', ('172.20.10.15', 10001)) +#data, _ = client.recvfrom(1024) +#print(f"Ответ от сервера: {data.decode()}") +client.close() \ No newline at end of file diff --git a/UDP_chat.py b/UDP_chat.py new file mode 100644 index 0000000..c778fc9 --- /dev/null +++ b/UDP_chat.py @@ -0,0 +1,50 @@ +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() \ No newline at end of file diff --git a/UDP_client.py b/UDP_client.py new file mode 100644 index 0000000..228508f --- /dev/null +++ b/UDP_client.py @@ -0,0 +1,8 @@ +import socket + +client = socket.socket(socket.AF_INET, socket.SOCK_DGRAM) +client.setsockopt(socket.SOL_SOCKET, socket.SO_BROADCAST, 1) +client.sendto(b'hello server this is ivan', ('255.255.255.255', 10001)) +#data, _ = client.recvfrom(1024) +#print(f"Ответ от сервера: {data.decode()}") +client.close() \ No newline at end of file diff --git a/UDP_server.py b/UDP_server.py new file mode 100644 index 0000000..b60690f --- /dev/null +++ b/UDP_server.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) diff --git a/r1_client.py b/r1_client.py new file mode 100644 index 0000000..b30265d --- /dev/null +++ b/r1_client.py @@ -0,0 +1,8 @@ +import socket + +client = socket.socket(socket.AF_INET, socket.SOCK_STREAM) +client.connect(('172.20.10.2', 10000)) +client.sendall(b'hello server') +data = client.recv(1024) +print(f"Ответ от сервера: {data.decode()}") +client.close() \ No newline at end of file diff --git a/r1_server.py b/r1_server.py new file mode 100644 index 0000000..8f14be6 --- /dev/null +++ b/r1_server.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