普通訊息是指雲訊息佇列 RocketMQ 版中無特性的訊息,區別於有特性的定時和延時訊息、順序訊息和事務訊息。不同訊息類型所屬的Topic不能混用,例如收發普通訊息的Topic不能用來收發其他類型的訊息。本文提供使用TCP協議下的C/C++ SDK收發普通訊息的範例程式碼供您參考。
前提條件
您已完成以下操作:
下載C/C++ SDK。更多資訊,請參見版本說明。
準備環境。更多資訊,請參見環境準備(v1.x.x)。
建立資源。代碼中涉及的資源資訊,例如執行個體、Topic和Group ID等,需要在控制台上提前建立。更多資訊,請參見建立資源。
擷取阿里雲存取金鑰AccessKey ID和AccessKey Secret。更多資訊,請參見建立AccessKey。
發送普通訊息
請參考以下範例程式碼進行訊息發送。
#include "ONSFactory.h"
#include "ONSClientException.h"
using namespace ons;
int main()
{
//建立Producer,並配置發送訊息所必需的資訊。
ONSFactoryProperty factoryInfo;
//您在訊息佇列RocketMQ版控制台建立的Group ID。
factoryInfo.setFactoryProperty(ONSFactoryProperty::ProducerId, "XXX");
//設定TCP接入網域名稱,進入訊息佇列RocketMQ版控制台執行個體詳情頁面的存取點地區查看。
factoryInfo.setFactoryProperty(ONSFactoryProperty::NAMESRV_ADDR, "XXX");
// 您在訊息佇列RocketMQ版控制台建立的Topic。
factoryInfo.setFactoryProperty(ONSFactoryProperty::PublishTopics,"XXX" );
//訊息內容。
factoryInfo.setFactoryProperty(ONSFactoryProperty::MsgContent, "XXX");
//請確保環境變數ALIBABA_CLOUD_ACCESS_KEY_ID、ALIBABA_CLOUD_ACCESS_KEY_SECRET已設定。
//AccessKey ID,阿里雲身分識別驗證標識。
factoryInfo.setFactoryProperty(ONSFactoryProperty::AccessKey, getenv("ALIBABA_CLOUD_ACCESS_KEY_ID"));
//AccessKey Secret,阿里雲身分識別驗證密鑰。
factoryInfo.setFactoryProperty(ONSFactoryProperty::SecretKey, getenv("ALIBABA_CLOUD_ACCESS_KEY_SECRET"));
//create producer;
Producer *pProducer = ONSFactory::getInstance()->createProducer(factoryInfo);
//在發送訊息前,必須調用start方法來啟動Producer,只需調用一次即可。
pProducer->start();
Message msg(
//普通訊息所屬的Topic,切勿使用普通訊息的Topic來收發其他類型的訊息。
factoryInfo.getPublishTopics(),
//Message Tag,可理解為Gmail中的標籤,對訊息進行再歸類,方便Consumer指定過濾條件在訊息佇列RocketMQ版的伺服器過濾。
"TagA",
//Message Body,不可為空,訊息佇列RocketMQ版不做任何幹預,需要Producer與Consumer協商好一致的序列化和還原序列化方式。
factoryInfo.getMessageContent()
);
// 設定代表訊息的業務關鍵屬性,請儘可能全域唯一。
// 以方便您在無法正常收到訊息情況下,可通過訊息佇列RocketMQ版控制台查詢訊息並補發。
// 注意:不設定也不會影響訊息正常收發。
msg.setKey("ORDERID_100");
//發送訊息,只要不拋出異常,就代表發送成功。
try
{
SendResultONS sendResult = pProducer->send(msg);
}
catch(ONSClientException & e)
{
//自訂處理exception的細節。
}
// 在應用退出前,必須銷毀Producer對象,否則會導致記憶體泄露等問題。
pProducer->shutdown();
return 0;
}
訂閱普通訊息
訂閱普通訊息的說明和範例程式碼,請參見訂閱訊息。