kademlia.py 文件源码

def __init__(self, *args):
        self.ip = args[0]
        self.port = args[1]

        application = service.Application("kademlia")
        application.setComponent(ILogObserver, log.FileLogObserver(sys.stdout, log.INFO).emit)

        if os.path.isfile('cache.pickle'):
            kserver = Server.loadState('cache.pickle')
        else:
            kserver = Server()
            kserver.bootstrap([(self.ip, self.port)])
        kserver.saveStateRegularly('cache.pickle', 10)

        server = internet.UDPServer(self.port, kserver.protocol)
        server.setServiceParent(application)

        self.log = logging.getLogger(resource_filename(__name__, __file__))