rpc_interface.py 文件源码

def setup_server():
    config = yaml.load(open('./config/config.yml', 'r'))
    server_port = 8080
    if 'rpc' in config:
        server_port = config['rpc']['server_port']

    site = server.Site(RPCInterface())
    endpoint = endpoints.TCP4ServerEndpoint(reactor, server_port)
    endpoint.listen(site)