fix: Optimize some code

dubbo/cluster/monitor/cpu.py

@@ -31,7 +31,7 @@
 _cpu_invocation = RpcInvocation(
     "org.apache.dubbo.MetricsService",
     "cpu",
-    b"",
+    str(1).encode("utf-8"),
     attributes={
         common_constants.CALL_KEY: UnaryCallType,
     },
@@ -164,11 +164,13 @@ def get_service_handler() -> RpcServiceHandler:
         )
 
     @staticmethod
-    def get_cpu_usage(*args) -> bytes:
+    def get_cpu_usage(interval) -> bytes:
         """
         Get the CPU usage.
+        :param interval: The interval.
+        :type interval: bytes
         :return: The CPU usage.
         :rtype: bytes
         """
-        float_value = CpuUtils.get_total_cpu_usage()
+        float_value = CpuUtils.get_total_cpu_usage(interval=int(interval.decode("utf-8")))
         return str(float_value).encode("utf-8")

dubbo/utils.py

@@ -16,7 +16,7 @@
 
 import socket
 
-__all__ = ["EventHelper", "FutureHelper", "NetworkUtils"]
+__all__ = ["EventHelper", "FutureHelper", "NetworkUtils", "CpuUtils"]
 
 from typing import List, Tuple
 

samples/registry/zookeeper/client.py

@@ -36,7 +36,7 @@ def unary(self, request):
 
 if __name__ == "__main__":
     registry_config = RegistryConfig.from_url(
-        "zookeeper://127.0.0.1:2181?loadbalance=cpu"
+        "zookeeper://127.0.0.1:2181"
     )
     bootstrap = dubbo.Dubbo(registry_config=registry_config)
 
@@ -47,13 +47,6 @@ def unary(self, request):
 
     unary_service_stub = UnaryServiceStub(dubbo_client)
 
-    time.sleep(5)
-
     result = unary_service_stub.unary(unary_unary_pb2.Request(name="world"))
 
     print(result.message)
-
-    time.sleep(10)
-
-    result = unary_service_stub.unary(unary_unary_pb2.Request(name="world"))
-    print(result.message)

samples/registry/zookeeper/server.py

@@ -46,8 +46,4 @@ def handle_unary(request):
     # start the server
     server = bootstrap.create_server(service_config).start()
 
-    server1 = bootstrap.create_server(
-        ServiceConfig(service_handler, port=50052)
-    ).start()
-
     input("Press Enter to stop the server...\n")