Как отправить сообщение всем подключенным клиентам?

Question

[Алексей Фобиус]

Как отправить сообщение всем подключенным клиентам, после того, как я его получил на сервер?

код сервера :

import socket

s = socket.socket(socket.AF_INET, socket.SOCK_DGRAM)
s.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR, 1)
s.setsockopt(socket.SOL_SOCKET, socket.SO_BROADCAST, 1)
s.bind(('0.0.0.0',3535))

print('[ Start Server ]')

while True:
    message = s.recv(128).decode()               
    print(message)

код клиента :

import socket


sock = socket.socket(socket.AF_INET, socket.SOCK_DGRAM)
sock.setsockopt(socket.SOL_SOCKET, socket.SO_BROADCAST, 1)

while True:
    msg = input('введите текст сообщения : ')
     sock.sendto(msg.encode(), ('0.0.0.0',3535))

Comments

[Алексей Черемисин]

Dr. Bacon, для UDP и броадкаста? Ну-ну...

Answer 1

[Алексей Черемисин]

Так у вас UDP сокет, поэтому со стороны клиента нужно сделать тоже самое, что и со стороны сервера bind(), потом, как-то серверу передать порт, на котором клиент будет слушать ответ от сервера. Запустить поток, который будет обслуживать входящие сообщения от сервера. (Итого, два потока, один для посылки серверу, второй для ответов от сервера).
На стороне сервера использовать не recv() а data, addr = sock.recvfrom(128), получая сразу IP-адрес клиента. Вот эти адреса прихраниваете в массивчик, они и будут вашими клиентами.

Можно изобрести свой протокол хендшейка, где первое сообщение будет порт (и чего нибудь служебное, типа public-ключа), на котором слушает клиент (конечно порт клиента можно забить в код навечно).

Comments

[Алексей Фобиус]

пробовал, когда запускаю ругается на бинд, говорит что нельзя к одному привязать несколько (айпи я не указывал, только порт)

[Алексей Черемисин]

Алексей Фобиус, Все просто, наверняка вы и клиент и сервер запускаете на одном компьютере! Укажите для клиента другой порт, например 3536.

[Алексей Фобиус]

Алексей Черемисин, да не, там проблема была чуть в другом, я справился

у меня вопрос теперь возник, как мне одновременно слушать и иметь возможность написать?

это видимо по броадкастам как-то разделять надо, в коих я ничего не понимаю

просто сейчас, я могу писать сообщение, и ждать ответа, затем так же писать, и снова ждать ответа

мне нужно сделать эти процессы синхронными

[Алексей Черемисин]

Алексей Фобиус,

мне нужно сделать эти процессы синхронными

- асинхронными!
Вариантов два:
- использовать модуль select и слушать сразу несколько потоков, есть одно но - плохо работает в винде
- запустить поток для прослушивания ответа от сервера https://webdevblog.ru/vvedenie-v-potoki-v-python/
Но это я вам уже писал в самом ответе..