|
@@ -15,14 +15,8 @@ class JSONRPCServer:
|
|
|
self.server.register_function(self.service.sumation, 'sum')
|
|
|
self.server.register_function(self.service.sumation, 'notify_sum')
|
|
|
self.server.register_function(self.service.sumation, 'namespace.sum')
|
|
|
-
|
|
|
-
|
|
|
- self.thread = threading.Thread(self.server.serve_forever)
|
|
|
- self.thread.daemon = True
|
|
|
- self.thread.stop = self.stop
|
|
|
+ self.thread = threading.Thread(target=self.server.serve_forever)
|
|
|
self.thread.start()
|
|
|
-
|
|
|
-
|
|
|
|
|
|
def _wait_for_rpc_start(self):
|
|
|
rpc = jsonrpclib.Server("http://{0}:{1}".format(SERVER_ADDR[0], SERVER_ADDR[1]))
|
|
@@ -42,9 +36,28 @@ class JSONRPCServer:
|
|
|
|
|
|
class JSONRPCClient:
|
|
|
|
|
|
- def __init__(self) -> None:
|
|
|
- self.client = jsonrpclib.Server("http://{0}:{1}".format(SERVER_ADDR[0], SERVER_ADDR[1]))
|
|
|
+ def __init__(self):
|
|
|
+
|
|
|
+
|
|
|
+ self.client = jsonrpclib.Server("http://{0}:{1}".format("192.168.31.226", 888))
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+ def test(self):
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
|
|
|
+
|
|
|
+ self.client.get_opc_config()
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
|
|
|
class ExampleService:
|
|
|
|
|
@@ -66,11 +79,12 @@ class ExampleService:
|
|
|
|
|
|
class ExampleAggregateService(ExampleService):
|
|
|
|
|
|
- def __init__(self) -> None:
|
|
|
+ def __init__(self):
|
|
|
self.sub_service = ExampleService()
|
|
|
|
|
|
|
|
|
|
|
|
-server = JSONRPCServer()
|
|
|
+
|
|
|
client = JSONRPCClient()
|
|
|
-print(client.ping())
|
|
|
+client.test()
|
|
|
+
|