ApsaraMQ for RocketMQ：收發定時訊息

前提條件

您已完成以下操作：

• 下載C/C++ SDK。更多資訊，請參見版本說明。

• 準備環境。請根據您使用的SDK版本做好環境準備工作：

  • 環境準備（v2.x.x）

  • 環境準備（v1.x.x）

• 建立資源。代碼中涉及的資源資訊，例如執行個體、Topic和Group ID等，需要在控制台上提前建立。更多資訊，請參見建立資源。

• 擷取阿里雲存取金鑰AccessKey ID和AccessKey Secret。更多資訊，請參見建立AccessKey。

發送定時訊息

發送定時訊息的範例程式碼如下。

#include "ONSFactory.h"
#include "ONSClientException.h"

#include <windows.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(
            //Message Topic
            factoryInfo.getPublishTopics(),
            //Message Tag，可理解為Gmail中的標籤，對訊息進行再歸類，方便Consumer指定過濾條件在訊息佇列RocketMQ版的伺服器過濾       
            "TagA",
            //Message Body，不可為空，訊息佇列RocketMQ版不做任何幹預，需要Producer與Consumer協商好一致的序列化和還原序列化方式。
            factoryInfo.getMessageContent()
    );

    // 設定代表訊息的業務關鍵屬性，請儘可能全域唯一。
    // 以方便您在無法正常收到訊息情況下，可通過訊息佇列RocketMQ版控制台查詢訊息並補發。
    // 注意：不設定也不會影響訊息正常收發。
    msg.setKey("ORDERID_100");

    // deliver time單位ms，指定一個時刻，在這個時刻之後訊息才能被消費，這個例子表示3s後才能被消費。
    long deliverTime = GetTickCount64() + 3000;
    msg.setStartDeliverTime(deliverTime);

    //發送訊息，只要不拋出異常，就代表發送成功。     
    try
    {
        SendResultONS sendResult = pProducer->send(msg);
    }
    catch(ONSClientException & e)
    {
        //自訂處理exception的細節。
    }

    // 在應用退出前，必須銷毀Producer對象，否則會導致記憶體泄露等問題。
    pProducer->shutdown();

    return 0;
}
            

訂閱定時訊息

定時訊息的訂閱與普通訊息訂閱一致，更多資訊，請參見訂閱訊息。