全部產品
Search
文件中心

ApsaraMQ for RocketMQ:收發普通訊息

更新時間:Sep 23, 2024

普通訊息是指雲訊息佇列 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;
}

訂閱普通訊息

訂閱普通訊息的說明和範例程式碼,請參見訂閱訊息