區(qū)塊鏈技術(shù)與應(yīng)用 第四章：P2P 網(wǎng)絡(luò)（上）

2233445566者其他下載者(包括發(fā)布者)的IP778899importargparseimportjsonimportimportargparseimportjsonimportloggingimportpicklefromredisliteimportRedisfromtornadoimportwebsocket,web,ioloopfromwrenchbox.loggingimportsetup_logclients=[]/3/library/argparse.parser=argparse.ArgumentParser()'--debug',action='store_true',aultFalsehelpshowdebuginformation)...'-p','--port',type=int,default=DEFAULTS['port'],help='listeningport,default:{}'.format(DEFAULTS['port']))...'-r','--redis',type=str,default='redis.db',help='redisdatabasefile,default:redis.db')rgsprint(args)importargparseimportjsonimportloggingimportpicklefromredisliteimportRedisfromtornadoimportwebsocket,web,ioloopfromwrenchbox.loggingimportsetup_logclients=[]/3/library/pickle.importargparseimportjsonimportloggingimportpicklefromredisliteimportRedisfromtornadoimportwebsocket,web,ioloopfromwrenchbox.loggingimportsetup_logclients=[]可選持久性(Durability)的鍵值對存儲數(shù)據(jù)庫...setup_log(level=logging.DEBUGifargs.debugelselogging.INFO)db=Redis(args.redis)ifb'peers'notindb.keys():db.set('peers',pickle.dumps(set([])))importargparseimportjsonimportloggingimportpicklefromredisliteimportRedisfromtornadoimportwebsocket,web,ioloopfromwrenchbox.loggingimportsetup_logclients=[]...web.Application([(r'/',IndexHandler),(r'/ws',SocketHandler)]).listen(args.port)('Tornadoislisteningonport:%d',args.port)ioloop.IOLoop.instance().start()classIndexHandler(web.RequestHandler):defget(self):self.render("index.html")<divclass="container"></div>classSocketHandlerwebsocket.WebSocketHandler):defcheck_origin(self,origin):returnTruedefopen(self):('Clientconnected:%s',self.request.remote_ip)ifselfnotinclients:clients.append(self)defon_close(self):ifselfinclients:clients.remove(self)else:...else:...defon_message(self,message):try:sageself.write_message(json.dumps({'status':500,}))vifmessageisnotNone:if'op'inmessage:ifmessage['op']=='register':if'args'inmessageand'addr'inmessage['args']:...else:...elifmessage['op']=='peers':...else:...else:...if'args'inmessageand'addr'inmessage['args']:peers=pickle.loads(db.get('peers'))ifnotisinstance(message['args']['addr'],list):message['args']['addr']=[str(message['args']['addr'])]foraddrinmessage['args']['addr']:ifaddr.startswith('ws://')oraddr.startswith('wss://'):peers.add(addr)db.set('peers',pickle.dumps(peers))self.write_message(json.dumps({'status':202,'error':'Accepted'}))if'args'inmessageand'addr'inmessage['args']:...else:self.write_message(json.dumps({'status':500,'error':'Operation"register"requiresthefollowing"args":"addr"',}))elifmessage['op']=='peers':self.write_message(json.dumps({'status':200,'error':'OK','response':{'peers':list(pickle.loads(db.get('peers')))}}))else:self.write_message(json.dumps({'status':404,'error':'Operation"{}"isnotsupported.'.format(message['op']),}))else:self.write_message(json.dumps({'status':500,}))