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

qpid-broker服務器采用Java語言版本6.1.4
相關資料
http://qpid.apache.org/documentation.html

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

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

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

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

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

下載版本qpid-cpp-1.35.0
詳細的編譯參考可以在源碼中找到文件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的情況下，嘗試重連會導致后續(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,如果服務器接收到的報文一直沒有返回，在這里會一直阻塞??！
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;
}
}

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

當前文章：Qpid第五課消息總線使用經驗-創(chuàng)新互聯
網頁鏈接：http://bm7419.com/article20/cdedjo.html

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

廣告

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

成都網站建設