这是我之前在 Boost 的另一个线程中打开的后续问题：反序列化通过 ZeroMQ pull socket 传递的自定义 C++ 对象。该线程中的问题已根据提供的答案解决。现在我在运行时遇到了另一个问题。请看下面的描述。我真的是 C++ 领域的新手，所以如果你告诉我除了我在问题陈述中描述的内容之外，还有什么需要改进提供的代码的任何部分，我将不胜感激。
描述：
我有一个名为GenericMessage的 C++ 类，它只包含一个 id 和数据作为其成员（参见下面的代码片段 2 - GenericMessage.hxx）。我的意图是序列化这个类的一个实例，并通过实现推送模式的 ZeroMQ 套接字发送它。
序列化和发送任务已在ZMQHandler 类（参见 sendToBE 函数）中实现，该类放置在如下代码片段 3所示的头文件名 ZMQHandler.hxx 中。此类由下面第四个代码片段中所示的TestFE.cxx实例化。
GenericMessage 实例的接收和反序列化在TestBE.cxx中实现， 可在下面的第 5 个代码片段中找到。我的意图是通过 ZMQ 套接字（即拉套接字）接收 GenericMessage 实例，对其进行反序列化，然后将其成员打印到标准输出。
我验证了通过 ZeroMQ 套接字传输的序列化和 GenericMessage 对象工作正常。反序列化似乎也有效，因为我没有得到任何异常或分段错误之类的东西。
问题陈述：
TestBE.cxx 中的代码（参见代码片段 5）的预期是通过 ZeroMQ 套接字接收 GenericMessage 对象，将其反序列化，然后打印其两个成员，即 id 和 data，在这种情况下是字符串对象。更准确地说，它应该首先打印它获得的字符流的内容，然后是反序列化对象的成员。相反，它根本不打印这些成员。Al，它将包括问号在内的奇怪符号放入接收到的字符流中。请看下面的第一个代码片段，你会明白我的意思。
问题：
i)为什么我不能得到预期的输出？为什么我在输出中看到标有奇怪符号的问题？为什么我看不到打印的 id 和 data 字段，尽管它们在打印的字符流中可见？
ii) GenericMessage 类中的数据字段是一个模板类型，它被设置为 std::string 用于测试目的。但是，在实际使用中，我计划以序列化的形式传输一个更复杂的对象。在这方面，您认为使用类 boost::archive::text_iarchive 和 boost::archive::text_oarchive 有用吗？我应该改用二进制吗？如果是这样，您认为我应该注意一些陷阱/可能的问题吗？提前致谢。
片段 1：程序输出与预期输出
*******************
The EXPECTED OUTPUT
*******************
Connecting to FE...
CHAR [22 serialization::archive 9 0 1 0
0 1 12 Hello there!]
ID: 1
Data: Hello there!
CHAR [22 serialization::archive 9 0 1 0
0 2 12 Hello there!]
ID: 2
Data: Hello there!
CHAR [22 serialization::archive 9 0 1 0
0 3 12 Hello there!]
ID: 3
Data: Hello there!
......
*************************
PRINTED OUTPUT IN REALITY
*************************
Connecting to FE...
CHAR [22 serialization::archive 9 0 1 0
0 1 12 Hello there!]
ID: 1
Data: Hello there!
//continues in increasing order same as above until the 18th message in the following
CHAR [22 serialization::archive 9 0 1 0
0 18 12 Hello there!]
ID: 0
Data:
//!!!!AFTER the 18th message I got question marks in the printed char stream!!!!!
CHAR [22 serialization::archive 9 0 1 0
0 19 12 Hello there!���]
ID: 0
Data:
CHAR [22 serialization::archive 9 0 1 0
0 20 12 Hello there!���]
ID: 0
Data:
代码片段 2 (GenericMessage.hxx)
#include <iostream>
#include <string>
#include <sstream>
#include <boost/serialization/serialization.hpp>
#include <boost/archive/binary_oarchive.hpp>
#include <boost/archive/binary_iarchive.hpp>
#include <boost/archive/text_oarchive.hpp>
#include <boost/archive/text_iarchive.hpp>
template <class T>
class GenericMessage {
public:
GenericMessage():
beId(-1)
{}
GenericMessage(int id, T msg):
beId(id),
data(msg)
{}
~GenericMessage(){}
T getData()
{
return data;
}
std::string toString()
{
std::ostringstream ss;
ss << getBeId();
std::string ret = ss.str();
return ("ID: " + ret + " DATA: " + getData());
}
void setBeId(int id)
{
beId = id;
}
int getBeId()
{
return beId;
}
private:
friend class boost::serialization::access;
int beId;
T data;
template <class Archive>
void serialize(Archive & ar, const unsigned int version)
{
ar & beId;
ar & data;
}
};
代码片段 3 (ZmqHandler.hxx)
#include "zmq.hpp"
#include "GenericMessage.hxx"
#include <unistd.h>
#include <cassert>
template <class A>
class ZmqHandler {
public:
ZmqHandler():
mContext(1),
mOutbHandlerSocket(mContext, ZMQ_PUSH)
{
mOutbHandlerSocket.bind ("tcp://*:5555");
}
~ZmqHandler() {}
void sendToBE(GenericMessage<A> *theMsg)
{
std::ostringstream archive_stream;
boost::archive::text_oarchive archive(archive_stream);
try
{
archive << theMsg;
} catch (boost::archive::archive_exception& ex) {
std::cout << "Archive Exception during deserializing:" << std::endl;
std::cout << ex.what() << std::endl;
} catch (int e) {
std::cout << "EXCEPTION " << e << std::endl;
}
std::string outbound_data_ = archive_stream.str();
// no need to use the c-style string function 'strlen'
int len = outbound_data_.length();
zmq::message_t msgToSend(len);
memcpy( msgToSend.data(), outbound_data_.data(), len );
mOutbHandlerSocket.send(msgToSend);
std::cout << "SENT request: [" << theMsg->toString() << "]" << std::endl;
std::cout << "LENGTH [" << len << "]" << std::endl;
}
private:
zmq::context_t mContext;
zmq::socket_t mOutbHandlerSocket;
};
代码片段 4 (TestFE.cxx)
#include "ZmqHandler.hxx"
int main ()
{
ZmqHandler<std::string> zmqHandler;
int counter = 1;
while(1)
{
std::string data = "Hello there!";
GenericMessage<std::string> msg(counter, data);
zmqHandler.sendToBE(&msg);
counter++;
sleep(1);
}
return 0;
}
代码片段 5 (TestBE.cxx)
#include "zmq.hpp"
#include "GenericMessage.hxx"
#include <fstream>
int main ()
{
// Prepare our context and socket
zmq::context_t context (1);
zmq::socket_t socket (context, ZMQ_PULL);
std::cout << "Connecting to FE..." << std::endl;
socket.connect ("tcp://localhost:5555");
while(1){
zmq::message_t reply;
socket.recv (&reply);
const char *buf = static_cast<const char*>(reply.data());
std::cout << "CHAR [" << buf << "]" << std::endl;
std::string input_data_( buf, reply.size() );
std::istringstream archive_stream(input_data_);
boost::archive::text_iarchive archive(archive_stream);
GenericMessage<std::string> theMsg;
try
{
archive >> theMsg;
} catch (boost::archive::archive_exception& ex) {
std::cout << "Archive Exception during deserializing:" << std::endl;
std::cout << ex.what() << std::endl;
} catch (int e) {
std::cout << "EXCEPTION " << e << std::endl;
}
std::cout << "ID: " << theMsg.getBeId() << std::endl;
std::cout << "Data: " << theMsg.getData() << std::endl;
}
return 0;
}