python recvfrom_intoについて

Question

#やりたいこと
UDPでsocket通信させたいです．
recvfrom_into()でヘッダのみを読み込みたいのですが，エラーが出てしまいます．
ご回答よろしくお願いします．

#エラー

Traceback (most recent call last):
  File "server_udp.py", line 17, in <module>
    recvfrom_into(recv_data, recv_header.length)
NameError: name 'recvfrom_into' is not defined

#サンプルコード

import socket
from ctypes import *

MYADDR = "127.0.0.1"
MYPORT = 50002
BUFSIZE = 1024


class MessageHeader(Structure):
    _fields_ = [
        ('type', c_uint8),
        ('length', c_uint16),
    ]


if __name__ == "__main__":
    s = socket.socket(socket.AF_INET, socket.SOCK_DGRAM)
    s.bind((MYADDR, MYPORT))

    while True:
        recv_header = MessageHeader()
        nbytes, addr = s.recvfrom_into(recv_header, sizeof(MessageHeader))
        recv_data = b''
        recvfrom_into(recv_data, recv_header.length)
        print(recv_data.decode() + "\n")

Answer 1

バイトオーダーが環境依存になるので Structure の代わりに
BigEndianStructure / LittleEndianStructure を使いましょう。
簡易的には struct モジュールも使えます。

バイトオーダが異なる場合、読みだしたデータの値が期待通りではなくなります。

---

エラーの原因については、recvfrom_into -> s.recvfrom_into ですが
２回めの方は、使い方にも誤りがあります。

引数に指定するのは、「予めメモリを確保した」「書込み可能な」バッファーです。
bytes オブジェクトは読み出しのみなので、ここでは bytearray 等を用います。

若しくは、固定長データの読み出しではないので recvfrom_into ではなく
バッファの確保を読み出しメソッドに任せて recvfrom で
任意の長さのバイトを読み出しでも良いです。

---

戻り値の確認

必ずメソッドの戻り値の送信した・受信したバイト数を確認。
ローカル環境でのテストでは再現しないことが多い。

また、UDPではパケットの到達保証がありません。送信側次第ですが、
順序も保証されないので、TCPのように ヘッダ部分の後にデータ本体を読み込む
みたいな事は成立しないケースもあります。

Comments

[succulent]

ご丁寧に解説して頂きありがとうございます！
ご指摘の通り，baffer typeでエラーに遭遇しておりました...加えて感謝いたします.
追加での質問なのですが，受信を続けて書いた場合clientの送信の度に1つのrecvしか動作しないのですが，Client1度の送信でヘッダを受信したのちデータも受信するにはどうしたらよいでしょうか？

```
#現状 (server terminal)
46 # client 送信 (header表示)
"test" # client 送信2回目 (data表示)

# やりたいこと
46 # client 送信1回目
"test"
46 # client 送信2回目
"test"
```

[teamikl]

別の質問にも回答を書いたのですが、
それをするには TCP を使いましょうってなってきます。
UDP では到達順序なども保証されません。
送信パケットを分割した場合 header の後に data が届くとは限らない。

[succulent]

複数の質問への回答，本当にありがとうございます．
今回はheaderとdataを分割せず1つのパケットとして送信しています．その場合も順序は変わってくるのでしょうか？

[teamikl]

１つのパケットなら中のデータの順序が変わるようなことはありません。
パケットが届くかどうかはともかく、
チェックサムがあるので、パケット単位での中のデータは保証されます。

同じパケットなら、予め大きめのバッファサイズを指定して読み出し、
独自にバッファリングをするといった対応が必要です。(UDPの場合)
一度目の recvfrom でヘッダ部分のみを読み出すと、残りのdata部分は破棄されてます。

[succulent]

確認したところ
1 # client 送信1回目 (header:1, data:aa)
bb # client 送信2回目 (header:2, data:bb)
となっていた原因が理解出来ました．
recvfromでまとめて受信してから，headerとdataを分けたいと思います．

Answer 2

NameError: name 'recvfrom_into' is not defined

というエラーについてですが、

        recvfrom_into(recv_data, recv_header.length)

は正しくは

        s.recvfrom_into(recv_data, recv_header.length)

ではないでしょうか。

Comments

[succulent]

ありがとうございます！こんなミスで失礼しました...