我正在使用 activemq-cpp，并且正在尝试使用 BytesMessage 发送二进制数据。我有一个生产者和一个消费者设置来发送和接收消息。连接和会话工作正常，因为我能够发布到主题并允许消费者使用 TextMessage 获取消息。验证连接性后，我将 TextMessage 实现更改为 BytesMessage。我现在遇到的问题是对 BytesMessages 进行转码并在收到消息后从消息中取出数据。
在我的制片人中，我有：
void producer() {
try {
//....setup code
//temporary vector
vector<unsigned char> vec;
unsigned char temp1 = 'a';
vec.push_back(temp1);
vec.push_back(temp1);
vec.push_back(temp1);
BytesMessage * message = session->createBytesMessage();
message->writeBytes(vec);
cout << "SIZE IS: " << vec.size() << endl;
producer->send( message );
delete message;
} catch (CMSException& e) {
e.printStackTrace();
}
}
在我的消费者中，我有：
void begin(){
// setup code to get session, etc.
shared_ptr<BytesMessage> bytemessage =
boost::dynamic_pointer_cast<BytesMessage>(message);
vector<unsigned char> temp;
bytemessage->readBytes(temp);
cout << "SIZE IS: " << temp.size() << endl;
}
Producer 打印出大小为 3，这是正确的。但是消费者打印出一个大小为0，表示它没有读入之前正确写入的消息。这让我问，我做错了什么？
我试图在本地编写和阅读它，但我仍然无法这样做：
void producer() {
try {
//....setup code
//temporary vector
vector<unsigned char> vec;
unsigned char temp1 = 'a';
vec.push_back(temp1);
vec.push_back(temp1);
vec.push_back(temp1);
BytesMessage * message = session->createBytesMessage();
message->writeBytes(vec);
cout << "SIZE IS: " << vec.size() << endl;
message->reset();
vector<unsigned char> temp2;
message->readBytes(temp2);
cout << "SIZE IS2: " << temp2.size() << endl;
delete message;
} catch (CMSException& e) {
e.printStackTrace();
}
}
写入后的 cout 打印出 3，但读取后的 cout 仍打印出 0。
我没有正确写入数据吗？非常感谢正确方向的任何一点。谢谢！