Python套接字接收大量数据

Question

当我尝试接收大量数据时，它会被切断，我必须按enter键才能获取其余数据。起初，我可以增加一点，但它仍然不会收到所有的。正如您所看到的，我增加了conn.recv（）上的缓冲区，但它仍然无法获取所有数据。它会在某一点切断它。我必须在原始输入上按enter键才能接收其余数据。我是否可以一次获取所有数据？这是密码。

port = 7777
sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
sock.bind(('0.0.0.0', port))
sock.listen(1)
print ("Listening on port: "+str(port))
while 1:
    conn, sock_addr = sock.accept()
    print "accepted connection from", sock_addr
    while 1:
        command = raw_input('shell> ')
        conn.send(command)
        data = conn.recv(8000)
        if not data: break
        print data,
    conn.close()

Answer 1

可以接受的答案是好的，但对于大文件来说速度会非常慢-字符串是一个不可变的类这意味着每次使用符号时都会创建更多的对象，使用列表作为堆栈结构将更有效。

这应该更管用

while True: 
    chunk = s.recv(10000)
    if not chunk: 
        break
    fragments.append(chunk)

print "".join(fragments)

Answer 2

您可以将其用作：data=recvall（sock）

def recvall(sock):
    BUFF_SIZE = 4096 # 4 KiB
    data = b''
    while True:
        part = sock.recv(BUFF_SIZE)
        data += part
        if len(part) < BUFF_SIZE:
            # either 0 or end of data
            break
    return data

Answer 3

TCP/IP是基于流的协议，而不是基于消息的协议。无法保证一个对等方的每次send（）调用都会导致另一个对等方的一次recv（）调用，而另一个对等方接收到发送的确切数据时，可能会收到数据单，由于数据包碎片，会在多个recv（）调用中分割。

为了区分消息边界，您需要在TCP之上定义自己的基于消息的协议。然后，为了读取消息，您继续调用recv（），直到您读取了整个消息或发生错误。

发送消息的一种简单方法是在每条消息前面加上长度前缀。然后，要阅读一条消息，首先要读取长度，然后读取那么多字节。以下是您可以如何做到这一点：

def send_msg(sock, msg):
    # Prefix each message with a 4-byte length (network byte order)
    msg = struct.pack('>I', len(msg)) + msg
    sock.sendall(msg)

def recv_msg(sock):
    # Read message length and unpack it into an integer
    raw_msglen = recvall(sock, 4)
    if not raw_msglen:
        return None
    msglen = struct.unpack('>I', raw_msglen)[0]
    # Read the message data
    return recvall(sock, msglen)

def recvall(sock, n):
    # Helper function to recv n bytes or return None if EOF is hit
    data = bytearray()
    while len(data) < n:
        packet = sock.recv(n - len(data))
        if not packet:
            return None
        data.extend(packet)
    return data

然后，您可以使用send_msg和recv_msg功能发送和接收整个消息，并且在网络级别拆分或合并数据包时不会出现任何问题。