从插座接收到的数据

Question

上下文： 我有一个带有server.py.py文件的系统和live_client.py。服务器正在不断更新对象。如果我通过插座发送对象的属性（cliend.send（str（obj.attribute_to_send）.encode（'utf-8''））。

问题： 之后，我尝试使用Pickle client.send（pickle.loads（obj））从服务器发送对象。当客户端试图用cickle.loads（data_received）将对象恢复时，就会发生问题。 错误代码： _pickle.unpicklingerror：泡菜数据被截断。

server.py

async def stream_feed_clients():
    obj_gen = object_generator()
    global object
    global STREAM_CLIENTS
    async for obj in obj_gen:
        object = obj        
        for client in STREAM_CLIENTS: #STREAM_CLIENTS:Each time a client connects, another thread stores the client in this variable
            try:
                client.send(pickle.dumps(obj))
            except ConnectionResetError:
                client.close()
                print("Client disconnected!")
                STREAM_CLIENTS = set(filter(lambda x: x != client, STREAM_CLIENTS))

import socket, pickle, time

from CustomClass import MyClass

HOST = 'localhost'
PORT = XXXX
try:
    c = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
    c.connect((HOST, PORT))
    message = {'client_type': 'LIVE'}
    print('Waiting')
    time.sleep(5)
    print('Sending')
    c.send(pickle.dumps(message)) # NOTE: This pickle works. It is used to notify the server this is a client that wants live data.
    print('Message sent')
    while True:
        data = c.recv(4096 * 32) # I've been trying with different buffer sizes.
        obj = pickle.loads(data) # ERROR OCCURS HERE: _pickle.UnpicklingError: pickle data was truncated
        print(obj.a)
except KeyboardInterrupt:
    print('Closing connection to server')
    c.close()
    print('Connection closed')
    print('Exiting...')
    exit()

客户

class MyClass:
    def __init__(self, a):
        self.a = a
    
    def get_a(self):
        return self.a