用户使用已创建Queue作为Endpoint对Topic内容进行订阅;当有消息发布到Topic中时,Topic会通过内部数据通道,将Topic中的消息推送到各个订阅的Queue中。用户只需对订阅的Queue进行轮询拉取即可。
client = new DefaultMNSClient(ServiceSettings.getMNSEndpoint(),
ServiceSettings.getMNSAccessKeyId(),
ServiceSettings.getMNSAccessKeySecret());
// 创建队列Queue
String queueName = "JavaSDKTestQueue";
String subName = "JavaTestSub"
QueueMeta queueMeta = new QueueMeta();
queueMeta.setQueueName(queueName);
CloudQueue queue = client.createQueue(queueMeta);
// 创建主题Topic
String topicName = "SampleTopic";
TopicMeta meta = new TopicMeta();
meta.setTopicName(topicName);
topic = client.createTopic(meta);
// 使用队列作为endpoint进行订阅
String queueEndpoint = topic.generateQueueEndpoint(queueName);
SubscriptionMeta subMeta = new SubscriptionMeta();
subMeta.setSubscriptionName(subName);
subMeta.setNotifyStrategy(SubscriptionMeta.NotifyStrategy.EXPONENTIAL_DECAY_RETRY);
subMeta.setEndpoint(queueEndpoint);
String subUrl = topic.subscribe(subMeta);
在文档使用中是否遇到以下问题
更多建议
匿名提交