C/C++ SDK集群方式订阅消息如何实现？

集群订阅即某个消费者集群只消费指定的Topic，而不是消费所有Topic。

1. #include "ONSFactory.h"
2. using namespace ons;
4. // MyMsgListener：创建消费消息的实例
5. //pushConsumer拉取到消息后，会主动调用该实例的consume 函数
6. class MyMsgListener : public MessageListener
7. {
9.     public:
11.         MyMsgListener()
12.         {
13.         }
15.         virtual ~MyMsgListener()
16.         {
17.         }
19.         virtual Action consume(Message &message, ConsumeContext &context)
20.         {
21.             //自定义消息处理细节
22.             return CommitMessage; //CONSUME_SUCCESS;
23.         }
24. };
27. int main(int argc, char* argv[])
28. {
30.     //pushConsumer创建和工作需要的参数，必须输入
31.     ONSFactoryProperty factoryInfo;
32.     factoryInfo.setFactoryProperty(ONSFactoryProperty::ConsumerId, "XXX");//您在MQ控制台申请的consumerId
33.     factoryInfo.setFactoryProperty(ONSFactoryProperty::PublishTopics,"XXX" );//您在MQ控制台申请的msg topic
34.     factoryInfo.setFactoryProperty(ONSFactoryProperty::AccessKey, "XXX");//阿里云身份验证，在阿里云服务器管理控制台创建
35.     factoryInfo.setFactoryProperty(ONSFactoryProperty::SecretKey,  "XXX");//阿里云身份验证，在阿里云服务器管理控制台创建
37.     //create pushConsumer
38.     PushConsumer* pushConsumer = ONSFactory::getInstance()->createPushConsumer(factoryInfo);
40.     //指定pushConsumer 订阅的消息topic和tag, 注册消息回调函数
41.     MyMsgListener  msglistener;
42.     pushConsumer->subscribe(factoryInfo.getPublishTopics(), "*",&msglistener );
44.     //start pushConsumer
45.     pushConsumer->start();
47.     //NOTE:直到不再接收消息，才能调用shutdown；调用shutdown之后，consumer退出，不能接收到任何消息
49.     //销毁pushConsumer, 在应用退出前，必须销毁Consumer 对象，否则会导致内存泄露等问题
50.     pushConsumer->shutdown();
51.     return 0;
53. }