809      阿裏雲

發送普通消息__C/C++ SDK_TCP 接入(專業)_消息隊列 MQ-阿裏雲

請參考以下示例代碼進行消息發送。

#include "ONSFactory.h"
#include "ONSClientException.h"
using namespace ons;
int main()
{
    //創建producer和發送消息所必需的信息;
    ONSFactoryProperty factoryInfo;   
    factoryInfo.setFactoryProperty(ONSFactoryProperty::ProducerId, "XXX");//您在控製台創建的Producer ID
    factoryInfo.setFactoryProperty(ONSFactoryProperty::PublishTopics,"XXX" );// 消息內容
    factoryInfo.setFactoryProperty(ONSFactoryProperty::MsgContent, "XXX");//消息內容
    factoryInfo.setFactoryProperty(ONSFactoryProperty::AccessKey, "XXX");//AccessKey 阿裏雲身份驗證，在阿裏雲服務器管理控製台創建
    factoryInfo.setFactoryProperty(ONSFactoryProperty::SecretKey, "XXX" );//SecretKey 阿裏雲身份驗證，在阿裏雲服務器管理控製台創建
    //create producer;
    Producer *pProducer = ONSFactory::getInstance()->createProducer(factoryInfo);
    //在發送消息前，必須調用start方法來啟動Producer，隻需調用一次即可;
    pProducer->start();
    Message msg(
            //Message Topic
            factoryInfo.getPublishTopics(),
            //Message Tag,可理解為Gmail中的標簽，對消息進行再歸類，方便Consumer指定過濾條件在MQ服務器過濾       
            "TagA",
            //Message Body,不能為空，MQ不做任何幹預，需要Producer與Consumer協商好一致的序列化和反序列化方式
            factoryInfo.getMessageContent()
    );
    // 設置代表消息的業務關鍵屬性，請盡可能全局唯一
    // 以方便您在無法正常收到消息情況下，可通過 MQ 控製台查詢消息並補發
    // 注意：不設置也不會影響消息正常收發
    msg.setKey("ORDERID_100");
    //發送消息，隻要不拋出異常，就代表發送成功     
    try
    {
        SendResultONS sendResult = pProducer->send(msg);
    }
    catch(ONSClientException & e)
    {
        //自定義處理exception的細節
    }
    // 在應用退出前，必須銷毀Producer對象，否則會導致內存泄露等問題
    pProducer->shutdown();
    return 0;
}