(dubbo-integration-cases) branch main updated: Configure enable metrics collect (#38)

[albumenj]

This is an automated email from the ASF dual-hosted git repository.

albumenj pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/dubbo-integration-cases.git


The following commit(s) were added to refs/heads/main by this push:
     new a9801275 Configure enable metrics collect (#38)
a9801275 is described below

commit a98012753a1ddd869d315605cc47dc3e6abdd7e1
Author: Albumen Kevin <jhq0...@gmail.com>
AuthorDate: Thu Aug 29 19:01:53 2024 +0800

    Configure enable metrics collect (#38)
---
 .../dubbo/samples/client/GreetingServiceIT.java    | 22 +++++++++++++++-------
 1 file changed, 15 insertions(+), 7 deletions(-)

diff --git 
a/99-integration/dubbo-samples-test-13580/src/test/java/org/apache/dubbo/samples/client/GreetingServiceIT.java
 
b/99-integration/dubbo-samples-test-13580/src/test/java/org/apache/dubbo/samples/client/GreetingServiceIT.java
index 596b5499..bbc106e6 100644
--- 
a/99-integration/dubbo-samples-test-13580/src/test/java/org/apache/dubbo/samples/client/GreetingServiceIT.java
+++ 
b/99-integration/dubbo-samples-test-13580/src/test/java/org/apache/dubbo/samples/client/GreetingServiceIT.java
@@ -17,17 +17,17 @@
 
 package org.apache.dubbo.samples.client;
 
-import org.apache.dubbo.common.utils.PojoUtils;
 import org.apache.dubbo.config.ApplicationConfig;
+import org.apache.dubbo.config.MetricsConfig;
 import org.apache.dubbo.config.ReferenceConfig;
 import org.apache.dubbo.config.RegistryConfig;
+import org.apache.dubbo.config.bootstrap.DubboBootstrap;
 import org.apache.dubbo.metrics.collector.CombMetricsCollector;
 import org.apache.dubbo.metrics.collector.DefaultMetricsCollector;
 import org.apache.dubbo.metrics.data.BaseStatComposite;
 import org.apache.dubbo.metrics.data.RtStatComposite;
 import org.apache.dubbo.metrics.model.container.LongContainer;
 import org.apache.dubbo.rpc.model.FrameworkModel;
-import org.apache.dubbo.rpc.service.GenericService;
 import org.apache.dubbo.samples.api.GreetingsService;
 
 import cn.hutool.http.HttpUtil;
@@ -47,12 +47,21 @@ public class GreetingServiceIT {
 
     @Test
     public void test1() throws NoSuchMethodException, 
InvocationTargetException, IllegalAccessException, NoSuchFieldException {
-        ReferenceConfig<GreetingsService> referenceConfig = new 
ReferenceConfig<>();
         ApplicationConfig applicationConfig = new 
ApplicationConfig("first-dubbo-consumer");
         applicationConfig.setQosPort(22333);
-        referenceConfig.setApplication(applicationConfig);
-        referenceConfig.setRegistry(new RegistryConfig("zookeeper://" + 
zookeeperHost + ":2181"));
+        ReferenceConfig<GreetingsService> referenceConfig = new 
ReferenceConfig<>();
         referenceConfig.setInterface(GreetingsService.class);
+
+        MetricsConfig metricsConfig = new MetricsConfig();
+        metricsConfig.setEnableRpc(true);
+
+        DubboBootstrap.getInstance()
+                .application(applicationConfig)
+                .metrics(metricsConfig)
+                .registry(new RegistryConfig("zookeeper://" + zookeeperHost + 
":2181"))
+                .reference(referenceConfig)
+                .start();
+
         GreetingsService greetingsService = referenceConfig.get();
 
         String message = greetingsService.echo1("hello");
@@ -91,7 +100,7 @@ public class GreetingServiceIT {
         List<LongContainer<? extends Number>> longContainers = 
rtStats.get("consumer");
         LongContainer<? extends Number> longContainer = longContainers.get(4);
         for (Number value : longContainer.values()) {
-            ((AtomicLong)value).set(0);
+            ((AtomicLong) value).set(0);
         }
 
         for (int i = 0; i < 10; i++) {
@@ -111,7 +120,6 @@ public class GreetingServiceIT {
             Assertions.assertEquals(0, Double.parseDouble(data.get("echo2")));
         }
 
-
         FrameworkModel.destroyAll();
     }