阿里云-消息队列-API指南-D

1、消息队列OPEN API消息队列/OPEN API消息队列/OPEN API PAGE 70 PAGE 70OPEN APIONS OPEN API说明Open API调用过程Open API 底层通过HTTP接口提供服务，用户调用OpenAPI的SDK，发出Http请求到应用网关POP，再由POP将请求转发给MQ的后端服务去执行。用户将参数封装到每个请求中，每个请求即对应一个方法。执行的结果放在response中。请求和响应的字符编 码都是采用UTF-8编码。注意：因为POP网关是面对公网环境提供服务的，因此使用Open-API的前提是，客户端需要能够访问公网服务。否则会提示服务无法连接Op

2、en API 调用说明客户端依赖公测期间，ons open api的sdk获取方法有2种，一种是下载sdk源码，编译后加入到本地的maven仓库中，另一种是下载打包好的jar包，直接导入工程中。com.aliyunaliyun-java-sdk-ons1.2.0-SNAPSHOTcom.aliyunaliyun-java-sdk-core2.2.0其中aliyun-java-sdk-ons的包目前还没有部署到软件仓库中，所以是从官网上下载SDK到本地，编译部署到本 地的软件仓库中。SDK的源码下载链接（2）下载Jar包com.aliyunaliyun-java-sdk-core2.2.0其中a

3、liyun-java-sdk-ons的jar包是从官网上下载SDK到本地。SDK的Jar包下载链接String regionId = cn-hangzhou;String accessKey = XXXXXXXXXXXXXXXXX; String secretKey = XXXXXXXXXXXXXXXXX; String endPointName =cn-hangzhou; String productName =Ons;String domain =;/*根据自己所在的区域选择Region后,设置对应的接入点String regionId = cn-hangzhou;String acces

4、sKey = XXXXXXXXXXXXXXXXX; String secretKey = XXXXXXXXXXXXXXXXX; String endPointName =cn-hangzhou; String productName =Ons;String domain =;/*根据自己所在的区域选择Region后,设置对应的接入点*/ try DefaultProfile.addEndpoint(endPointName,regionId,productName,domain); catch (ClientException e) e.printStackTrace();IClientPro

5、file profile= DefaultProfile.getProfile(regionId,accessKey,secretKey); IAcsClient iAcsClient= new DefaultAcsClient(profile);参数说明cn-beijing,cn-hangzhou,cn-qingdao,cn- shenzhen,默认是杭州。accessKey，指的是用户在阿里云官网上获取的AKsecretKey，指的是用户在阿里云官网上获得的SKendPointName,接入点名称,例如cn-hangzhouproductName,OpenAPI的产品名称,直接写Ons即可

6、.domain , OpenAPI的接入点Domain,规则是ons.$RegionId. ,目前MQ支持OpenAPI的Region参考表如下区域名称RegionIdDomain备注公有云北京- 使用公有云北京Region的用户建议此接入点公有云青岛- qingdao.aliyuncs.co m使用公有云青岛Region的用户建议此接入点公有云杭州- hangzhou.aliyuncs.c om使用公有云杭州Region的用户建议此接入点公有云上海- shanghai.aliyuncs.co m使用公有云上海Region的用户建议此接入点公有云深圳- shenzhen.aliyuncs.co

7、 m使用公有云深圳Region的用户建议此接入点金融云杭州cn-hangzhou- -hangzhou- 使用金融云杭州Region的用户建议此接入点需要注意：创建ACS客户端使用的regionId只是代表API的接入点,跟MQ本身提供服务的Region名称并不是一 个概念。实际使用MQ的OpenAPI时，一般都需要通过 setONSRegionId（）方法来设置访问ONS哪个区域的资源。该值必须要通过OnsRegionList方法获取列表来配置，因为OnsRegionId是变动的，不能够写固定值获取ONSRegionIdList的方法历史版本说明API版本：1.2.0-SNAPSHOT支持R

8、egion化调用支持账号授权API支持消息发送接收的趋势查询APIAPI版本：1.1.1-SNAPSHOT支持根据Topic做分页查询消息清除消息堆积支持全清和根据时间戳2种方式API版本：1.1.0-SNAPSHOTOpenAPI支持动态错误码TopicGet接口不再需要输入Region信息，可以用于查询某个Topic属于哪个Region该版本升级为Https接入。版本号1.1.0-SNAPSHOT，将不再支持。变换版本号为1.1.0-SNAPSHOTAPI版本：1.0.2-SNAPSHOTOpenAPI修复若干bug创建topic时，重复情况下异常信息透传。查询消息需要传入topic全面添

9、加鉴权需要的信息添加消息轨迹的api接口报警接口，添加list等接口API版本：1.0.1-SNAPSHOTOpenAPI修复若干bug把返回结果中所有regionId替换成OnsRegionId以和POP的regionId区分开，方便用户理 解修复consumerstatus返回结果中的若干问题，保护consumetime超界，clientId没有说明 等问题修复consumestatus等接口返回的List为空等问题。变换版本号为1.0.1-SNAPSHOTAPI版本：1.0.0-SNAPSHOTOpenAPI上线测试更新文档中的参数说明，修复regionidList等方法的使用添加接入A

10、PI的依赖描述Topic相关接口获取当前集群的Topic列表描述根据用户指定的ONS区域，查询用户所拥有的所有Topic的信息。请求参数名称类型是否必须描述OnsRegionIdString是当前查询ONS所在区域，可以通过ONSRegionList方法获取OnsPlatformString否该请求来源，默认是从POP平台PreventCacheLong是用于CSRF校验，设置为系统当前时间即可TopicString否查询指定Topic时设置，否则查询所有topic名称类型描述返回参数名称类型描述RequestIdString为公共参数，每个请求独一无二HelpUrlString帮助链接Dat

11、aList(PublishInfoDo)返回所有已发布的Topic信息列表PublishInfoDo数据结构成员类型描述idLong该发布信息在数据库中的IDchannelIdInteger该Topic所在区域ID，0- ALIYUN，1-CLOUD，2,3,4channelNameString该Topic所在区域名称，ALIYUN,CLOUD,.onsRegionIdLong该Topic所在区域ID，就是ONSRegionList方法获取的内容regionNameString该topic所在区域名称topicStringTopic名称ownerStringTopic所有者编号relation

12、Integer所有关系编号1-持有者，2-可以发布，4-可以订阅，6-可以发布和订阅relationNameString所有关系名称，例如持有者、可订阅、可发布、可发布订阅statusInteger当前状态编号（0 服务中 1 冻结2 暂停）statusNameString当前状态别名，服务中，appkeyIntegernullcreateTimeLong创建时间updateTimeLong更新时间remarkString备注，可以不填使用示例public static void main (Stringargs) String regionId = cn-hangzhou;Stringpub

13、lic static void main (Stringargs) String regionId = cn-hangzhou;StringaccessKey=XXXXXXXXXXXXXXXXX; StringsecretKey=XXXXXXXXXXXXXXXXX; String endPointName=cn-hangzhou;String productName =Ons;String productName =Ons;String domain =;/*根据自己所在的区域选择Region后,设置对应的接入点*/ try DefaultProfile.addEndpoint(endPoin

14、tName,regionId,productName,domain); catch (ClientException e) e.printStackTrace();IClientProfile profile= DefaultProfile.getProfile(regionId,accessKey,secretKey); IAcsClient iAcsClient= new DefaultAcsClient(profile);OnsTopicListRequest request =new OnsTopicListRequest();/*ONSRegionId是指你需要API访问ONS哪个区

15、域的资源。*该值必须要根据OnsRegionList方法获取的列表来选择和配置，因为OnsRegionId是变动的，不能够写固定值*/ request.setOnsRegionId(daily);request.setPreventCache(System.currentTimeMillis(); request.setTopic(XXXXXXXXXXXXX);try OnsTopicListResponse response=client.getAcsResponse(request); List publishInfoDoList=response.getData(); for(OnsTo

16、picListResponse.PublishInfoDo publishInfoDo:publishInfoDoList)System.out.println(publishInfoDo.getTopic()+publishInfoDo.getOwner(); catch (ServerException e) e.printStackTrace(); catch (ClientException e) e.printStackTrace();返回结果JODIE_TEST_16dd 1344371 JODIE_TEST_17dd 1344371 JODIE_TEST_18dd 1344371

17、 JODIE_TEST_19dd1344371 JODIE_TEST_20dd 1344371 JODIE_TEST_21dd 1344371 JODIE_TEST_24dd 1344371JODIE_TEST_27dd 1344371 JODIE_TEST_28dd 1344371 Mingduan_TEST_28dd 1344371Mingduan_TEST_00dd 1344371 Mingduan_TEST_10dd 1344371 Mingduan_10dd 1344371创建Topic描述根据用户指定的ONS区域，创建Topic，一个用户下面的topic不可以重复,重复申请会抛出服

18、务器内部异常，在 用户端显示为unknownerror。请求参数名称类型是否必须描述OnsRegionIdString是当前查询ONS所在区域，可以通过OnsRegionList方法获取OnsPlatformString否该请求来源，默认是从POP平台PreventCacheLong是用于CSRF校验，设置为系统当前时间即可TopicString是需要创建的topic名称，在一个用户下不可重复，即使区域不同QpsLong否设置该Topic的QPS估计StatusInteger否Topic申请的状态,（0 服务中 1 冻结 2 暂停）RemarkString否备注，可以不填AppkeyStrin

19、g否应用的KeyAppNameString否应用名注意：OnsRegionId返回参数名称类型描述RequestIdString为公共参数，每个请求独一无二HelpUrlString帮助链接使用示例public static void main(String args) String regionId = cn-hangzhou;String accessKey = XXXXXXXXXXXXXXXXX; String secretKey = XXXXXXXXXXXXXXXXX; String endPointName =cn-hangzhou; String productName =Ons;

20、public static void main(String args) String regionId = cn-hangzhou;String accessKey = XXXXXXXXXXXXXXXXX; String secretKey = XXXXXXXXXXXXXXXXX; String endPointName =cn-hangzhou; String productName =Ons;String domain =;/*根据自己所在的区域选择Region后,设置对应的接入点*/ try DefaultProfile.addEndpoint(endPointName,regionI

21、d,productName,domain); catch (ClientException e) e.printStackTrace(); catch (ClientException e) e.printStackTrace();IClientProfile profile= DefaultProfile.getProfile(regionId,accessKey,secretKey); IAcsClient iAcsClient= new DefaultAcsClient(profile);OnsTopicCreateRequest request = new OnsTopicCreate

22、Request(); request.setAcceptFormat(FormatType.JSON); request.setTopic(XXXXXXXX);request.setQps(1000l); request.setRemark(test); request.setStatus(0);/*ONSRegionId是指你需要API访问ONS哪个区域的资源。*该值必须要根据OnsRegionList方法获取的列表来选择和配置，因为OnsRegionId是变动的，不能够写固定值*/ request.setOnsRegionId(daily); request.setCluster(taob

23、aodaily);request.setPreventCache(System.currentTimeMillis(); try OnsTopicCreateResponseresponse=client.getAcsResponse(request); System.out.println(response.getRequestId();catch (ServerException e) e.printStackTrace();catch (ClientException e) e.printStackTrace();catch (Exception e) e.printStackTrace

24、();返回结果0EA3E854-0115-45F4-9210-97EAECC0A562删除指定Topic描述根据用户指定的ONS区域，找到用户指定的Topic，删除。请求参数名称类型是否必须描述OnsRegionIdString是当前查询ONS所在区域，可以通过ONSRegionList方法获取OnsPlatformString否该请求来源，默认是从POP平台PreventCacheLong是用于CSRF校验，设置为系统当前时间即可TopicString是指定删除的TopicClusterString否指定Topic所在的集群名称返回参数名称类型描述RequestIdString为公共参数，每

25、个请求独一无二HelpUrlString帮助链接使用示例public static void main(Stringargs) String regionId = cn-hangzhou;String accessKey = XXXXXXXXXXXXXXXXX; String secretKey = XXXXXXXXXXXXXXXXX; String endPointName =cn-hangzhou; String productName =Ons;public static void main(Stringargs) String regionId = cn-hangzhou;String

26、 accessKey = XXXXXXXXXXXXXXXXX; String secretKey = XXXXXXXXXXXXXXXXX; String endPointName =cn-hangzhou; String productName =Ons;String domain =;/*根据自己所在的区域选择Region后,设置对应的接入点*/ try DefaultProfile.addEndpoint(endPointName,regionId,productName,domain); catch (ClientException e) e.printStackTrace();ICli

27、entProfile profile= DefaultProfile.getProfile(regionId,accessKey,secretKey); IAcsClient iAcsClient= new DefaultAcsClient(profile);OnsTopicDeleteRequest request =new OnsTopicDeleteRequest(); request.setCluster(taobaodaily); request.setPreventCache(System.currentTimeMillis();/*ONSRegionId是指你需要API访问ONS

28、哪个区域的资源。*该值必须要根据OnsRegionList方法获取的列表来选择和配置，因为OnsRegionId是变动的，不能够写固定值*/ request.setOnsRegionId(daily); request.setTopic(Mingduan_67dd); try OnsTopicDeleteResponseresponse=client.getAcsResponse(request); System.out.println(response.getRequestId();catch (ServerException e) e.printStackTrace();catch (Se

29、rverException e) e.printStackTrace();catch (ClientException e) e.printStackTrace();catch (Exception e) e.printStackTrace();返回结果63A8024F-7763-4BBE-AA56-C8E2408B358A查询指定Topic描述根据用户指定的ONS区域，查询用户指定的Topic，类似于TopicList请求参数名称类型是否必须描述OnsRegionIdString否当前查询ONS所在区域，可以通过ONSRegionList方法获取OnsPlatformString否该请求来源

30、，默认是从POP平台PreventCacheLong是用于CSRF校验，设置为系统当前时间即可TopicString是查询指定Topic时设置返回参数名称类型描述RequestIdString为公共参数，每个请求独一无二HelpUrlString帮助链接DataList(PublishInfoDo)返回所有已发布的Topic信息列表PublishInfoDo数据结构成员类型描述idLong该发布信息在数据库中的IDchannelIdInteger该Topic所在区域ID，0- ALIYUN，1-CLOUD，2,3,4channelNameString该Topic所在区域名称，ALIYUN,CL

31、OUD,.onsRegionIdLong该Topic所在区域ID，就是ONSRegionList方法获取的内容regionNameString该topic所在区域名称topicStringTopic名称ownerStringTopic所有者编号relationInteger所有关系编号1-持有者，2-可以发布，4-可以订阅，6-可以发布和订阅relationNameString所有关系名称，例如持有者、可订阅、可发布、可发布订阅statusInteger当前状态编号（0 服务中 1 冻结2 暂停）statusNameString当前状态别名，服务中，appkeyIntegernullcreat

32、eTimeLong创建时间updateTimeLong更新时间remarkString备注，可以不填使用示例public static void main(String args) String regionId = cn-hangzhou;String accessKey = XXXXXXXXXXXXXXXXX; String secretKey = XXXXXXXXXXXXXXXXX; String endPointName =cn-hangzhou; String productName =Ons;public static void main(String args) String r

33、egionId = cn-hangzhou;String accessKey = XXXXXXXXXXXXXXXXX; String secretKey = XXXXXXXXXXXXXXXXX; String endPointName =cn-hangzhou; String productName =Ons;String domain =;/*根据自己所在的区域选择Region后,设置对应的接入点*/ try DefaultProfile.addEndpoint(endPointName,regionId,productName,domain); catch (ClientException

34、 e) e.printStackTrace();IClientProfile profile= DefaultProfile.getProfile(regionId,accessKey,secretKey); IClientProfile profile= DefaultProfile.getProfile(regionId,accessKey,secretKey); IAcsClient iAcsClient= new DefaultAcsClient(profile);OnsTopicGetRequest request = new OnsTopicGetRequest(); reques

35、t.setAcceptFormat(FormatType.JSON); request.setTopic(MingduanTest);/*ONSRegionId是指你需要API访问ONS哪个区域的资源。*该值必须要根据OnsRegionList方法获取的列表来选择和配置，因为OnsRegionId是变动的，不能够写固定值*/ request.setOnsRegionId(daily);request.setPreventCache(System.currentTimeMillis(); try OnsTopicGetResponse response = client.getAcsRespon

36、se(request); List publishInfoDoList=response.getData(); for (OnsTopicGetResponse.PublishInfoDo publishInfoDo:publishInfoDoList)System.out.println(publishInfoDo.getId()+ + publishInfoDo.getChannelId()+ +publishInfoDo.getChannelName()+ + publishInfoDo.getOnsRegionId()+ + publishInfoDo.getRegionName()+

37、 + publishInfoDo.getTopic()+ + publishInfoDo.getOwner()+ + publishInfoDo.getRelation()+ + publishInfoDo.getRelationName()+ + publishInfoDo.getStatus()+ + publishInfoDo.getStatusName()+ + publishInfoDo.getAppkey()+ + publishInfoDo.getCreateTime()+ + publishInfoDo.getUpdateTime()+ + publishInfoDo.getR

38、emark();System.out.println(response.getRequestId();catch (ServerException e) e.printStackTrace();catch (ClientException e) e.printStackTrace();catch (Exception e) e.printStackTrace();返回结果145 0 ALIYUN daily 日常环境 MingduanTest 1344371 1 所有者 0 服务中 null 14441973850001444197385000 test 63A8024F-7763-4BBE-

39、AA56-C8E2408B358A根据输入条件搜索符合的Topic信息描述在用户指定的ONS区域，搜索符合条件的Topic信息并返回。请求参数名称类型是否必须描述OnsRegionIdString是当前查询ONS所在区域，可以通过ONSRegionList方法获取OnsPlatformString否该请求来源，默认是从POP平台PreventCacheLong是用于CSRF校验，设置为系统当前时间即可SearchString是输入的搜索条件，可以是topic或者appname等字段返回参数名称类型描述RequestIdString为公共参数，每个请求独一无二HelpUrlString帮助链接D

40、ataList(PublishInfoDo)返回所有符合条件的Topic信息列表PublishInfoDo数据结构成员类型描述idLong该发布信息在数据库中的IDchannelIdInteger该Topic所在区域ID，0- ALIYUN，1-CLOUD，2,3,4channelNameString该Topic所在区域名称，ALIYUN,CLOUD,.onsRegionIdLong该Topic所在区域ID，就是ONSRegionList方法获取的内容regionNameString该topic所在区域名称topicStringTopic名称ownerStringTopic所有者编号relat

41、ionInteger所有关系编号1-持有者，2-可以发布，4-可以订阅，6-可以发布和订阅relationNameString所有关系名称，例如持有者、可订阅、可发布、可发布订阅statusInteger当前状态编号（0 服务中 1 冻结2 暂停）statusNameString当前状态别名，服务中，appkeyIntegernullcreateTimeLong创建时间updateTimeLong更新时间remarkString备注，可以不填使用示例public static void main(String args) String regionId = cn-hangzhou;String

42、 accessKey = XXXXXXXXXXXXXXXXX; String secretKey = XXXXXXXXXXXXXXXXX; String endPointName =cn-hangzhou; String productName =Ons;public static void main(String args) String regionId = cn-hangzhou;String accessKey = XXXXXXXXXXXXXXXXX; String secretKey = XXXXXXXXXXXXXXXXX; String endPointName =cn-hangz

43、hou; String productName =Ons;String domain =;/*根据自己所在的区域选择Region后,设置对应的接入点*/ try DefaultProfile.addEndpoint(endPointName,regionId,productName,domain); catch (ClientException e) e.printStackTrace();IClientProfile profile= DefaultProfile.getProfile(regionId,accessKey,secretKey); IAcsClient iAcsClient=

44、 new DefaultAcsClient(profile);OnsTopicSearchRequestrequest=newOnsTopicSearchRequest(); request.setAcceptFormat(FormatType.JSON);/*ONSRegionId是指你需要API访问ONS哪个区域的资源。*该值必须要根据OnsRegionList方法获取的列表来选择和配置，因为OnsRegionId是变动的，不能够写固定值*/ request.setOnsRegionId(daily);request.setPreventCache(System.currentTimeMi

45、llis(); request.setSearch(JODIE_TEST_28dd);try OnsTopicSearchResponse response = client.getAcsResponse(request); List publishInfoDoList=response.getData(); for(OnsTopicSearchResponse.PublishInfoDo publishInfoDo:publishInfoDoList)System.out.println(publishInfoDo.getTopic()+ +publishInfoDo.getOwner();

46、System.out.println(response.getRequestId();System.out.println(response.getRequestId(); catch (ClientException e) e.printStackTrace();catch (Exception e) e.printStackTrace();返回结果JODIE_TEST_28dd 1344371查询指定topic的消息状态描述根据用户指定的ONS区域，查询用户所拥有的所有Topic的状态，包括当前的Topic上存在的消息数量，更新时 间等信息。请求参数名称类型是否必须描述OnsRegionI

47、dString是当前查询ONS所在区域，可以通过ONSRegionList方法获取OnsPlatformString否该请求来源，默认是从POP平台PreventCacheLong是用于CSRF校验，设置为系统当前时间即可TopicString是查询指定Topic的名字返回参数名称类型描述RequestIdString为公共参数，每个请求独一无二HelpUrlString帮助链接DataOnsTopicStatusResponse.Dat a查询到的Topic的信息存储数据结构OnsTopicStatusResponse.Data数据结构成员类型描述totalCountLong当前Topic的

48、所有分区存在的消息数总和lastTimeStampLong当前Topic的最后更新时间使用示例public static void main(String args) String regionId = cn-hangzhou;String accessKey = XXXXXXXXXXXXXXXXX; String secretKey = XXXXXXXXXXXXXXXXX; String endPointName =cn-hangzhou; String productName =Ons;public static void main(String args) String regionId

49、 = cn-hangzhou;String accessKey = XXXXXXXXXXXXXXXXX; String secretKey = XXXXXXXXXXXXXXXXX; String endPointName =cn-hangzhou; String productName =Ons;String domain =;/*根据自己所在的区域选择Region后,设置对应的接入点*/ try DefaultProfile.addEndpoint(endPointName,regionId,productName,domain); catch (ClientException e) e.p

50、rintStackTrace();IClientProfile profile= DefaultProfile.getProfile(regionId,accessKey,secretKey); IAcsClient iAcsClient= new DefaultAcsClient(profile);OnsTopicStatusRequest request = new OnsTopicStatusRequest(); request.setAcceptFormat(FormatType.JSON);/*ONSRegionId是指你需要API访问ONS哪个区域的资源。*该值必须要根据OnsRe

51、gionList方法获取的列表来选择和配置，因为OnsRegionId是变动的，不能够写固定值*/ request.setOnsRegionId(daily);request.setPreventCache(System.currentTimeMillis(); request.setTopic(JODIE_TEST_27dd);try OnsTopicStatusResponseresponse=client.getAcsResponse(request); OnsTopicStatusResponse.Datadata=response.getData();Long totalCount

52、=data.getTotalCount();Long lastTimeStamp =data.getLastTimeStamp(); System.out.println(response.getRequestId(); catch (ClientException e) e.printStackTrace();catch (Exception e) e.printStackTrace();消费管理相关接口查询消费堆积描述根据用户指定的ONS区域，查询指定Consumer的堆积情况，包含统计信息等请求参数名称类型是否必须描述OnsRegionIdString是当前查询ONS所在区域，可以通过O

53、NSRegionList方法获取OnsPlatformString否该请求来源，默认是从POP平台PreventCacheLong是用于CSRF校验，设置为系统当前时间即可ConsumerIdString是需要查询的消费端CIDDetailBoolean否是否查询详细信息，默认为否返回参数名称类型描述RequestIdString为公共参数，每个请求独一无二HelpUrlString帮助链接DataData指定consumer的消费堆积情况Data数据结构成员类型描述OnLineBoolean当前消费者是否在线TotalDiffLong当前ConsumerID订阅的所有Topic的消息总堆积数

54、ConsumeTpsFloat当前消费TPSLastTimestampLong最后更新时刻DelayTimeLong延迟时间DetailInTopicListList(OnsConsumerAccumulat eResponse.Data.DetailInTopi cDo)各个Topic具体情况DetailInTopicList数据结构成员类型描述TopicStringTopic名称TotalDiffLong当前Topic的消费堆积LastTimestampLong最后更新时刻DelayTimeLong当前topic的消费延迟时间使用示例public static void main(Stri

55、ng args) String regionId = cn-hangzhou;String accessKey = XXXXXXXXXXXXXXXXX; String secretKey = XXXXXXXXXXXXXXXXX; String endPointName =cn-hangzhou; String productName =Ons;public static void main(String args) String regionId = cn-hangzhou;String accessKey = XXXXXXXXXXXXXXXXX; String secretKey = XXX

56、XXXXXXXXXXXXXX; String endPointName =cn-hangzhou; String productName =Ons;String domain =;/*根据自己所在的区域选择Region后,设置对应的接入点*/ try DefaultProfile.addEndpoint(endPointName,regionId,productName,domain); catch (ClientException e) e.printStackTrace();IClientProfile profile= DefaultProfile.getProfile(regionId

57、,accessKey,secretKey); IAcsClient iAcsClient= new DefaultAcsClient(profile); OnsConsumerAccumulateRequestrequest=newOnsConsumerAccumulateRequest();/request.setCluster(taobaodaily);/*ONSRegionId是指你需要API访问ONS哪个区域的资源。*该值必须要根据OnsRegionList方法获取的列表来选择和配置，因为OnsRegionId是变动的，不能够写固定值*/ request.setOnsRegionId(

58、daily);request.setPreventCache(System.currentTimeMillis(); request.setAcceptFormat(FormatType.JSON); request.setDetail(true); request.setConsumerId(RTDSQ_1013_GROUP);try OnsConsumerAccumulateResponse response=iAcsClient.getAcsResponse(request); OnsConsumerAccumulateResponse.Data data =response.getDa

59、ta(); System.out.println(data.getOnline()+ +data.getTotalDiff()+ +data.getConsumeTps()+ +data.getDelayTime()+ +data.getLastTimestamp();for (OnsConsumerAccumulateResponse.Data.DetailInTopicDo detailInTopicDo:data.getDetailInTopicList() System.out.println(detailInTopicDo.getTopic()+ for (OnsConsumerAc

60、cumulateResponse.Data.DetailInTopicDo detailInTopicDo:data.getDetailInTopicList() System.out.println(detailInTopicDo.getTopic()+ +detailInTopicDo.getTotalDiff()+ +detailInTopicDo.getLastTimestamp()+ +detailInTopicDo.getDelayTime(); catch (ServerException e) e.printStackTrace(); catch (ClientExceptio