在上接收多个数据包的Python套接字

Question

当我将Python客户机连接到服务器时，有两个数据包被发送到客户机：

第一个是：

FD 01

第二个：

^{pr2}$

但是，当我试图通过套接字在Python客户机中接收它们时，我会同时接收到这两个消息：

FD 01 FF 66 46 3E 61 37 07 CA 0B

我希望每次都在缓冲区中接收数据包，这样我就可以解析一个数据包，在后台做一些工作，然后在队列中解析另一个数据包。我怎么解决这个问题？在

这是我的客户代码：

class ReceivePacket():
    def __init__(self, bytes):
        reply = str(bytes).encode('hex')
        print "<- [{}] - {}".format(headers.RECV.get(int(reply[:2], 16), int(reply[:2], 16)),
                                    ' '.join([reply[i:i + 2] for i in range(0, len(reply), 2)]).upper())

class Client(threading.Thread):
    def __init__(self):
        threading.Thread.__init__(self)

        self.size = 1024
        self.sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM)  # type: socket.socket

        self.buf = bytearray(self.size)

        self.net = network.Network()
        self.net.bindClient(self)

        try:
            self.sock.connect((HOST, AUTH_PORT))
        except socket.error, msg:
            raise

    def run(self):
        while True:
            reply = self.sock.recv_into(memoryview(self.buf))

            if reply:
                self.receive(reply)

    def receive(self, nbytes):
        ReceivePacket(self.buf) # Having FD 01 FF 66 46 3E 61 37 07 CA 0B here

c = Client()
c.start()

Answer 1

你的眼泪是你能做的。就像在tcp/udp数据包中一样，您可以定义自己的头。 对于bytestream，一个字节似乎足以容纳后面的消息的大小。在

您的bytestreams将如下所示： 02 FD 01 09 FF 66 46 3E 61 37 07 CA 0B 因此： 02 FD 01 09 FF 66 46 3E 61 37 07 CA 0B 这允许您接收缓冲区中的所有数据，然后处理后面的n个字节。在

如果您还希望数据包顺序能够被随机处理，那么您可能还需要在报头中抛出第二个字节来定义消息类型。 生成的bytestream将如下所示： [长度|类型|数据]

Answer 2

另一个解决方案是使用pickle来序列化您的数据包，例如，它在读取时自动获取每个数据包。在

“把泡菜串在一起就好了，Python知道每个泡菜的终点” 像这样：

>>> import cStringIO as stringio
>>> import cPickle as pickle
>>> o1 = {}
>>> o2 = []
>>> o3 = ()
>>> p = pickle.dumps(o1)+pickle.dumps(o2)+pickle.dumps(o3)
>>> s = stringio.StringIO(p)
>>> pickle.load(s)
{}
>>> pickle.load(s)
[]
>>> pickle.load(s)
()