Как исправить состояние блокировки sock.recv() в python

На основе примера кода из Как вы выполняете многоадресную рассылку UDP в Python? когда я пытаюсь запустить его в своей системе, он работает нормально. Итак, я изменил его с вашими изменениями, это код receiver.py,

import socket
import struct

MCAST_GRP = '239.0.1.104'
MCAST_PORT = 12345
IS_ALL_GROUPS = True

sock = socket.socket(socket.AF_INET, socket.SOCK_DGRAM, socket.IPPROTO_UDP)
sock.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR, 1)
if IS_ALL_GROUPS:
    # on this port, receives ALL multicast groups
    sock.bind(('', MCAST_PORT))
else:
    # on this port, listen ONLY to MCAST_GRP
    sock.bind((MCAST_GRP, MCAST_PORT))

mreq = struct.pack("4sl", socket.inet_aton(MCAST_GRP), socket.INADDR_ANY)

sock.setsockopt(socket.IPPROTO_IP, socket.IP_ADD_MEMBERSHIP, mreq)

print("Entering while loop")
while True:
    print("I'm in while loop")
    print(sock.recv(4096))

Обратите внимание, я немного изменил операторы печати и удалил f, так как он вызывал ошибку. А это код sender.py,

import socket

MCAST_GRP = '239.0.1.104'
MCAST_PORT = 12345
# regarding socket.IP_MULTICAST_TTL
# ---------------------------------
# for all packets sent, after two hops on the network the packet will not 
# be re-sent/broadcast (see https://www.tldp.org/HOWTO/Multicast-HOWTO-6.html)
MULTICAST_TTL = 2

sock = socket.socket(socket.AF_INET, socket.SOCK_DGRAM, socket.IPPROTO_UDP)
sock.setsockopt(socket.IPPROTO_IP, socket.IP_MULTICAST_TTL, MULTICAST_TTL)
sock.sendto(bytes("robot", 'UTF-8'), (MCAST_GRP, MCAST_PORT))

Обратите внимание, что я конвертирую строку robot в байты с кодировкой UTF-8, так как это необходимо при использовании python3 и не требуется в python2. Это мой результат выполнения,

Как видите, когда я вызываю отправителя, получатель отображает строку robot и выполняет цикл while. Это работает нормально.

В случае, если вы уже получаете многоадресные пакеты, которые вы показывали на своем Wireshark, вам необходимо убедиться, что эти пакеты отправляются на тот же номер порта, на котором вы слушаете, то есть 12345 в вашем случае. Если они отправляются на другой номер порта [что, вероятно, так и есть], измените приемник, чтобы он прослушивал этот номер порта, чтобы начать получать эти пакеты.

Попробуйте этот простой код, вы можете установить меньше BUFF_SIZE, если хотите.

#BUFF_SIZE = 4096
BUFF_SIZE = 1024
data = b''
while True:
    #chunk = s.recv(BUFF_SIZE)

    #FOR UDP (@Saeed credits)
    chuck = sock.recvfrom(BUFF_SIZE)

    data += chunk
    if len(chunk) < BUFF_SIZE:
        break

print(data)