53      阿裏雲

訂閱消息__快速入門_消息隊列 MQ-阿裏雲

消息發送成功後，訂閱方需要對消息進行訂閱。訂閱消息需要通過調用相關協議及開發語言的 SDK/API 來完成。

調用 TCP Java SDK 訂閱消息

您可以運行以下示例代碼來測試訂閱消息的功能。運行代碼前請按照說明正確設置相關參數。

public class ConsumerTest {
    public static void main(String[] args) {
        Properties properties = new Properties();
        properties.put(PropertyKeyConst.ConsumerId, "XXX");// 您在MQ控製台創建的Consumer ID
        properties.put(PropertyKeyConst.AccessKey, "XXX");// 鑒權用AccessKey，在阿裏雲服務器管理控製台創建
        properties.put(PropertyKeyConst.SecretKey, "XXX");// 鑒權用SecretKey，在阿裏雲服務器管理控製台創建
        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");
    }
}

查看消息訂閱是否成功

完成上述步驟後，您可以在 MQ 控製台查看訂閱端是否啟動成功，即消息訂閱是否成功。

1. 在 MQ 控製台左側菜單欄依次單擊發布訂閱管理>訂閱管理。

2. 找到要查看的 Topic，單擊右側操作選項裏的消費者狀態。 如果是否在線顯示為是，則說明訂閱端已成功啟動。

   如果消費者狀態是否在線顯示為否，請參考消費者狀態問題排查。

   

完成以上所有步驟後，您就成功接入了 MQ 服務，可以用 MQ 進行消息發送和訂閱了。

最後更新：2016-11-23 16:04:04

  上一篇： 申請資源__快速入門_消息隊列 MQ-阿裏雲

  下一篇： Demo 環境準備__MQ Demo 工程_消息隊列 MQ-阿裏雲