Qpid第五課消息總線使用經(jīng)驗-創(chuàng)新互聯(lián)

qpid-broker服務(wù)器采用Java語言版本6.1.4
相關(guān)資料
http://qpid.apache.org/documentation.html

創(chuàng)新互聯(lián)公司成立與2013年，是專業(yè)互聯(lián)網(wǎng)技術(shù)服務(wù)公司，擁有項目網(wǎng)站制作、網(wǎng)站設(shè)計網(wǎng)站策劃，項目實施與項目整合能力。我們以讓每一個夢想脫穎而出為使命，1280元陽曲做網(wǎng)站,已為上家服務(wù),為陽曲各地企業(yè)和個人服務(wù),聯(lián)系電話:18982081108

問題1）
發(fā)送到qpid服務(wù)器上的消息，如果沒有被其他的客戶端消費是否一直保存在內(nèi)存中，
可能導(dǎo)致服務(wù)器內(nèi)存耗盡，服務(wù)器崩潰，因為服務(wù)器的內(nèi)存一開始就是設(shè)置為512MB

解決方案: 指定消息的超時時間，如果超時，就刪除

問題2）
發(fā)送到qpid服務(wù)器上的消息，如果由于超時，客戶端斷開連接，是否也會出現(xiàn)上述類似的問題

qpid C++編程例子
http://qpid.apache.org/releases/qpid-cpp-1.36.0/messaging-api/cpp/examples/client.cpp.html

下載版本qpid-cpp-1.35.0
詳細(xì)的編譯參考可以在源碼中找到文件INSTALL-WINDOWS.txt
代碼
int HandleQPID()
{
std::string connectionOptions = "";
Connection connection("192.168.1.12:7070", connectionOptions);
connection.setOption("username", "admin");
connection.setOption("password", "admin");
//true的情況下，嘗試重連會導(dǎo)致后續(xù)一直的阻塞
connection.setOption("reconnect", false);
try
{
connection.open();
Session session = connection.createSession();
Sender sender = session.createSender(info.strMessageAddress);

Message request;
request.setContent(info.strSendContext);
session.sync();

Address responseQueue("#response-queue; {create:always, delete:always}");
request.setReplyTo(responseQueue);
sender.send(request);
Receiver receiver = session.createReceiver(responseQueue);

try
{
Message response;
//如果不指定Duration,如果服務(wù)器接收到的報文一直沒有返回，在這里會一直阻塞！！
if (receiver.fetch(response, Duration(300)))
{
info.strRecvContext = response.getContent();
std::cout << "info" << std::endl;
std::cout << info.strRecvContext << std::endl;
}
session.acknowledge();
}
catch (const std::exception& error)
{
std::cout << "receiver.fetch exception:" << error.what() << std::endl;
session.acknowledge();
session.close();
connection.close();
return -1;
}
session.close();
connection.close();
return 0;
}
catch (const std::exception& error)
{
//std::cout << "E:" << error.what() << std::endl;
info.strRecvContext = "";
connection.close();
return -1;
}
}

另外有需要云服務(wù)器可以了解下創(chuàng)新互聯(lián)scvps.cn，海內(nèi)外云服務(wù)器15元起步，三天無理由+7*72小時售后在線，公司持有idc許可證，提供“云服務(wù)器、裸金屬服務(wù)器、高防服務(wù)器、香港服務(wù)器、美國服務(wù)器、虛擬主機、免備案服務(wù)器”等云主機租用服務(wù)以及企業(yè)上云的綜合解決方案，具有“安全穩(wěn)定、簡單易用、服務(wù)可用性高、性價比高”等特點與優(yōu)勢，專為企業(yè)上云打造定制，能夠滿足用戶豐富、多元化的應(yīng)用場景需求。

當(dāng)前文章：Qpid第五課消息總線使用經(jīng)驗-創(chuàng)新互聯(lián)
網(wǎng)頁鏈接：http://www.muchs.cn/article20/cdedjo.html

成都網(wǎng)站建設(shè)公司_創(chuàng)新互聯(lián)，為您提供響應(yīng)式網(wǎng)站、網(wǎng)站策劃、服務(wù)器托管、微信小程序、軟件開發(fā)、商城網(wǎng)站

聲明：本網(wǎng)站發(fā)布的內(nèi)容（圖片、視頻和文字）以用戶投稿、用戶轉(zhuǎn)載內(nèi)容為主，如果涉及侵權(quán)請盡快告知，我們將會在第一時間刪除。文章觀點不代表本網(wǎng)站立場，如需處理請聯(lián)系客服。電話：028-86922220；郵箱：631063699@qq.com。內(nèi)容未經(jīng)允許不得轉(zhuǎn)載，或轉(zhuǎn)載時需注明來源：創(chuàng)新互聯(lián)

猜你還喜歡下面的內(nèi)容