Apache Dubbo for Python 技术文档

1. 安装指南

在开始安装前，请确保您的系统中已安装 Python 3.11 或更高版本。

从源代码安装

1. 克隆项目源代码：

   git clone https://github.com/apache/dubbo-python.git
   

2. 进入项目目录并安装：

   cd dubbo-python && pip install .
   

2. 项目使用说明

Apache Dubbo for Python 是 Apache Dubbo 的 Python 实现，支持构建微服务架构。以下是快速入门的步骤：

快速启动

1. 构建并启动服务端：

   import dubbo
   from dubbo.configs import ServiceConfig
   from dubbo.proxy.handlers import RpcMethodHandler, RpcServiceHandler
   
   
   class UnaryServiceServicer:
       def say_hello(self, message: bytes) -> bytes:
           print(f"Received message from client: {message}")
           return b"Hello from server"
   
   
   def build_service_handler():
       # 构建方法处理器
       method_handler = RpcMethodHandler.unary(
           method=UnaryServiceServicer().say_hello, method_name="unary"
       )
       # 构建服务处理器
       service_handler = RpcServiceHandler(
           service_name="org.apache.dubbo.samples.HelloWorld",
           method_handlers=[method_handler],
       )
       return service_handler
   
   
   if __name__ == "__main__":
       # 构建服务配置
       service_handler = build_service_handler()
       service_config = ServiceConfig(
           service_handler=service_handler, host="127.0.0.1", port=50051
       )
       # 启动服务端
       server = dubbo.Server(service_config).start()
   
       input("Press Enter to stop the server...\n")
   

2. 构建并启动客户端：

   import dubbo
   from dubbo.configs import ReferenceConfig
   
   
   class UnaryServiceStub:
       def __init__(self, client: dubbo.Client):
           self.unary = client.unary(method_name="unary")
   
       def say_hello(self, message: bytes) -> bytes:
           return self.unary(message)
   
   
   if __name__ == "__main__":
       # 创建客户端
       reference_config = ReferenceConfig.from_url(
           "tri://127.0.0.1:50051/org.apache.dubbo.samples.HelloWorld"
       )
       dubbo_client = dubbo.Client(reference_config)
       unary_service_stub = UnaryServiceStub(dubbo_client)
   
       # 调用远程方法
       result = unary_service_stub.say_hello(b"Hello from client")
       print(result)
   

3. 项目 API 使用文档

Apache Dubbo for Python 提供了以下 API：

RpcMethodHandler

• unary(method, method_name): 创建一个处理单次请求的方法处理器。

RpcServiceHandler

• 构造函数：创建一个服务处理器。

  • service_name: 服务名。
  • method_handlers: 方法处理器的列表。

ServiceConfig

• 构造函数：配置服务。

  • service_handler: 服务处理器。
  • host: 服务地址。
  • port: 服务端口。

ReferenceConfig

• from_url(url): 从 URL 创建一个服务引用配置。

dubbo.Client

• 构造函数：创建一个客户端。

UnaryServiceStub

• say_hello(message): 调用远程服务的方法。

4. 项目安装方式

请参考“安装指南”部分的内容进行项目安装。