Aus der Steckdose lesen: Ist garantiert, dass mindestens x Bytes gelesen werden?

Question

Ich habe einen seltenen Fehler, der beim Lesen einer Steckdose aufzutreten scheint.

Es scheint, dass ich beim Lesen von Daten manchmal nur 1-3 Bytes eines Datenpakets erhalte, das größer als dieses ist.

Wie ich aus der Pipe-Programmierung gelernt habe, erhalte ich dort immer mindestens 512 Bytes, solange der Absender genügend Daten bereitstellt.

Außerdem überträgt mein Sender jedes Mal, wenn er etwas sendet, mindestens >= 4 Bytes - ich dachte also, dass am Anfang (!!) der Übertragung mindestens 4 Bytes auf einmal empfangen werden.

In 99,9% aller Fälle scheint meine Annahme zuzutreffen ... aber es gibt wirklich seltene Fälle, in denen weniger als 4 Bytes empfangen werden. Es erscheint mir lächerlich, warum das Netzwerksystem dies tun sollte?

Weiß jemand mehr?

Hier ist der von mir verwendete Lesecode:

mySock, addr = masterSock.accept()
mySock.settimeout(10.0)
result = mySock.recv(BUFSIZE)
# 4 bytes are needed here ...
...
# read remainder of datagram
...

Der Absender sendet das komplette Datagramm mit einem Aufruf von send.

Edit: das Ganze funktioniert auf localhost - es sind also keine komplizierten Netzwerkanwendungen (Router etc.) beteiligt. BUFSIZE ist mindestens 512 und der Absender sendet mindestens 4 Bytes.

Answer 1

Wenn der Absender 515 Bytes sendet und Ihre BUFSIZE 512 ist, dann wird der erste Recv 512 Bytes zurückgeben, und der nächste 3 Bytes... Könnte das der Fall sein?

(Dies ist nur einer von vielen Fällen, in denen ein 3-Byte-Recv aus einer größeren Sendung resultiert...)

Answer 2

Wenn Sie immer noch interessiert sind, können Sie sich diese Muster ansehen:

# 4 bytes are needed here ......
# read remainder of datagram...

kann die dumme Sache mit dem Fenster verursachen.

Siehe este aus

Answer 3

Utilice recv_into(...) Methode aus dem socket Modul.

Robert S. Barnes hat das Beispiel in C geschrieben.

Sie können aber Python 2.x mit den Standard-Python-Bibliotheken verwenden:

def readReliably(s,n):
    buf = bytearray(n)
    view = memoryview(buf)
    sz = s.recv_into(view,n)
    return sz,buf

while True:
  sk,skfrom = s.accept()
  sz,buf = io.readReliably(sk,4)
  a = struct.unpack("4B",buf)
  print repr(a)
  ...

Beachten Sie, dass sz zurückgegeben von readReliably() Funktion kann größer sein als n .