Python recv multicastは1バイトを返します

Question

recvが期待どおりに動作していません。 私は10バイト（wiresharkで検証）を送信しています。recvは最初のバイトを取得して残りを破棄します（次のsendtoまで）。 これはマルチキャストのものですか？私はユニキャストUDPでこれと同じことをやったことがあり、何の問題もないと確信しています。あなたがいずれかにあなたのバッファサイズを設定するので、あなたは1バイトのみを取得している

import struct, socket, multiprocessing, time 

MCAST_PORT = 62950 
MCAST_GRP = '239.0.0.13' 

def _Rx(self, RXsock, Queue): 
    print "Receiver started" 
    while True: 
     # State machine goes here to parse header and recv (<msglen>) bytes. 
     print "Waiting Rx char...", RXsock 
     char = RXsock.recv(1) # Blocks here after first byte ("1") ??? 
     print "Rx", hex(ord(char)) 



TXsock = socket.socket(socket.AF_INET, socket.SOCK_DGRAM, socket.IPPROTO_UDP) 
TXsock.setsockopt(socket.IPPROTO_IP, socket.IP_MULTICAST_TTL, 2) 

RXsock = socket.socket(socket.AF_INET, socket.SOCK_DGRAM, socket.IPPROTO_UDP) 
RXsock.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR, 1) 
RXsock.bind((MCAST_GRP, MCAST_PORT)) 
mreq = struct.pack("4sl", socket.inet_aton(MCAST_GRP), socket.INADDR_ANY) 
RXsock.setsockopt(socket.IPPROTO_IP, socket.IP_ADD_MEMBERSHIP, mreq) 

RxQueue = multiprocessing.Queue() 
receiver = multiprocessing.Process(target=_Rx, args=(None, RXsock, RxQueue)) 
receiver.daemon = True 
receiver.start() 


TXsock.sendto("09123456789", (MCAST_GRP, MCAST_PORT)) 
time.sleep(3) 

Answer 1

：

はここに私のコード例です。 documentation for socket.recvから

：

一度に受信するデータの最大量は、BUFSIZEによって指定されます。

1024または4096をrecvに設定してみてください。 man page for recvから

：

メッセージが供給され、バッファに収まるには長すぎる場合、過剰バイトはメッセージを受信したソケットの種類に応じて廃棄することができます。

あなたのコメントは、一度に1バイトずつヘッダを解析しようとしていると言います。データグラムの受信が完了したら、ヘッダを解析することができます。

あなたが本当にrecvにsocket.MSG_PEEKフラグを渡してみてください、バッファを部分的に読み取りを行う必要がある場合：

MSG_PEEK

このフラグは、当初からデータを返すために受信動作を引き起こしキューからそのデータを削除することなくキューを受信する。したがって、後続の受信呼び出しは同じデータを返します。

ただし、一度に1バイトを読み取ることはできません。