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-阿里云