c++ - 在 C++ 中使用 POCO 和 cereal 反序列化多个对象

Question

我正在尝试通过网络将一些对象从一个程序发送到另一个程序，使用 POCO::Net 来处理连接并使用 cereal 来处理序列化。

所有数据包都继承自单一基础，BasePacket。

class BasePacket {}; 
typedef std::shared_ptr<BasePacket> BasePacketPtr;

这是我发送数据的方式:

Poco::Net::StreamSocket &socket; //passed as an argument
Poco::Net::SocketOutputStream os(socket);
while (!sendQueue.empty()) {
    BasePacketPtr v;
    v = sendQueue.front();
    { //block to make sure that cereal flushes everything
     cereal::BinaryOutputArchive oa(os);
     oa << v;
    }
    sendQueue.pop();
}
os.flush();

这就是我接收数据的方式:

Poco::Net::StreamSocket &socket; //passed as an argument
Poco::Net::SocketInputStream is(socket);
cereal::BinaryInputArchive ia(is);
BasePacketPtr v;
while(socket.available()) {
    ia >> v;
    //do sth with v...
}

问题在于，当数据发送速度非常快时，很多数据包可能在套接字缓冲区中等待， Cereal 读取所有字节，但只反序列化第一个数据包，其余数据包丢失。

有没有办法让 Cereal 一次只读取一个数据包或反序列化多个数据包？或者我应该在 Poco 的 socketstream 和 cereal 的存档之间创建某种缓冲区来发送数据大小，以便它可以在将它传递给 cereal 之前读取一个数据包？

Answer 1

如果有人碰巧遇到同样的问题，这里是问题的原因:

while(socket.available())

这只会迭代一次，即使缓冲区中有多个数据包( Cereal 存档从套接字获取所有数据，因此它没有任何可用数据，因此返回 0)。

当新数据包出现时，缓冲区被重置，数据丢失。

解决方案是继续从 cereal achieve 中读取数据，直到没有更多数据为止。如果这是在单独的线程中运行，即使 while(isRunning()) { ia >> v;/.../} 就足够了。