消费端中文乱码

详细解答可以参考官方帮助文档

OnsConsumerConnection 接口用于查询指定Consumer ID(CID)下当前客户端的连接情况。

使用场景

一般用于判断指定 CID 的消费者是否在线，并获取详细的客户端连接的列表。

请求参数列表

返回参数列表

ConnectionDo 数据结构

相关 API

• OnsConsumerStatus：消费者状态查询
• OnsConsumerAccumulate：消费堆积查询

使用示例

    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 ="ons.cn-hangzhou.aliyuncs.com";

            /**
            *根据自己需要访问的区域选择 Region，并设置对应的接入点
            */
            try {
                DefaultProfile.addEndpoint(endPointName，regionId，productName，domain);
            } catch (ClientException e) {
                e.printStackTrace();
            }
            IClientProfile profile= DefaultProfile.getProfile(regionId，accessKey，secretKey);
            IAcsClient iAcsClient= new DefaultAcsClient(profile);
            OnsConsumerGetConnectionRequest request = new OnsConsumerGetConnectionRequest();
            /**
            *ONSRegionId 是指你需要 API 访问 MQ 哪个区域的资源.
            *该值必须要根据 OnsRegionList 方法获取的列表来选择和配置，因为 OnsRegionId 是变动的，不能够写固定值
            */
            request.setOnsRegionId("daily");
            request.setPreventCache(System.currentTimeMillis());
            request.setAcceptFormat(FormatType.JSON);
            request.setConsumerId("RTDSQ_1013_GROUP");
            try {
                OnsConsumerGetConnectionResponse response=iAcsClient.getAcsResponse(request);
                List<OnsConsumerGetConnectionResponse.Data.ConnectionDo> connectionDoList=response.getData().getConnectionList();
                for(OnsConsumerGetConnectionResponse.Data.ConnectionDo connectionDo:connectionDoList){
                    System.out.println(connectionDo.getClientId()+"  "+
                    connectionDo.getClientAddr()+"  "+
                    connectionDo.getLanguage()+"  "+
                    connectionDo.getVersion());
                }
            } catch (ServerException e) {
                e.printStackTrace();
            } catch (ClientException e) {
                e.printStackTrace();
            }
        }