Display indicator data in KEY, VALUE format

dubbo-config/dubbo-config-api/src/main/java/org/apache/dubbo/config/deploy/DefaultApplicationDeployer.java

@@ -372,20 +372,6 @@ private void initMetricsReporter() {
             applicationModel.getBeanFactory().getBean(DefaultMetricsCollector.class);
         Optional<MetricsConfig> configOptional = configManager.getMetrics();
 
-        // TODO compatible with old usage of metrics, remove protocol check after new metrics is ready for use.
-        boolean importMetricsPrometheus;  // Use package references instead of config checks
-        try {
-            Class.forName("io.micrometer.prometheus.PrometheusConfig");
-            importMetricsPrometheus = true;
-        } catch (ClassNotFoundException e) {
-            importMetricsPrometheus = false;
-        }
-
-        if (!importMetricsPrometheus) {
-            //use old metrics
-            return;
-        }
-
         MetricsConfig metricsConfig = configOptional.orElse(new MetricsConfig(applicationModel));
         if (StringUtils.isBlank(metricsConfig.getProtocol())) {
             metricsConfig.setProtocol(PROTOCOL_PROMETHEUS);

dubbo-metrics/dubbo-metrics-api/src/main/java/org/apache/dubbo/metrics/report/MetricsReporter.java

@@ -31,4 +31,8 @@ public interface MetricsReporter {
     void refreshData();
 
     String getResponse();
+
+    default String getResponseWithName(String metricsName) {
+        return null;
+    }
 }

dubbo-metrics/dubbo-metrics-default/pom.xml

@@ -46,5 +46,11 @@
             <artifactId>micrometer-tracing-integration-test</artifactId>
             <scope>test</scope>
         </dependency>
+        <dependency>
+            <groupId>org.apache.dubbo</groupId>
+            <artifactId>dubbo-qos-api</artifactId>
+            <version>${project.parent.version}</version>
+            <scope>compile</scope>
+        </dependency>
     </dependencies>
 </project>

dubbo-metrics/dubbo-metrics-default/src/main/java/org/apache/dubbo/metrics/report/DefaultMetricsReporter.java

@@ -0,0 +1,92 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements.  See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License.  You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package org.apache.dubbo.metrics.report;
+
+import io.micrometer.core.instrument.Counter;
+import io.micrometer.core.instrument.Gauge;
+import io.micrometer.core.instrument.Timer;
+import io.micrometer.core.instrument.simple.SimpleMeterRegistry;
+
+import org.apache.dubbo.common.URL;
+import org.apache.dubbo.rpc.model.ApplicationModel;
+
+import java.util.HashMap;
+import java.util.Map;
+
+import java.util.concurrent.TimeUnit;
+
+public class DefaultMetricsReporter extends AbstractMetricsReporter {
+
+    SimpleMeterRegistry meterRegistry = new SimpleMeterRegistry();
+
+    protected DefaultMetricsReporter(URL url, ApplicationModel applicationModel) {
+        super(url, applicationModel);
+    }
+
+    @Override
+    public String getResponse() {
+        return null;
+    }
+
+    @Override
+    public String getResponseWithName(String metricsName) {
+        //name->tags->value
+        Map<String, Map<String, Object>> result = new HashMap<>();
+        StringBuilder sb = new StringBuilder();
+        meterRegistry.getMeters().stream().filter(meter -> {
+            if (metricsName != null) {
+                return meter.getId().getName().contains(metricsName);
+            }
+            return true;
+        }).forEach(meter -> {
+            result.putIfAbsent(meter.getId().getName(), new HashMap<>());
+            Object value = null;
+            if (meter instanceof Counter) {
+                Counter counter = (Counter) meter;
+                value = counter.count();
+            }
+            if (meter instanceof Gauge) {
+                Gauge gauge = (Gauge) meter;
+                value = gauge.value();
+            }
+            if (meter instanceof Timer) {
+                Timer timer = (Timer) meter;
+                value = timer.totalTime(TimeUnit.MILLISECONDS);
+            }
+            result.get(meter.getId().getName()).put(meter.getId().getTags().toString(), value);
+        });
+        result.forEach((name, tags) -> {
+            sb.append("##metrics name=").append(name).append(System.lineSeparator());
+            tags.forEach((tag, value) -> {
+                sb.append(" #tags:").append(tag).append(System.lineSeparator()).append(" #value：").append(value)
+                    .append(System.lineSeparator());
+            });
+        });
+        return sb.toString();
+    }
+
+    @Override
+    protected void doInit() {
+        addMeterRegistry(meterRegistry);
+    }
+
+    @Override
+    protected void doDestroy() {
+
+    }
+}

dubbo-metrics/dubbo-metrics-default/src/main/java/org/apache/dubbo/metrics/report/DefaultMetricsReporterCmd.java

@@ -0,0 +1,119 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements.  See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License.  You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package org.apache.dubbo.metrics.report;
+
+import org.apache.dubbo.common.utils.JsonUtils;
+import org.apache.dubbo.qos.api.BaseCommand;
+import org.apache.dubbo.qos.api.Cmd;
+import org.apache.dubbo.qos.api.CommandContext;
+import org.apache.dubbo.rpc.model.ApplicationModel;
+import org.apache.dubbo.rpc.model.FrameworkModel;
+
+import java.io.CharArrayReader;
+import java.io.IOException;
+import java.io.LineNumberReader;
+import java.util.HashMap;
+import java.util.List;
+import java.util.Map;
+import java.util.Optional;
+
+@Cmd(name = "metrics_default", summary = "reuse qos report")
+public class DefaultMetricsReporterCmd implements BaseCommand {
+
+    public FrameworkModel frameworkModel;
+
+    public DefaultMetricsReporterCmd(FrameworkModel frameworkModel) {
+        this.frameworkModel = frameworkModel;
+    }
+
+    @Override
+    public String execute(CommandContext commandContext, String[] args) {
+        List<ApplicationModel> models = frameworkModel.getApplicationModels();
+        String result = "There is no application with data";
+        if (notSpecifyApplication(args)) {
+            result = useFirst(models, result, null);
+        } else if (args.length == 1) {
+            result = specifyApplication(args[0], models, null);
+        } else if (args.length == 2) {
+            result = specifyApplication(args[0], models, args[1]);
+        }
+        return result;
+    }
+
+    private boolean notSpecifyApplication(String[] args) {
+        return args == null || args.length == 0;
+    }
+
+    private String useFirst(List<ApplicationModel> models, String result, String metricsName) {
+        for (ApplicationModel model : models) {
+            String current = getResponseByApplication(model, metricsName);
+            if (getLineNumber(current) > 0) {
+                result = current;
+                break;
+            }
+        }
+        return result;
+    }
+
+    private String specifyApplication(String appName, List<ApplicationModel> models, String metricsName) {
+        if ("application_all".equals(appName)) {
+            return allApplication(models);
+        } else {
+            return specifySingleApplication(appName, models, metricsName);
+        }
+    }
+
+    private String specifySingleApplication(String appName, List<ApplicationModel> models, String metricsName) {
+        Optional<ApplicationModel> modelOptional = models.stream()
+            .filter(applicationModel -> appName.equals(applicationModel.getApplicationName())).findFirst();
+        if (modelOptional.isPresent()) {
+            return getResponseByApplication(modelOptional.get(), metricsName);
+        } else {
+            return "Not exist application: " + appName;
+        }
+    }
+
+    private String allApplication(List<ApplicationModel> models) {
+        Map<String, String> appResultMap = new HashMap<>();
+        for (ApplicationModel model : models) {
+            appResultMap.put(model.getApplicationName(), getResponseByApplication(model, null));
+        }
+        return JsonUtils.toJson(appResultMap);
+    }
+
+    private String getResponseByApplication(ApplicationModel applicationModel, String metricsName) {
+        String response = "MetricsReporter not init";
+        MetricsReporter metricsReporter = applicationModel.getBeanFactory().getBean(MetricsReporter.class);
+        if (metricsReporter != null) {
+            metricsReporter.refreshData();
+            response = metricsReporter.getResponseWithName(metricsName);
+        }
+        return response;
+    }
+
+
+    private static long getLineNumber(String content) {
+        LineNumberReader lnr = new LineNumberReader(new CharArrayReader(content.toCharArray()));
+        try {
+            lnr.skip(Long.MAX_VALUE);
+            lnr.close();
+        } catch (IOException ignore) {
+        }
+        return lnr.getLineNumber();
+    }
+}

dubbo-metrics/dubbo-metrics-default/src/main/java/org/apache/dubbo/metrics/report/DefaultMetricsReporterFactory.java

@@ -0,0 +1,35 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements.  See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License.  You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package org.apache.dubbo.metrics.report;
+
+import org.apache.dubbo.common.URL;
+import org.apache.dubbo.rpc.model.ApplicationModel;
+
+public class DefaultMetricsReporterFactory extends AbstractMetricsReporterFactory {
+    private final ApplicationModel applicationModel;
+
+    public DefaultMetricsReporterFactory(ApplicationModel applicationModel) {
+        super(applicationModel);
+        this.applicationModel = applicationModel;
+    }
+
+    @Override
+    public MetricsReporter createMetricsReporter(URL url) {
+        return new DefaultMetricsReporter(url, applicationModel);
+    }
+}

dubbo-metrics/dubbo-metrics-default/src/main/resources/META-INF/dubbo/internal/org.apache.dubbo.metrics.report.MetricsReporterFactory

@@ -0,0 +1 @@
+default=org.apache.dubbo.metrics.report.DefaultMetricsReporterFactory

dubbo-metrics/dubbo-metrics-default/src/main/resources/META-INF/dubbo/internal/org.apache.dubbo.qos.api.BaseCommand

@@ -0,0 +1 @@
+metrics_default=org.apache.dubbo.metrics.report.DefaultMetricsReporterCmd