java - ActiveMQ JMS 用BlobMessage发送大文件 用CMS接收BlobMessage接收不到
迷茫
迷茫 2017-04-17 15:34:59
0
0
497

我的需求是这样的:
需要用ActiveMQ 来在客户端与客户端之间来传递大文件,我写了两个客户端,一个客户端用JMS创建了一个BlobMessage来发送文件,另一个客户端用ActiveMQ提供的C++接口---CMS,来接收文件数据,发送端(producer)已经显示成功发送,在ActiveMQ的broker上能看到相应的Queue名。我用接收端(consumer)也能接收到发送过来的BlobMessage的properties。但是却无法得到文件内容。getContent函数返回为空,不知道是什么原因。但是getMarshalledProperties()函数都能得到发送过来的properties。

JMS代码:

Sender sf = new Sender ("10.1.72.35", 41112); String str = sf.connect(); System.out.print(str); MessageHeader header = new MessageHeader("BABJ", 3600, "QueneName", 200, "1030", 300, "dataID", "20150825", "SendText.txt", "D:/data"); File f1 =new File("D:\\data\\SendText.txt"); str = sf.sendMessage(header, "FILE", f1); System.out.print(str); str = sf.disconnect(); System.out.print(str);

CMS端onMessage函数的代码:

void CMQReceiver::RecvMessage() { MessageHeader header; long nFileSize = 0; // 消费者没有创建成功 if (consumer == NULL) { return; } try { Message *message = consumer->receiveNoWait();//consumer->receive(); if (message == NULL) { return; } //commands::ActiveMQBlobMessage *testMsg = new commands::ActiveMQBlobMessage(); //bool bFlg = util::ActiveMQMessageTransformation::transformMessage(message, amqConnection, (commands::Message **)&testMsg); //if (bFlg) //{ // string strName = testMsg->getName(); //} //ActiveMQConsumer *mqConsumer = dynamic_cast(consumer); //Message *message = mqConsumer->receiveNoWait(); /*************************************** BLOB MESSAGE **************************************************/ commands::ActiveMQBlobMessage* blobMessage = dynamic_cast(message); if (blobMessage) { commands::Message* cmdMsg = (commands::Message*)blobMessage; if (cmdMsg) { std::vector properties = cmdMsg->getMarshalledProperties(); LIST_PROPERTIES lstProperties; int nErr = ParseProperties(properties, lstProperties); if (nErr == 0) { // 解析属性消息 getMessageHeader(lstProperties, header, nFileSize); // 获取数据 if (nFileSize > 0) { // 获取数据 //cms::Message* cmsMsg = (cms::Message*)blobMessage->clone(); //BytesMessage *byteMsg = (BytesMessage*)cmsMsg; //unsigned char * body = byteMsg->getBodyBytes(); //if (body) //{ // int a = 0; //} std::vector fileContent; fileContent = blobMessage->getContent(); } } } } /****************************************OBJCET MESSAGE ******************************************************/ commands::ActiveMQObjectMessage* objectMessage = dynamic_cast(message); if (objectMessage) { commands::Message* cmdMsg = (commands::Message*)objectMessage; if (cmdMsg) { // 属性 std::vector properties = cmdMsg->getMarshalledProperties(); LIST_PROPERTIES lstProperties; int nErr = ParseProperties(properties, lstProperties); if (nErr == 0) { // 解析属性消息 getMessageHeader(lstProperties, header, nFileSize); // 获取Bean数据 } // Bean内容(得到的内容是序列化的数据) std::vector content = cmdMsg->getContent(); // 执行反序列化解析 } } } catch (CMSException& e) { e.printStackTrace(); string msg = e.getMessage(); } }

references:
http://activemq.apache.org/can-i-send-really-large-files-over-activemq.html
http://activemq.apache.org/blob-messages.html
http://markmail.org/message/7cwjpekvbgdoigdg
http://activemq.apache.org/cms/example.html
http://activemq.apache.org/cms/cms-api-overview.html

迷茫
迷茫

业精于勤,荒于嬉;行成于思,毁于随。

全部回覆 (0)
最新下載
更多>
網站特效
網站源碼
網站素材
前端模板
關於我們 免責聲明 Sitemap
PHP中文網:公益線上PHP培訓,幫助PHP學習者快速成長!