in dubbo/client.py [0:0]
def __init__(self, hosts, application_name='search_platform'):
"""
:param hosts: Zookeeper的地址
:param application_name: 当前客户端的名称
"""
zk = KazooClient(hosts=hosts)
# 对zookeeper连接状态的监控
zk.add_listener(self.state_listener)
zk.start()
self.zk = zk
self.hosts = {}
self.weights = {}
self.application_name = application_name
self.lock = threading.Lock()