注册到Runner中
ServiceRunner
start()
get_rpc_exchange与MQ建立连接
setup()
__init___worker_poolentrypointsdependenciessubextensions
ack_message
ConsumerMixin.run:连接通讯
具体的逻辑处理,比如get_user_info
cli-run
有请求数据
SpawningProxy(self.containers)
RpcConsumer
SpawningProxy
3.创建service_runner
handle_message
1.加载config2.导入services
spawn_worker
ServiceContainer
创建Container
QueueConsumer
handle_result
线程处理_run_worker
4.start()