阿里云-消息服務(wù)-SDK手冊-D

1、消息服務(wù)SDK使用手冊消息服務(wù)/SDK使用手冊消息服務(wù)/SDK使用手冊 PAGE 57 PAGE 57SDK使用手冊Java SDK MNS JavaSDK建議下載最新發(fā)布的SDK版本以獲得最佳性能和穩(wěn)定性。Version 1.1.5更新日期2016-05-26 sdk下載 sample下載更新內(nèi)容增加事務(wù)消息隊列TransactionQueue；增加一對多廣播消息功能；新增Javasdk性能測試示例代碼；使用幫助下載sample并解壓aliyun-sdk-mns-samples-1.1.5.zip；用Eclipse導(dǎo)入Maven工程，選中aliyun-sdk-mns-samples文件夾；在

2、用戶目錄(/home/YOURNAME/inLinuxorC:UsersYOURNAMEinWindows)中創(chuàng)建.perties文件，并填寫服務(wù)地址、AccessKeyID和AccessKeySecret：mns.accountendpoint=http:/$ mns.accountendpoint=http:/$ mns.accesskeyid=$your_accesskeyid mns.accesskeysecret=$your_accesskeysecret運行QueueSample.javaTopicSample.javaCloudPullTopicDemo.java（廣播消息示例代

3、碼）， TransactionMessageDemo.java（事務(wù)隊列完全封裝版使用示例），TransactionMessageDemo2.java（事務(wù)隊列用戶自定義版示例，需要用戶自定義本地事務(wù)，做failover處理）Version 1.1.4更新日期2016-04-25 sdk下載 sample下載更新內(nèi)容Subscription支持Queue/MailEndpointTopic支持消息過濾BugFix(maxConnectionsPerRoute)最大鏈接數(shù)導(dǎo)致請求超時使用幫助下載sample并解壓aliyun-sdk-mns-samples-1.1.4.zip；用Eclipse導(dǎo)

4、入Maven工程，選中aliyun-sdk-mns-samples文件夾；在用戶目錄(/home/YOURNAME/inLinuxorC:UsersYOURNAMEinWindows)中創(chuàng)建.perties文件，并填寫服務(wù)地址、AccessKeyID和AccessKeySecret：mns.accountendpoint=http:/$ mns.accountendpoint=http:/$ mns.accesskeyid=$your_accesskeyid mns.accesskeysecret=$your_accesskeysecret運行QueueSample.javaTopicSamp

5、le.javaVersion 1.1.3更新日期2016-03-28 sdk下載 sample下載更新內(nèi)容支持HTTPS去除Message對象中priority，dequeueCount，delaySeconds的默認(rèn)初始化值使用幫助下載sample并解壓aliyun-sdk-mns-samples-1.1.3.zip；用Eclipse導(dǎo)入Maven工程，選中aliyun-sdk-mns-samples文件夾；在用戶目錄(/home/YOURNAME/inLinuxorC:UsersYOURNAMEinWindows)中創(chuàng)建.perties文件，并填寫服務(wù)地址、AccessKeyID和Acce

6、ssKeySecret：mns.accountendpoint=http:/$ mns.accountendpoint=http:/$ mns.accesskeyid=$your_accesskeyid mns.accesskeysecret=$your_accesskeysecret運行QueueSample.javaTopicSample.javaVersion 1.1.2更新日期2016-01-30 sdk下載 sample下載更新內(nèi)容1. fixbug: popMessage接口無參數(shù)情況下waitseconds取QueueMeta中設(shè)置的值，而非0使用幫助下載sample并解壓ali

7、yun-sdk-mns-samples-1.1.2.zip；用Eclipse導(dǎo)入Maven工程，選中aliyun-sdk-mns-samples文件夾；在用戶目錄(/home/YOURNAME/inLinuxorC:UsersYOURNAMEinWindows)中創(chuàng)建.perties文件，并填寫服務(wù)地址、AccessKeyID和AccessKeySecret：mns.accountendpoint=http:/$ mns.accountendpoint=http:/$ mns.accesskeyid=$your_accesskeyid mns.accesskeysecret=$your_acc

8、esskeysecret運行QueueSample.javaTopicSample.javaVersion 1.1.1更新日期2016-01-19 sdk下載 sample下載更新內(nèi)容1. fixbug: 中文消息使用UTF8編碼，而非平臺默認(rèn)字符集使用幫助下載sample并解壓aliyun-sdk-mns-samples-1.1.1.zip；用Eclipse導(dǎo)入Maven工程，選中aliyun-sdk-mns-samples文件夾；在用戶目錄(/home/YOURNAME/inLinuxorC:UsersYOURNAMEinWindows)中創(chuàng)建.perties文件，并填寫服務(wù)地址、Acce

9、ssKeyID和AccessKeySecret：mns.accountendpoint=http:/$ mns.accountendpoint=http:/$ mns.accesskeyid=$your_accesskeyid mns.accesskeysecret=$your_accesskeysecret運行QueueSample.javaTopicSample.javaVersion 1.1.0更新日期2016-01-06 sdk下載 sample下載更新內(nèi)容添加對于Topic功能的支持添加對于STSToken的支持消息Base64編碼支持可選使用幫助下載sample并解壓aliyun-

10、sdk-mns-samples-1.1.0.zip；用Eclipse導(dǎo)入Maven工程，選中aliyun-sdk-mns-samples文件夾；在用戶目錄(/home/YOURNAME/inLinuxorC:UsersYOURNAMEinWindows)中創(chuàng)建.perties文件，并填寫服務(wù)地址、AccessKeyID和AccessKeySecret：mns.accountendpoint=http:/$ mns.accountendpoint=http:/$ mns.accesskeyid=$your_accesskeyid mns.accesskeysecret=$your_accessk

11、eysecret運行QueueSample.javaTopicSample.javaVersion 1.0.5更新日期2015-12-02 sdk下載 sample下載更新內(nèi)容修復(fù)bug：多CloudAccount對象時導(dǎo)致內(nèi)存泄漏依賴的httpasyncclient版本升至4.1使用幫助下載sample并解壓aliyun-sdk-mns-samples-1.0.5.zip；用Eclipse導(dǎo)入Maven工程，選中aliyun-sdk-mns-samples文件夾；在用戶目錄(/home/YOURNAME/inLinuxorC:UsersYOURNAMEinWindows)中創(chuàng)建.pertie

12、s文件，并填寫服務(wù)地址、AccessKeyID和AccessKeySecret：mns.accountendpoint=http:/$ mns.accountendpoint=http:/$ mns.accesskeyid=$your_accesskeyid mns.accesskeysecret=$your_accesskeysecret運行Sample.java文件Version 1.0.4更新日期2015-11-05 sdk下載 sample下載更新內(nèi)容修復(fù)bug：網(wǎng)絡(luò)異常時極端情況下線程掛起修復(fù)bug：關(guān)閉空閑連接回收常駐線程使用幫助下載sample并解壓aliyun-sdk-mns-

13、samples-1.0.4.zip；用Eclipse導(dǎo)入Maven工程，選中aliyun-sdk-mns-samples文件夾；在用戶目錄(/home/YOURNAME/inLinuxorC:UsersYOURNAMEinWindows)中創(chuàng)建.perties文件，并填寫服務(wù)地址、AccessKeyID和AccessKeySecret：mns.accountendpoint=http:/$ mns.accountendpoint=http:/$ mns.accesskeyid=$your_accesskeyid mns.accesskeysecret=$your_accesskeysecret

14、運行Sample.java文件Version 1.0.3更新日期2015-06-09 sdk下載 sample下載更新內(nèi)容修復(fù)bug：大量closewait的連接導(dǎo)致SDK掛起；增加samplecode；3. API協(xié)議升級：x-mns-version=2015-06-06；4. 支持BatchSendMessage、BatchReceiveMessage、BatchPeekMessage、BatchDeleteMessage；使用幫助下載sample并解壓aliyun-sdk-mns-samples-1.0.3.zip；用Eclipse導(dǎo)入Maven工程，選中aliyun-sdk-mns-s

15、amples文件夾；在用戶目錄(/home/YOURNAME/inLinuxorC:UsersYOURNAMEinWindows)中創(chuàng)建.perties文件，并填寫服務(wù)地址、AccessKeyID和AccessKeySecret：mns.accountendpoint=http:/$ mns.accountendpoint=http:/$ mns.accesskeyid=$your_accesskeyid mns.accesskeysecret=$your_accesskeysecret運行Sample.java文件Version 1.0.2更新日期2015-03-03 下載更新內(nèi)容1. 優(yōu)化

16、XML解析邏輯，提升性能Version 1.0.1更新日期2014-12-19 下載更新內(nèi)容1. 缺省線程池修正為50， 修復(fù)大規(guī)模并發(fā)同步時SDK端的性能瓶頸Version 1.0.0更新日期2014-08-01 下載隊列使用手冊本文檔介紹如何使用java sdk中的sample代碼，完成創(chuàng)建隊列、發(fā)送消息、接收刪除消息和刪除隊列操作。準(zhǔn)備下載最新版javasdk，解壓到aliyun-sdk-mns-samples文件夾；用Eclipse導(dǎo)入Maven工程，選中aliyun-sdk-mns-samples文件夾；在用戶目錄(Linux系統(tǒng)為/home/YOURNAME/目錄或者Windows

17、系統(tǒng)為.perties文件，并填寫服務(wù)地址、AccessKeyID和AccessKeySecret：AccessKeyId、AccessKeySecret訪問阿里云API的密鑰對；如果使用主賬號訪問，登陸AccessKey創(chuàng)建、查看；如果使用子賬號訪問，請登錄阿里云訪問控制控制臺查看；Endpoint訪問MNS的接入地址，登陸MNS控制臺 單擊右上角 獲取Endpoint 查看;不同地域的接入地址不同，分為公網(wǎng)以及內(nèi)網(wǎng)域名；創(chuàng)建隊列public class CreateQueueDemo public static void main(String args) CloudAccount acc

18、ount = new CloudAccount(YourAccessId, YourAccessKey, MNSEndpoint);MNSClient client = account.getMNSClient(); / 在程序中，CloudAccount以及MNSClient單例實現(xiàn)即可，多線程安全String queueName = TestQueue;public class CreateQueueDemo public static void main(String args) CloudAccount account = new CloudAccount(YourAccessId,

19、YourAccessKey, MNSEndpoint);MNSClient client = account.getMNSClient(); / 在程序中，CloudAccount以及MNSClient單例實現(xiàn)即可，多線程安全String queueName = TestQueue;QueueMeta metanew QueueMeta()/生成本地QueueMeta屬性，有關(guān)隊列屬性詳細(xì)介紹見/document_detail/27476.htmlmeta.setQueueName(queueName); / 設(shè)置隊列名meta.setPollingWaitSeconds(15); meta.

20、setMaxMessageSize(2048L);try CloudQueue queue = client.createQueue(meta); catch (ClientException ce)System.out.println(Something wrong with the network connection between client and MNS service.+ Please check your network and DNS availablity.); ce.printStackTrace(); catch (ServiceException ex)if (se

21、.getErrorCode().equals(QueueNotExist)System.out.println(Queue is not exist.Please create before use); else if (se.getErrorCode().equals(TimeExpired)System.out.println(The request is time expired. Please check your local machine timeclock);se.printStackTrace(); catch (Exception e)System.out.println(U

22、nknown exception happened!); e.printStackTrace();client.close(); / 程序退出時，需主動調(diào)用client的close方法進行資源釋放發(fā)送消息public class ProducerDemo public static void main(String args) public class ProducerDemo public static void main(String args) CloudAccount account = new CloudAccount(YourAccessId, YourAccessKey, MNS

23、Endpoint);MNSClient client = account.getMNSClient(); / 在程序中，CloudAccount以及MNSClient單例實現(xiàn)即可，多線程安全try CloudQueue queue = client.getQueueRef(TestQueue); Message message = new Message(); message.setMessageBody(I am test message ); Message putMsg = queue.putMessage(message);System.out.println(Send message

24、 id is: + putMsg.getMessageId(); catch (ClientException ce)System.out.println(Something wrong with the network connection between client and MNS service.+ Please check your network and DNS availablity.); ce.printStackTrace(); catch (ServiceException ex)if (se.getErrorCode().equals(QueueNotExist)Syst

25、em.out.println(Queue is not exist.Please create before use); else if (se.getErrorCode().equals(TimeExpired)System.out.println(The request is time expired. Please check your local machine timeclock);se.printStackTrace(); catch (Exception e)System.out.println(Unknown exception happened!); e.printStack

26、Trace();client.close(); / 程序退出時，需主動調(diào)用client的close方法進行資源釋放client.close(); / 程序退出時，需主動調(diào)用client的close方法進行資源釋放接收和刪除消息public class ConsumerDemo public static void main(String args) public class ConsumerDemo public static void main(String args) CloudAccount account = new CloudAccount(YourAccessId, YourAcc

27、essKey, MNSEndpoint);MNSClient clientaccount.getMNSClient()/，CloudAccount以及MNSClient單例實現(xiàn)即可，多線程安全tryCloudQueue queue = client.getQueueRef(TestQueue);Message popMsg = queue.popMessage(); if (popMsg != null)System.out.println(message handle: + popMsg.getReceiptHandle(); System.out.println(message body:

28、 + popMsg.getMessageBodyAsString(); System.out.println(message id: + popMsg.getMessageId(); System.out.println(messagedequeuecount:+popMsg.getDequeueCount();/刪除已經(jīng)取出消費的消息queue.deleteMessage(popMsg.getReceiptHandle(); System.out.println(delete message successfully.n);elseSystem.out.println(message not

29、 exist in TestQueue.n); catch (ClientException ce)System.out.println(Something wrong with the network connection between client and MNS service.+ Please check your network and DNS availablity.); ce.printStackTrace(); catch (ServiceException se)if (se.getErrorCode().equals(QueueNotExist)System.out.pr

30、intln(Queue is not exist.Please create queue before use); else if (se.getErrorCode().equals(TimeExpired)System.out.println(The request is time expired. Please check your local machine timeclock);se.printStackTrace(); catch (Exception e)System.out.println(Unknown exception happened!); e.printStackTra

31、ce();client.close();public class DeleteQueueDemo public static void main(String args) CloudAccount account = new CloudAccount(YourAccessId, YourAccessKey, MNSEndpoint);MNSClient clientpublic class DeleteQueueDemo public static void main(String args) CloudAccount account = new CloudAccount(YourAccess

32、Id, YourAccessKey, MNSEndpoint);MNSClient clientaccount.getMNSClient()/，CloudAccount以及MNSClient單例實現(xiàn)即可，多線程安全tryCloudQueue queue = client.getQueueRef(TestQueue);queue.delete(); catch (ClientException ce)System.out.println(Something wrong with the network connection between client and MNS service.+ Ple

33、ase check your network and DNS availablity.); ce.printStackTrace(); catch (ServiceException se)se.printStackTrace(); catch (Exception e)System.out.println(Unknown exception happened!); e.printStackTrace();client.close();主題使用手冊本文檔介紹如何使用java sdk中的sample代碼，完成創(chuàng)建主題、創(chuàng)建訂閱，發(fā)布消息、接收消息以及刪除主題等操作。準(zhǔn)備下載最新版javasdk，

34、解壓到aliyun-sdk-mns-samples文件夾；用Eclipse導(dǎo)入Maven工程，選中aliyun-sdk-mns-samples文件夾；在用戶目錄(Linux系統(tǒng)為/home/YOURNAME/目錄或者Windows系統(tǒng)為.perties文件，并填寫服務(wù)地址、AccessKeyID和AccessKeySecret：AccessKeyId、AccessKeySecret訪問阿里云API的密鑰對；創(chuàng)建主題如果使用主賬號訪問，登陸AccessKey創(chuàng)建、查看；如果使用子賬號訪問，請登錄阿里云訪問控制控制臺查看；Endpoint訪問MNS的接入地址，登陸MNS控制臺 單擊右上角 獲取En

35、dpoint 查看;不同地域的接入地址不同，分為公網(wǎng)以及內(nèi)網(wǎng)域名；public class CreateTopicDemo public static void main(String args) CloudAccount account = new CloudAccount(YourAccessId, YourAccessKey, MNSEndpoint);MNSClient client = account.getMNSClient(); / 在程序中，CloudAccount以及MNSClient單例實現(xiàn)即可，多線程安全String topicName = TestTopic; Topi

36、cMeta meta = new TopicMeta(); meta.setTopicName(topicName);public class CreateTopicDemo public static void main(String args) CloudAccount account = new CloudAccount(YourAccessId, YourAccessKey, MNSEndpoint);MNSClient client = account.getMNSClient(); / 在程序中，CloudAccount以及MNSClient單例實現(xiàn)即可，多線程安全String t

37、opicName = TestTopic; TopicMeta meta = new TopicMeta(); meta.setTopicName(topicName);try CloudTopic topic = client.createTopic(meta); catch (Exception e) e.printStackTrace();System.out.println(create topic error, + e.getMessage();client.close();啟動HttpEndpoint對MNS推送消息請求做簽名驗證； 解析推送請求的消息body體；返回相應(yīng)的處理返回

38、碼：200；對MNS推送消息請求做簽名驗證； 解析推送請求的消息body體；返回相應(yīng)的處理返回碼：200；HttpEndpoint的具體實現(xiàn)源碼可參考sdk中源碼；創(chuàng)建訂閱public class SubscribeDemo 對已經(jīng)創(chuàng)建好的主題Topic進行訂閱，在訂閱時需要設(shè)置對應(yīng)的推送Endpoint地址（目前支持HTTP、郵件以及 隊列）、錯誤重試策略、推送消息格式等；public class SubscribeDemo public static void main(String args) CloudAccount account = new CloudAccount(YourAcc

39、essId, YourAccessKey, MNSEndpoint);MNSClient client = account.getMNSClient(); / 在程序中，CloudAccount以及MNSClient單例實現(xiàn)即可，多線程安全public static void main(String args) CloudAccount account = new CloudAccount(YourAccessId, YourAccessKey, MNSEndpoint);MNSClient client = account.getMNSClient(); / 在程序中，CloudAccoun

40、t以及MNSClient單例實現(xiàn)即可，多線程安全CloudTopic topic = client.getTopicRef(TestTopic); try SubscriptionMeta subMeta = new SubscriptionMeta(); subMeta.setSubscriptionName(TestSub); subMeta.setEndpoint(HttpEndpoint.GenEndpointLocal(); subMeta.setNotifyContentFormat(SubscriptionMeta.NotifyContentFormat.XML); String

41、 subUrl = topic.subscribe(subMeta);System.out.println(subscription url: + subUrl); catch (Exception e) e.printStackTrace();System.out.println(subscribe/unsubribe error);client.close();5.發(fā)布消息public class PublishMessageDemo public static void main(String args) CloudAccount account = new CloudAccount(Y

42、ourAccessId, YourAccessKey, MNSEndpoint);public class PublishMessageDemo public static void main(String args) CloudAccount account = new CloudAccount(YourAccessId, YourAccessKey, MNSEndpoint);MNSClient client = account.getMNSClient(); / 在程序中，CloudAccount以及MNSClient單例實現(xiàn)即可，多線程安全CloudTopic topic = clie

43、nt.getTopicRef(TestTopic); try TopicMessage msgnew Base64TopicMessage()/可以使用TopicMessage結(jié)構(gòu)，選擇不進行Base64加密msg.setMessageBody(hello world!);msg = topic.publishMessage(msg); System.out.println(msg.getMessageId(); System.out.println(msg.getMessageBodyMD5(); catch (Exception e) e.printStackTrace(); System

44、.out.println(subscribe error);client.close();查看HttpEndpoint接收消息第5步發(fā)布了一條消息到Topic中，MNS會將該消息推送到所有的訂閱Endpoint，本例中的HttpEndpoint會將 接收到的消息打印出來。取消訂閱public class UnsubscribeDemo public static void main(String args) CloudAccount account = new CloudAccount(YourAccessId, YourAccessKey, MNSEndpoint);public class

45、 UnsubscribeDemo public static void main(String args) CloudAccount account = new CloudAccount(YourAccessId, YourAccessKey, MNSEndpoint);MNSClient client = account.getMNSClient(); / 在程序中，CloudAccount以及MNSClient單例實現(xiàn)即可，多線程安全CloudTopic topic = client.getTopicRef(TestTopic); try topic.unsubscribe(TestSub

46、); catch (Exception e) e.printStackTrace(); System.out.println(unsubribe error);client.close();8.刪除主題public class DeleteTopicDemo public static void main(String args) CloudAccount account = new CloudAccount(YourAccessId, YourAccessKey, MNSEndpoint);public class DeleteTopicDemo public static void mai

47、n(String args) CloudAccount account = new CloudAccount(YourAccessId, YourAccessKey, MNSEndpoint);MNSClient client = account.getMNSClient(); / 在程序中，CloudAccount以及MNSClient單例實現(xiàn)即可，多線程安全CloudTopic topic = client.getTopicRef(TestTopic); try topic.delete(); catch (Exception e) e.printStackTrace(); System.

48、out.println(delete topic error);client.close();public class ProducerDemo public static void main(String args) public class ProducerDemo public static void main(String args) CloudAccount account = new CloudAccount(YourAccessId, YourAccessKey, MNSEndpoint);/這個client僅初始化一次/這個client僅初始化一次MNSClient clien

49、t = account.getMNSClient();/循環(huán)發(fā)送10條消息try/TestQueue是你的測試隊列，請?zhí)崆皠?chuàng)建CloudQueue queue = client.getQueueRef(TestQueue); for (int i = 0; i 10; i+)Message message = new Message(); message.setMessageBody(I am test message + i); Message putMsg = queue.putMessage(message);System.out.println(Send message id is:

50、+ putMsg.getMessageId(); catch (ClientException ce)System.out.println(Something wrong with the network connection between client and MNS service.+ Please check your network and DNS availablity.); ce.printStackTrace(); catch (ServiceException se)if (se.getErrorCode().equals(QueueNotExist)System.out.p

51、rintln(Queue is not exist.Please create before use); else if (se.getErrorCode().equals(TimeExpired)System.out.println(The request is time expired. Please check your local machine timeclock);/*you can get more MNS service error code from following link: /document_detail/mns/api_reference/error_code/e

52、rror_code.html*/ se.printStackTrace(); catch (Exception e)System.out.println(Unknown exception happened!); e.printStackTrace();client.close();public class ConsumerDemo public static void main(String args) public class ConsumerDemo public static void main(String args) CloudAccount account = new Cloud

53、Account(YourAccessId, YourAccessKey, MNSEndpoint);/this client need only initialize once MNSClient client = account.getMNSClient();/循環(huán)消費10條消息tryCloudQueue queue = client.getQueueRef(TestQueue); for (int i = 0; i 10; i+)Message popMsg = queue.popMessage(); if (popMsg != null)System.out.println(messag

54、e handle: + popMsg.getReceiptHandle(); System.out.println(message body: + popMsg.getMessageBodyAsString(); System.out.println(message id: + popMsg.getMessageId(); System.out.println(messagedequeuecount:+popMsg.getDequeueCount();/刪除已經(jīng)消費的消息queue.deleteMessage(popMsg.getReceiptHandle(); System.out.prin

55、tln(delete message successfully.n);elseSystem.out.println(message not exist in TestQueue.n); catch (ClientException ce)System.out.println(Something wrong with the network connection between client and MNS service.+ Please check your network and DNS availablity.); ce.printStackTrace(); catch (Service

56、Exception se)if (se.getErrorCode().equals(QueueNotExist)System.out.println(Queue is not exist.Please create queue before use); else if (se.getErrorCode().equals(TimeExpired)System.out.println(The request is time expired. Please check your local machine timeclock);/*you can get more MNS service error

57、 code in following link. /document_detail/mns/api_reference/error_code/error_code.html*/ se.printStackTrace(); catch (Exception e)System.out.println(Unknown exception happened!); e.printStackTrace();client.close();并發(fā)測試Case本文檔介紹了基于Java SDK提供的隊列消息發(fā)送以及消費的并發(fā)測試Case。用戶可指定并發(fā)度、運行時間；用戶可指定并發(fā)度、運行時間；使用發(fā)送總請求數(shù)除以運

58、行時間得到QPS；初始化Endpoint= AccessId= AccessKey=Endpoint= AccessId= AccessKey=QueueName=JavaSDKPerfTestQueue ThreadNum=200TotalSeconds=180注：ThreadNum是發(fā)送/消費的線程數(shù)，MNS具備強大的高并發(fā)擴展性能； TotalSeconds是測試Case運行的時間；ThreadNum是發(fā)送/消費的線程數(shù)，MNS具備強大的高并發(fā)擴展性能； TotalSeconds是測試Case運行的時間；package com.aliyun.mns;import com.aliyun.m

59、ns.client.CloudAccount; import com.aliyun.mns.client.CloudQueue; import com.aliyun.mns.client.MNSClient;import mon.http.ClientConfiguration; package com.aliyun.mns;import com.aliyun.mns.client.CloudAccount; import com.aliyun.mns.client.CloudQueue; import com.aliyun.mns.client.MNSClient;import mon.ht

60、tp.ClientConfiguration; import com.aliyun.mns.model.Message;import com.aliyun.mns.model.QueueMeta;import java.io.BufferedInputStream; import java.io.FileInputStream;import java.io.FileNotFoundException; import java.io.IOException;import java.util.ArrayList; import java.util.Properties;import java.ut