543      財經資訊

集群方式訂閱消息__Java SDK_TCP 接入(專業)_消息隊列 MQ-阿裏雲

集群訂閱即某個消費者集群隻消費指定的 Topic，而不是消費所有 Topic。

public class ConsumerTest {
    public static void main(String[] args) {
        Properties properties = new Properties();
        properties.put(PropertyKeyConst.ConsumerId, "XXX");// 您在控製台創建的 Consumer ID
        properties.put(PropertyKeyConst.AccessKey, "XXX");// AccessKey 阿裏雲身份驗證，在阿裏雲服務器管理控製台創建
        properties.put(PropertyKeyConst.SecretKey, "XXX");// SecretKey 阿裏雲身份驗證，在阿裏雲服務器管理控製台創建
        //公有雲生產環境：https://onsaddr-internal.aliyun.com:8080/rocketmq/nsaddr4client-internal
        //公有雲公測環境：https://onsaddr-internet.aliyun.com/rocketmq/nsaddr4client-internet
        //杭州金融雲環境：https://jbponsaddr-internal.aliyun.com:8080/rocketmq/nsaddr4client-internal
        //杭州深圳雲環境：https://mq4finance-sz.addr.aliyun.com:8080/rocketmq/nsaddr4client-internal
        properties.put(PropertyKeyConst.ONSAddr,
          "https://onsaddr-internal.aliyun.com:8080/rocketmq/nsaddr4client-internal");//此處以公有雲生產環境為例
        Consumer consumer = ONSFactory.createConsumer(properties);
        consumer.subscribe("TopicTestMQ", "*", new MessageListener() {
            public Action consume(Message message, ConsumeContext context) {
                System.out.println("Receive: " + message);
                return Action.CommitMessage;
            }
        });
        consumer.start();
        System.out.println("Consumer Started");
    }
}