OnsConsumerStatus

使用本接口时，请注意以下几点：

• 本接口一般用于在粗略判断消费堆积以及客户端在线情况后，需要排查消费异常的原因时调用，可以判断出指定 Group ID 的订阅关系是否一致、负载均衡是否正常以及获取在线客户端的 Jstack 信息等。
• 本接口需要调用后端大量接口完成数据聚合，因此查询速度慢，不建议频繁调用。

请求参数

返回数据

示例

请求示例

http(s)://[Endpoint]/?Action=OnsConsumerStatus
&GroupId=GID_test_group_id
&InstanceId=MQ_INST_111111111111_DOxxxxxx
&NeedJstack=true
&Detail=true
&<公共请求参数>

正常返回示例

XML 格式

<data>
    <connectionSet>
        <bizVersion>V4_3_6</bizVersion>
        <clientAddr>30.5.***.*</clientAddr>
        <clientId>30.5.***.*@97730#-1999745829#-1737591554#729272961762836</clientId>
        <language>JAVA</language>
        <version>V4_3_6</version>
    </connectionSet>
    <consumeModel>CLUSTERING</consumeModel>
    <consumeTps>0</consumeTps>
    <consumerConnectionInfoList>
        <bizVersion>V4_3_6</bizVersion>
        <clientId>30.5.***.*@97730#-1999745829#-1737591554#729272961762836</clientId>
        <consumeType>PUSH</consumeType>
        <jstack>
            <thread>ConsumeMessageThread_4</thread>
            <trackList>TID: 44 STATE: WAITING</trackList>
            <trackList>sun.misc.Unsafe.park(Native Method)</trackList>
            <trackList>java.util.concurrent.locks.LockSupport.park(LockSupport.java:175)</trackList>
            <trackList>java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2039)</trackList>
            <trackList>java.util.concurrent.LinkedBlockingQueue.take(LinkedBlockingQueue.java:442)</trackList>
            <trackList>java.util.concurrent.ThreadPoolExecutor.getTask(ThreadPoolExecutor.java:1074)</trackList>
            <trackList>java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1134)</trackList>
            <trackList>java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)</trackList>
            <trackList>java.lang.Thread.run(Thread.java:748)</trackList>
        </jstack>
        <language>JAVA</language>
        <lastTimeStamp>1570701368114</lastTimeStamp>
        <runningDataList>
            <failedCountPerHour>0</failedCountPerHour>
            <failedTps>0</failedTps>
            <okTps>0</okTps>
            <rt>0</rt>
            <topic>test-mq_topic</topic>
        </runningDataList>
        <startTimeStamp>1570701361528</startTimeStamp>
        <subscriptionSet>
            <subString>*</subString>
            <subVersion>1570701364301</subVersion>
            <topic>test-mq_topic</topic>
        </subscriptionSet>
        <threadCount>20</threadCount>
        <version>V4_3_6</version>
    </consumerConnectionInfoList>
    <delayTime>0</delayTime>
    <detailInTopicList>
        <delayTime>0</delayTime>
        <lastTimestamp>1570701259403</lastTimestamp>
        <topic>test-mq_topic</topic>
        <totalDiff>0</totalDiff>
    </detailInTopicList>
    <instanceId>MQ_INST_111111111111_DOxxxxxx</instanceId>
    <lastTimestamp>1570701368114</lastTimestamp>
    <online>true</online>
    <rebalanceOK>true</rebalanceOK>
    <subscriptionSame>true</subscriptionSame>
    <totalDiff>0</totalDiff>
</data>
<requestId>10EDC518-10E7-4B34-92FB-171235FA6E38</requestId>

JSON 格式

{
	"requestId":"10EDC518-10E7-4B34-92FB-171235FA6E38",
	"data":{
		"totalDiff":0,
		"delayTime":0,
		"consumeTps":0,
		"subscriptionSame":true,
		"consumerConnectionInfoList":[
			{
				"startTimeStamp":1570701361528,
				"consumeType":"PUSH",
				"threadCount":20,
				"lastTimeStamp":1570701368114,
				"bizVersion":"V4_3_6",
				"subscriptionSet":[
					{
						"topic":"test-mq_topic",
						"subVersion":1570701364301,
						"tagsSet":[],
						"subString":"*"
					}
				],
				"language":"JAVA",
				"runningDataList":[
					{
						"topic":"test-mq_topic",
						"failedTps":0,
						"failedCountPerHour":0,
						"rt":0,
						"okTps":0
					}
				],
				"clientId":"30.5.***.*@97730#-1999745829#-1737591554#729272961762836",
				"version":"V4_3_6",
				"jstack":[
					{
						"thread":"ConsumeMessageThread_1",
						"trackList":[
							"TID: 44 STATE: WAITING",
							"sun.misc.Unsafe.park(Native Method)",
							"java.util.concurrent.locks.LockSupport.park(LockSupport.java:175)",
							"java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2039)",
							"java.util.concurrent.LinkedBlockingQueue.take(LinkedBlockingQueue.java:442)",
							"java.util.concurrent.ThreadPoolExecutor.getTask(ThreadPoolExecutor.java:1074)",
							"java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1134)",
							"java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)",
							"java.lang.Thread.run(Thread.java:748)"
						]
					}
				]
			}
		],
		"instanceId":"MQ_INST_111111111111_DOxxxxxx",
		"detailInTopicList":[
			{
				"topic":"test-mq_topic",
				"totalDiff":0,
				"delayTime":0,
				"lastTimestamp":1570701259403
			}
		],
		"rebalanceOK":true,
		"consumeModel":"CLUSTERING",
		"lastTimestamp":1570701368114,
		"connectionSet":[
			{
				"bizVersion":"V4_3_6",
				"language":"JAVA",
				"clientAddr":"30.5.***.*",
				"clientId":"30.5.***.*@97730#-1999745829#-1737591554#729272961762836",
				"version":"V4_3_6"
			}
		],
		"online":true
	}
}

错误码

访问错误中心查看更多错误码。