我的本地網絡上有以下套接字偵聽：def recvall(sock): BUFF_SIZE = 4096 # 4 KiB fragments = [] while True: chunk = sock.recv(BUFF_SIZE) fragments.append(chunk) # if the following line is removed, data is omitted time.sleep(0.005) if len(chunk) < BUFF_SIZE: break data = b''.join(fragments) return datadef main(): pcd = o3d.geometry.PointCloud() s = socket.socket(socket.AF_INET, socket.SOCK_STREAM) s.bind(('192.168.0.22', 2525)) print("starting listening...") s.listen(1) counter = 0 while True: clientsocket, address = s.accept() print(f"Connection from {address} has been established!") received_data = recvall(clientsocket) clientsocket.send(bytes(f"response nr {counter}!", "utf-8")) counter += 1 print(len(received_data))if __name__ == "__main__": main()172800我從手機上的應用程序向此端口發送字節長度的字節數據。正如您所看到的，我正在打印收到的數據量。time.sleep()僅當我按照上面的代碼所示使用時，該金額才是正確的。如果我不使用這種方法，則只會收到一部分數據。顯然這是一些計時問題，問題是：我怎樣才能確保在不使用的情況下一直接收到所有數據time.sleep()（因為這也不是100％確定有效，具體取決于設置的睡眠時間）
1 回答
幕布斯6054654
TA貢獻1876條經驗 獲得超7個贊
sock.recv()返回可用的數據。手冊頁中的相關部分recv(2)是：
The receive calls normally return any data available, up to the requested amount,
rather than waiting for receipt of the full amount requested.
在您的情況下，time.sleep(0.005)似乎允許消息的所有剩余數據到達并存儲在緩沖區中。
有一些選項可以消除time.sleep(0.005). 哪一種最合適取決于您的需求。
sock.close()如果發送方發送數據，但不期望得到響應，您可以讓發送方在發送數據后（即after ）關閉套接字sock.sendall()。recv()將返回一個空字符串，可用于打破while接收器上的循環。
def recvall(sock):
BUFF_SIZE = 4096
fragments = []
while True:
chunk = sock.recv(BUFF_SIZE)
if not chunk:
break
fragments.append(chunk)
return b''.join(fragments)
如果發送方發送固定長度（例如172800字節）的消息，則可以recv()循環使用，直到接收方收到完整的消息。
def recvall(sock, length=172800):
fragments = []
while length:
chunk = sock.recv(length)
if not chunk:
raise EOFError('socket closed')
length -= len(chunk)
fragments.append(chunk)
return b''.join(fragments)
其他選項包括：在發送方發送的消息末尾添加分隔符，例如不能成為數據一部分的特殊字符；然后接收器可以recv()循環運行，直到檢測到分隔符和 b。在發送方的消息前面加上消息的長度前綴；然后接收者就會知道每條消息需要多少字節。
添加回答
舉報
0/150
提交
取消