.NET SDK 集群方式订阅消息如何实现？

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

1. using System;
2. using System.Collections.Generic;
3. using System.Linq;
4. using System.Text;
5. using System.Runtime.InteropServices;
6. using ons;
8. namespace ons
9. {
11.     //pushConsumer拉取到消息后，会主动调用该实例的consumer函数
12.     public class MyMsgListener : MessageListener
13.     {    
14.         public MyMsgListener()
15.         {
16.         }
18.         ~MyMsgListener()
19.         {
20.         }
22.         public override  Action  consume(Message value, ConsumeContext context)
23.         {
24.             /*
25.                    所有中文编码相关问题都在SDK压缩包包含的文档里做了说明，请仔细阅读
26.            */
27.             return ons.Action.CommitMessage;
28.         }
29.     }
31.     class onscsharp
32.     {
33.            static void Main(string[] args)
34.         {
35.             //pushConsumer创建和工作需要的参数，必须输入
36.             ONSFactoryProperty factoryInfo = new ONSFactoryProperty();
37.             factoryInfo.setFactoryProperty(factoryInfo.ConsumerId, "XXX");//您在MQ控制台申请的Consumer ID
38.             factoryInfo.setFactoryProperty(factoryInfo.PublishTopics, "XXX");//您在MQ控制台申请的Topic
39.             factoryInfo.setFactoryProperty(factoryInfo.AccessKey,"xx");//AccessKey 阿里云身份验证，在阿里云服务器管理控制台创建
40.             factoryInfo.setFactoryProperty(factoryInfo.SecretKey, "xxxx");//SecretKey 阿里云身份验证，在阿里云服务器管理控制台创建
42.             //create consumer
43.             ONSFactory onsfactory = new ONSFactory();
44.             PushConsumer pConsumer = onsfactory.getInstance().createPushConsumer(factoryInfo);
46.             //register msg listener and subscribe msg topic
47.             MessageListener msgListener = new MyMsgListener();
48.             pConsumer.subscribe(factoryInfo.getPublishTopics(), "*",  msgListener);
50.             //start consumer  
51.             pConsumer.start();  
52.             //consumer启动后，会自动拉取消息，拉取到消息后，会自动调用MyMsgListener实例的consume函数；    
54.             //确定消费完成后，调用shutdown函数；在应用退出前，必须销毁Consumer 对象，否则会导致内存泄露等问题
55.             pConsumer.shutdown();
56.         }
57.     }
58. }