Вы получили более 4 байтов, и для распаковки требуется ровно четыре байта для '>I'. TCP - это потоковый протокол. Если сервер отправляет 4 байта для размера сообщения, а затем отправляет сообщение, а вы recv(BUFFER_SIZE), вы получите от 1 до BUFFER_SIZE байтов или ноль байтов, если сервер закрыл соединение. Вы должны проверить, что у вас есть по крайней мере 4 байта в буфере, затем удалить и преобразовать эти байты в длину, затем продолжать буферизовать больше вызовов recv, пока не получите количество байтов, указанное длиной сообщения.
Вот наглядный пример. Следующий серверный код ожидает клиентского соединения и затем отправляет случайное число из 1-1000 байтов значения 0, затем случайное число из 1-1000 байтов значения 1, повторяя до конечного байта значения 255. Каждый поток то же значение отправляется в другом вызове .sendall().
Клиент просто подключится к серверу и вызовет .recv(4096), распечатав, сколько байтов он получил вместе с уникальным набором полученных номеров. Получение одного и того же номера на два разных вызова .recv указывает на то, что данные были распределены по двум получателям. Получив более одного числа, recv указывает, что посылки были объединены в получении.
server.py
from socket import *
import random
s=socket()
s.bind(('',5000))
s.listen()
while True:
c,a = s.accept()
print(f'Connection from {a}')
with c:
for i in range(256):
length = random.randint(1,1000)
data = bytes([i] * length)
c.sendall(data)
print('Disconnected.')
client.py:
from socket import *
s=socket()
s.connect(('192.168.1.5',5000))
while True:
data = s.recv(4096)
if not data: break
print(len(data),set(data))
Вывод:
473 {0} # All the zeros were recv'd in the first recv
1704 {1, 2, 3} # Three sends were combined
4096 {4, 5, 6, 7, 8, 9, 10, 11, 12} # 12s were split across two packets
4096 {12, 13, 14, 15, 16}
4096 {16, 17, 18, 19, 20, 21, 22, 23, 24, 25}
4096 {32, 33, 34, 35, 36, 25, 26, 27, 28, 29, 30, 31}
4096 {36, 37, 38, 39, 40, 41, 42}
4096 {42, 43, 44, 45, 46, 47, 48, 49, 50, 51} # 51 was split across recvs.
3495 {51, 52, 53, 54, 55, 56, 57, 58, 59} # Didn't get a full 4096.
4096 {64, 65, 66, 60, 61, 62, 63} # Note: sets are unordered, so the numbers aren't sequential
1472 {66, 67, 68, 69, 70, 71} # Rarely gets the full 4096 after this point.
839 {72, 73}
1577 {74, 75, 76}
1610 {80, 77, 78, 79}
1566 {81, 82}
124 {83}
285 {84}
2087 {85, 86, 87}
4096 {88, 89, 90, 91, 92, 93}
168 {93}
1270 {94, 95}
1737 {96, 97, 98}
1593 {99, 100, 101}
1674 {102, 103}
1290 {104, 105, 106, 107}
1266 {108, 109}
3499 {110, 111, 112, 113, 114, 115}
2694 {116, 117, 118, 119, 120, 121, 122} # split 122s even without a full buffer.
666 {122, 123}
1532 {124, 125, 126, 127}
1065 {128, 129}
1121 {130, 131}
1601 {132, 133, 134, 135}
1507 {136, 137}
1055 {138, 139}
1663 {140, 141}
1286 {144, 145, 142, 143}
1796 {146, 147, 148}
2199 {149, 150, 151}
1636 {152, 153, 154}
809 {155, 156}
1462 {157, 158}
576 {159}
656 {160, 161}
1693 {162, 163, 164, 165}
1460 {168, 169, 166, 167}
27 {169}
1679 {170, 171, 172, 173}
505 {176, 174, 175}
736 {177, 178}
3910 {179, 180, 181, 182, 183, 184, 185}
1452 {186, 187, 188}
1772 {192, 189, 190, 191}
2112 {193, 194, 195, 196}
1712 {200, 197, 198, 199}
1769 {201, 202}
1024 {203, 204}
984 {205, 206}
339 {207}
1869 {208, 209}
1819 {210, 211}
624 {212}
1474 {216, 213, 214, 215}
1619 {217, 218, 219}
842 {220, 221, 222}
746 {224, 223}
1453 {225, 226}
4096 {227, 228, 229, 230, 231, 232, 233}
1514 {233, 234, 235, 236}
1554 {237, 238}
1677 {240, 241, 239}
1450 {242, 243}
522 {244, 245}
377 {246}
1919 {247, 248, 249, 250, 251}
1437 {252, 253, 254, 255}
Обратите внимание, что это выполнялось между двумя отдельными компьютерами («реальная» ситуация). Часто использование «localhost» и тестирование клиент / сервер на одном и том же компьютере вообще не фрагментирует отправку, что прискорбно, потому что люди изучают и тестируют на одном компьютере и задаются вопросом, почему код нарушается позже.
To на самом деле реализовать сообщения в TCP, один из методов заключается в том, что появляется в исходном почтовом коде, отправить размер сообщения, а затем сообщение. Вот пример этого:
server.py
from socket import *
import random
import struct
s=socket()
s.bind(('',5000))
s.listen()
while True:
c,a = s.accept()
print(f'Connection from {a}')
with c:
for i in range(256):
length = random.randint(1,1000)
data = bytes([i] * length)
c.send(struct.pack('<I',length)) # send 4-byte length
c.sendall(data) # send actual message
print('Disconnected.')
client.py
from socket import *
import struct
class Client:
'''Buffer the TCP stream and extract meaningful data on message boundaries.'''
def __init__(self,addr,port):
self.sock = socket()
self.sock.connect((addr,port))
self.buffer = b''
def __enter__(self):
return self
def __exit__(self,*args):
self.sock.close()
def get_raw(self,size):
'''Request a specific number of bytes to extract from the stream.'''
while len(self.buffer) < size:
data = self.sock.recv(4096)
if not data: # server closed
return b''
self.buffer += data
msg,self.buffer = self.buffer[:size],self.buffer[size:]
return msg
def get(self):
'''Extract a message from the stream.'''
raw = self.get_raw(4) # Get the 4-byte length data
if not raw:
return b''
length = struct.unpack('<I',raw)[0]
return self.get_raw(length) # Return the actual message
with Client('192.168.1.5',5000) as c:
while True:
data = c.get()
if not data: break
print(len(data),set(data))
Вывод:
290 {0}
619 {1}
450 {2}
238 {3}
803 {4}
779 {5}
358 {6}
245 {7}
782 {8}
90 {9}
108 {10}
370 {11}
346 {12}
783 {13}
21 {14}
646 {15}
53 {16}
912 {17}
678 {18}
794 {19}
617 {20}
76 {21}
279 {22}
634 {23}
479 {24}
189 {25}
117 {26}
865 {27}
940 {28}
477 {29}
596 {30}
700 {31}
354 {32}
734 {33}
272 {34}
511 {35}
669 {36}
816 {37}
43 {38}
948 {39}
256 {40}
829 {41}
48 {42}
193 {43}
721 {44}
132 {45}
334 {46}
494 {47}
952 {48}
768 {49}
103 {50}
657 {51}
354 {52}
298 {53}
262 {54}
713 {55}
386 {56}
325 {57}
676 {58}
391 {59}
707 {60}
162 {61}
462 {62}
575 {63}
237 {64}
502 {65}
488 {66}
28 {67}
588 {68}
2 {69}
660 {70}
937 {71}
452 {72}
412 {73}
24 {74}
320 {75}
464 {76}
457 {77}
71 {78}
213 {79}
208 {80}
969 {81}
204 {82}
542 {83}
179 {84}
779 {85}
393 {86}
630 {87}
492 {88}
75 {89}
592 {90}
630 {91}
946 {92}
447 {93}
497 {94}
644 {95}
626 {96}
629 {97}
840 {98}
614 {99}
29 {100}
876 {101}
644 {102}
318 {103}
285 {104}
936 {105}
416 {106}
281 {107}
888 {108}
529 {109}
249 {110}
89 {111}
250 {112}
868 {113}
454 {114}
303 {115}
506 {116}
337 {117}
747 {118}
582 {119}
248 {120}
321 {121}
746 {122}
536 {123}
491 {124}
739 {125}
234 {126}
532 {127}
115 {128}
691 {129}
939 {130}
464 {131}
603 {132}
12 {133}
920 {134}
467 {135}
697 {136}
441 {137}
673 {138}
466 {139}
595 {140}
697 {141}
801 {142}
971 {143}
986 {144}
615 {145}
591 {146}
556 {147}
734 {148}
904 {149}
256 {150}
865 {151}
993 {152}
942 {153}
3 {154}
152 {155}
404 {156}
840 {157}
253 {158}
558 {159}
917 {160}
326 {161}
29 {162}
713 {163}
841 {164}
191 {165}
432 {166}
100 {167}
936 {168}
185 {169}
586 {170}
736 {171}
474 {172}
400 {173}
619 {174}
933 {175}
588 {176}
512 {177}
79 {178}
437 {179}
504 {180}
115 {181}
321 {182}
982 {183}
288 {184}
6 {185}
531 {186}
538 {187}
929 {188}
790 {189}
769 {190}
567 {191}
647 {192}
258 {193}
807 {194}
966 {195}
936 {196}
715 {197}
259 {198}
301 {199}
718 {200}
743 {201}
281 {202}
448 {203}
776 {204}
498 {205}
575 {206}
569 {207}
534 {208}
42 {209}
15 {210}
436 {211}
260 {212}
156 {213}
180 {214}
580 {215}
99 {216}
647 {217}
767 {218}
983 {219}
274 {220}
23 {221}
81 {222}
918 {223}
584 {224}
55 {225}
302 {226}
750 {227}
410 {228}
685 {229}
710 {230}
197 {231}
498 {232}
682 {233}
906 {234}
687 {235}
599 {236}
761 {237}
471 {238}
269 {239}
791 {240}
241 {241}
822 {242}
364 {243}
591 {244}
74 {245}
245 {246}
143 {247}
113 {248}
305 {249}
512 {250}
148 {251}
755 {252}
437 {253}
167 {254}
559 {255}
(Можете ли вы сказать, что мне скучно @ дома во время вспышки COVID-19?)