anthunder(a.k.a. sofa-bolt-python)

See English README

anthunder是一个python实现的BOLT协议库，提供BOLT client和server功能，支持使用BOLT + Protobuf方式的RPC调用。

requirements

• python3 >= 3.5 (aio classes needs asyncio support)
• mosn >= 1.3 (to use with version >= 0.6)
• mosn < 1.3 (to use with version < 0.6)

roadmap

• 支持Bolt+pb调用服务端（client端）
• 支持通过servicemesh的服务发现与服务发布
• 支持使用Bolt+pb提供服务（server端）
• 支持其它序列化协议

Tutorial

以下示例以使用protobuf序列化为例。其它序列化协议请参考demo。

做为调用方

0. 获取服务方提供的 .proto 文件
1. 执行protoc --python_out=. *.proto命令，编译protobuf文件获得_pb2.py文件
2. 导入pb类并调用接口

fromSampleServicePbResult_pb2importSampleServicePbResultfromSampleServicePbRequest_pb2importSampleServicePbRequestfromanthunderimportAioClientfromanthunder.discovery.mosnimportMosnClient, ApplicationInfospanctx=ctx# ctx is transfered from upstream rpc, which is an object of mytracer.SpanContext, stores rpc_trace_context# spanctx = SpanContext() # or generate a new contextservice_reg=MosnClient() # using mosn for service discovery, see https://mosn.io for detailservice_reg.startup(ApplicationInfo(YOUR_APP_NAME))
# service_reg = LocalRegistry({interface: (inf_ip, inf_port)}) # or a service-address dict as service discovery# 订阅服务, subscribe before client's requestsservice_reg.subscribe(interface)
client=AioClient(YOUR_APP_NAME, service_register=service_reg) # will create a thread, and send heartbeat to remote every 30sinterface='com.alipay.rpc.common.service.facade.pb.SampleServicePb:1.0'# 同步调用content=client.invoke_sync(interface, "hello",
SampleServicePbRequest(name=some_name).SerializeToString(),
timeout_ms=500, spanctx=spanctx)
result=SampleServicePbResult()
result.ParseFromString(content)
# 异步调用defclient_callback(resp):
# callback function, accepts bytes as the only argument,# then do deserialize and further processesresult=SampleServicePbResult()
result.ParseFromString(content)
# do somethingfuture=client.invoke_async(interface, "hello", SampleServicePbRequest(name=some_name).SerializeToString(),
spanctx=spanctx, callback=client_callback)
)

参考unittest

做为服务方

fromanthunderimportAioListenerfromanthunder.discovery.mosnimportMosnClient, ApplicationInfoclassSampleService(object):
def__init__(self, ctx):
# service must accept one param as spanctx for rpc tracing supportself.ctx=ctxdefhello(self, bs: bytes):
obj=SampleServicePbRequest()
obj.ParseFromString(bs)
print("Processing Request", obj)
returnSampleServicePbResult(result=obj.name).SerializeToString()
interface='com.alipay.rpc.common.service.facade.pb.SampleServicePb:1.0'service_reg=MosnClient() # using mosn for service discovery, see https://mosn.io for detailservice_reg.startup(ApplicationInfo(YOUR_APP_NAME))
listener=AioListener(('127.0.0.1', 12199), YOUR_APP_NAME, service_register=service_reg)
# register interface and its function, plus its protobuf definition classlistener.register_interface(interface, service_cls=SampleService, provider_meta=ProviderMetaInfo(appName="test_app"))
# start server in a standalone threadlistener.run_threading()
# or start in current threadlistener.run_forever()
# publish interfaces, MUST after listener start.listener.publish()
# shutdown the serverlistener.shutdown()

License

Copyright (c) 2018-present, Ant Financial Service Group

Apache License 2.0

See LICENSE file.

Thirdparty

Part of the mysockpool package uses codes from urllib3 project under the term of MIT License. See origin-license.txt under the mysockpool package.