注释调整

README.md

@@ -11,10 +11,10 @@ from a2s_server import watch, simple_params
 def main(data: bytes, *args, **kwargs) -> bytes:
     '''
 
-    :param data: 固定格式
+    :param data: 固定格式,调用端发送的数据data
     :param args: 固定格式
     :param kwargs: 固定格式
-    :return:
+    :return: 返回调用端的 data
     '''
     # 内部处理程序
     data = data.decode("utf-8")
@@ -28,10 +28,10 @@ main()
 def main(data: bytes, *args, **kwargs) -> bytes:
     '''
 
-    :param data: 固定格式
+    :param data: 固定格式,调用端发送的数据data
     :param args: 固定格式
     :param kwargs: 固定格式
-    :return:
+    :return:返回调用端的 data
     '''
     # 内部处理程序
     data = data.decode("utf-8")
@@ -53,7 +53,9 @@ a2s_client # 简化a2s客户端调用
 from a2s_client import a2s_execute
 
 if __name__ == '__main__':
+    # bytes_data 调用端的 data 记得编码
     result = a2s_execute(a2s_ip="192.168.3.240:19094", topic="test", timeout=10, bytes_data=b"hello")
+    # result 服务端返回的 data 记得解码
     print(result.decode("utf-8"))
 
 ```

a2s_client.py

@@ -2,6 +2,7 @@
 
 import grpc
 from proto import service_pb2, service_pb2_grpc
+import logging
 
 
 def a2s_execute(a2s_ip: str, topic: str, timeout: int, bytes_data: bytes):
@@ -19,13 +20,11 @@ def a2s_execute(a2s_ip: str, topic: str, timeout: int, bytes_data: bytes):
         with grpc.insecure_channel(a2s_ip) as channel:
             # 客户端实例
             stub = service_pb2_grpc.CallerStub(channel)
-            print(topic,timeout,bytes_data)
             # 调用服务端方法
             response = stub.Call(service_pb2.Request(topic=topic, timeout=timeout, data=bytes_data))
-            print("==>",response)
             # 获取结果
             data = response.data
             return data
     except Exception as e:
-        print(e)
+        logging.warning(e)
         return None

demo/server.py

@@ -34,7 +34,3 @@ def main(data: bytes, *args, **kwargs) -> bytes:
     return data.encode("utf-8")
 
 main(nats_host="192.168.3.240",nats_port=19090,subject="test",queue="main")
-
-方式一,更简单方式启动
-方法二,灵活性更高
-推荐使用方法一