diff --git a/dubbo-monitor/dubbo-monitor-api/src/main/java/com/alibaba/dubbo/monitor/MonitorService.java b/dubbo-monitor/dubbo-monitor-api/src/main/java/com/alibaba/dubbo/monitor/MonitorService.java index 7d2cd5261b4a937c57ed90a5af8e90224a2c52b9..be2b7c40013e96e4671cbe383fdd8abf5f7ee6dd 100644 --- a/dubbo-monitor/dubbo-monitor-api/src/main/java/com/alibaba/dubbo/monitor/MonitorService.java +++ b/dubbo-monitor/dubbo-monitor-api/src/main/java/com/alibaba/dubbo/monitor/MonitorService.java @@ -61,10 +61,10 @@ public interface MonitorService { String MAX_CONCURRENT = "max.concurrent"; /** - * count. + * collect. * * @param statistics */ - void count(URL statistics); + void collect(URL statistics); } \ No newline at end of file diff --git a/dubbo-monitor/dubbo-monitor-api/src/main/java/com/alibaba/dubbo/monitor/support/MonitorFilter.java b/dubbo-monitor/dubbo-monitor-api/src/main/java/com/alibaba/dubbo/monitor/support/MonitorFilter.java index 9692a9b1132c4c8455dae731212704cd6b7ad463..238d9e98ad8b27ff3ffb0727c3330f499097f965 100644 --- a/dubbo-monitor/dubbo-monitor-api/src/main/java/com/alibaba/dubbo/monitor/support/MonitorFilter.java +++ b/dubbo-monitor/dubbo-monitor-api/src/main/java/com/alibaba/dubbo/monitor/support/MonitorFilter.java @@ -100,7 +100,7 @@ public class MonitorFilter implements Filter { remoteKey = MonitorService.CONSUMER; remoteValue = context.getRemoteHost(); } - monitor.count(new URL(Constants.COUNT_PROTOCOL, + monitor.collect(new URL(Constants.COUNT_PROTOCOL, NetUtils.getLocalHost(), localPort, service + "/" + method, MonitorService.APPLICATION, application, diff --git a/dubbo-monitor/dubbo-monitor-api/src/test/java/com/alibaba/dubbo/monitor/support/MonitorFilterTest.java b/dubbo-monitor/dubbo-monitor-api/src/test/java/com/alibaba/dubbo/monitor/support/MonitorFilterTest.java index 24733071cf1f3470f81745dc0e43cd414ff7fdf2..1d0cb4c7baf3a2ed8914bc180685362818a73780 100644 --- a/dubbo-monitor/dubbo-monitor-api/src/test/java/com/alibaba/dubbo/monitor/support/MonitorFilterTest.java +++ b/dubbo-monitor/dubbo-monitor-api/src/test/java/com/alibaba/dubbo/monitor/support/MonitorFilterTest.java @@ -80,7 +80,7 @@ public class MonitorFilterTest { } public void destroy() { } - public void count(URL statistics) { + public void collect(URL statistics) { MonitorFilterTest.this.lastStatistics = statistics; } }; diff --git a/dubbo-monitor/dubbo-monitor-default/src/main/java/com/alibaba/dubbo/monitor/dubbo/DubboMonitor.java b/dubbo-monitor/dubbo-monitor-default/src/main/java/com/alibaba/dubbo/monitor/dubbo/DubboMonitor.java index 6be72b26a6669a2567862098ecc3a7fa9a7a9d76..cb0a445a28f41f749c2f7c59de38fc051ce4c06a 100644 --- a/dubbo-monitor/dubbo-monitor-default/src/main/java/com/alibaba/dubbo/monitor/dubbo/DubboMonitor.java +++ b/dubbo-monitor/dubbo-monitor-default/src/main/java/com/alibaba/dubbo/monitor/dubbo/DubboMonitor.java @@ -109,7 +109,7 @@ public class DubboMonitor implements Monitor { MonitorService.MAX_ELAPSED, String.valueOf(maxElapsed), MonitorService.MAX_CONCURRENT, String.valueOf(maxConcurrent) ); - monitorService.count(url); + monitorService.collect(url); // 减掉已统计数据 long[] current; @@ -135,7 +135,7 @@ public class DubboMonitor implements Monitor { } } - public void count(URL url) { + public void collect(URL url) { // 读写统计变量 int success = url.getParameter(MonitorService.SUCCESS, 0); int failure = url.getParameter(MonitorService.FAILURE, 0); diff --git a/dubbo-monitor/dubbo-monitor-default/src/test/java/com/alibaba/dubbo/monitor/dubbo/DubboMonitorTest.java b/dubbo-monitor/dubbo-monitor-default/src/test/java/com/alibaba/dubbo/monitor/dubbo/DubboMonitorTest.java index 8f81003aff33f360ac6f918d194d4101558195b6..cfb7a87f34b748ef12a23062b9513b07d5a55ccb 100644 --- a/dubbo-monitor/dubbo-monitor-default/src/test/java/com/alibaba/dubbo/monitor/dubbo/DubboMonitorTest.java +++ b/dubbo-monitor/dubbo-monitor-default/src/test/java/com/alibaba/dubbo/monitor/dubbo/DubboMonitorTest.java @@ -60,7 +60,7 @@ public class DubboMonitorTest { private final MonitorService monitorService = new MonitorService() { - public void count(URL statistics) { + public void collect(URL statistics) { DubboMonitorTest.this.lastStatistics = statistics; } @@ -80,7 +80,7 @@ public class DubboMonitorTest { .addParameter(MonitorService.MAX_ELAPSED, 3) .addParameter(MonitorService.CONCURRENT, 1) .addParameter(MonitorService.MAX_CONCURRENT, 1); - monitor.count(statistics); + monitor.collect(statistics); while (lastStatistics == null) { Thread.sleep(10); } @@ -123,7 +123,7 @@ public class DubboMonitorTest { try { Monitor monitor = monitorFactory.getMonitor(URL.valueOf("dubbo://127.0.0.1:17979?interval=10")); try { - monitor.count(statistics); + monitor.collect(statistics); int i = 0; while(monitorService.getStatistics() == null && i < 200) { i ++; diff --git a/dubbo-monitor/dubbo-monitor-default/src/test/java/com/alibaba/dubbo/monitor/dubbo/MockMonitorService.java b/dubbo-monitor/dubbo-monitor-default/src/test/java/com/alibaba/dubbo/monitor/dubbo/MockMonitorService.java index b705bc2e09483fa6f97d2b2101b374a497422e41..102ea5a4c8b660257bd3ef006b0e14e4c2b70073 100644 --- a/dubbo-monitor/dubbo-monitor-default/src/test/java/com/alibaba/dubbo/monitor/dubbo/MockMonitorService.java +++ b/dubbo-monitor/dubbo-monitor-default/src/test/java/com/alibaba/dubbo/monitor/dubbo/MockMonitorService.java @@ -27,7 +27,7 @@ public class MockMonitorService implements MonitorService { private URL statistics; - public void count(URL statistics) { + public void collect(URL statistics) { this.statistics = statistics; } diff --git a/dubbo-simple/dubbo-monitor-simple/src/main/java/com/alibaba/dubbo/monitor/simple/SimpleMonitorService.java b/dubbo-simple/dubbo-monitor-simple/src/main/java/com/alibaba/dubbo/monitor/simple/SimpleMonitorService.java index b68377f5d1e430bc3cca594c4158574fd309df7d..ba3d0f0639c6fe646f8ec1938829680fc6c41c59 100644 --- a/dubbo-simple/dubbo-monitor-simple/src/main/java/com/alibaba/dubbo/monitor/simple/SimpleMonitorService.java +++ b/dubbo-simple/dubbo-monitor-simple/src/main/java/com/alibaba/dubbo/monitor/simple/SimpleMonitorService.java @@ -416,6 +416,10 @@ public class SimpleMonitorService implements MonitorService { } public void count(URL statistics) { + collect(statistics); + } + + public void collect(URL statistics) { queue.offer(statistics); if (logger.isInfoEnabled()) { logger.info("collect statistics: " + statistics); diff --git a/dubbo-simple/dubbo-monitor-simple/src/test/java/com/alibaba/dubbo/monitor/simple/SimpleMonitorServiceTest.java b/dubbo-simple/dubbo-monitor-simple/src/test/java/com/alibaba/dubbo/monitor/simple/SimpleMonitorServiceTest.java index 5fdd141e20f263359758f90630f205efca6b3804..04d0c12de1e9969bd831facf44d3311176c3abb9 100644 --- a/dubbo-simple/dubbo-monitor-simple/src/test/java/com/alibaba/dubbo/monitor/simple/SimpleMonitorServiceTest.java +++ b/dubbo-simple/dubbo-monitor-simple/src/test/java/com/alibaba/dubbo/monitor/simple/SimpleMonitorServiceTest.java @@ -29,7 +29,7 @@ public class SimpleMonitorServiceTest { @Test public void testMonitor() { - new SimpleMonitorService().count(new URL("dubbo", NetUtils.getLocalHost(), 0)); + new SimpleMonitorService().collect(new URL("dubbo", NetUtils.getLocalHost(), 0)); } } \ No newline at end of file