最近研究了dht网络，使用python写了个爬虫程序，另外用php做了个搜索网站，今天又把sphinx加上了，这样就是一个简单的bt种子搜索引擎了哈，网址：
H5小游戏网站：
另外也弄了一个微信公众号，不时发布一些热门影视剧：
微信公众号：tutuyouya
下面这个是加入共享网络，并获取种子hash码的Python:
#encoding: utf-8import socketfrom hashlib import sha1from random import randintfrom struct import unpack, packfrom socket import inet_aton, inet_ntoafrom bisect import bisect_leftfrom threading import Timerfrom time import sleepimport MySQLdbfrom bencode import bencode, bdecodeBOOTSTRAP_NODES = [("", 6881),("", 6881),("", 6881)] TID_LENGTH = 8KRPC_TIMEOUT = 10REBORN_TIME = 5 * 60K = 8def entropy(bytes):s = ""for i in range(bytes):s += chr(randint(0, 255))return sdef random_id():hash = sha1()hash.update( entropy(20) )return hash.digest()def decode_nodes(nodes):n = []length = len(nodes)if (length % 26) != 0: return nfor i in range(0, length, 26):nid = nodes[i:i+20]ip = inet_ntoa(nodes[i+20:i+24])port = unpack("!H", nodes[i+24:i+26])[0]n.append( (nid, ip, port) )return ndef encode_nodes(nodes):strings = []for node in nodes:s = "%s%s%s" % (node.nid, inet_aton(node.ip), pack("!H", node.port))strings.append(s)return "".join(strings)def intify(hstr):return long(hstr.encode('hex'), 16) def timer(t, f):Timer(t, f).start()class BucketFull(Exception):passclass KRPC(object):def __init__(self):self.types = {"r": self.response_received,"q": self.query_received}self.actions = {"ping": self.ping_received,"find_node": self.find_node_received,"get_peers": self.get_peers_received,"announce_peer": self.announce_peer_received,}self.socket = socket.socket(socket.AF_INET, socket.SOCK_DGRAM)self.socket.bind(("0.0.0.0", self.port))def response_received(self, msg, address):self.find_node_handler(msg)def query_received(self, msg, address):try:self.actions[msg["q"]](msg, address)except KeyError:passdef send_krpc(self, msg, address):try:self.socket.sendto(bencode(msg), address)except:passclass Client(KRPC):def __init__(self, table):self.table = tabletimer(KRPC_TIMEOUT, self.timeout)timer(REBORN_TIME, self.reborn)KRPC.__init__(self)def find_node(self, address, nid=None):nid = self.get_neighbor(nid) if nid else self.table.nidtid = entropy(TID_LENGTH)msg = {"t": tid,"y": "q","q": "find_node","a": {"id": nid, "target": random_id()}}self.send_krpc(msg, address)def find_node_handler(self, msg):try:nodes = decode_nodes(msg["r"]["nodes"])for node in nodes:(nid, ip, port) = nodeif len(nid) != 20: continueif nid == self.table.nid: continueself.find_node( (ip, port), nid )except KeyError:passdef joinDHT(self):for address in BOOTSTRAP_NODES: self.find_node(address)def timeout(self):if len( self.table.buckets ) < 2:self.joinDHT()timer(KRPC_TIMEOUT, self.timeout)def reborn(self):self.table.nid = random_id()self.table.buckets = [ KBucket(0, 2**160) ]timer(REBORN_TIME, self.reborn)def start(self):self.joinDHT()while True:try:(data, address) = self.socket.recvfrom(65536)msg = bdecode(data)self.types[msg["y"]](msg, address)except Exception:passdef get_neighbor(self, target):return target[:10]+random_id()[10:]class Server(Client):def __init__(self, master, table, port):self.table = tableself.master = masterself.port = portClient.__init__(self, table)def ping_received(self, msg, address):try:nid = msg["a"]["id"]msg = {"t": msg["t"],"y": "r","r": {"id": self.get_neighbor(nid)}}self.send_krpc(msg, address)self.find_node(address, nid)except KeyError:passdef find_node_received(self, msg, address):try:target = msg["a"]["target"]neighbors = self.table.get_neighbors(target)nid = msg["a"]["id"]msg = {"t": msg["t"],"y": "r","r": {"id": self.get_neighbor(target), "nodes": encode_nodes(neighbors)}}self.table.append(KNode(nid, *address))self.send_krpc(msg, address)self.find_node(address, nid)except KeyError:passdef get_peers_received(self, msg, address):try:infohash = msg["a"]["info_hash"]neighbors = self.table.get_neighbors(infohash)nid = msg["a"]["id"]msg = {"t": msg["t"],"y": "r","r": {"id": self.get_neighbor(infohash), "nodes": encode_nodes(neighbors)}}self.table.append(KNode(nid, *address))self.send_krpc(msg, address)self.master.log(infohash)self.find_node(address, nid)except KeyError:passdef announce_peer_received(self, msg, address):try:infohash = msg["a"]["info_hash"]nid = msg["a"]["id"]msg = { "t": msg["t"],"y": "r","r": {"id": self.get_neighbor(infohash)}}self.table.append(KNode(nid, *address))self.send_krpc(msg, address)self.master.log(infohash)self.find_node(address, nid)except KeyError:passclass KTable(object):def __init__(self, nid):self.nid = nidself.buckets = [ KBucket(0, 2**160) ]def append(self, node):index = self.bucket_index(node.nid)try:bucket = self.buckets[index]bucket.append(node)except IndexError:returnexcept BucketFull:if not bucket.in_range(self.nid): returnself.split_bucket(index)self.append(node)def get_neighbors(self, target):nodes = []if len(self.buckets) == 0: return nodesif len(target) != 20 : return nodesindex = self.bucket_index(target)try:nodes = self.buckets[index].nodesmin = index - 1max = index + 1while len(nodes) < K and ((min >= 0) or (max < len(self.buckets))):if min >= 0:nodes.extend(self.buckets[min].nodes)if max < len(self.buckets):nodes.extend(self.buckets[max].nodes)min -= 1max += 1num = intify(target)nodes.sort(lambda a, b, num=num: cmp(num^intify(a.nid), num^intify(b.nid)))return nodes[:K]except IndexError:return nodesdef bucket_index(self, target):return bisect_left(self.buckets, intify(target))def split_bucket(self, index):old = self.buckets[index]point = old.max - (old.max - old.min)/2new = KBucket(point, old.max)old.max = pointself.buckets.insert(index + 1, new)for node in old.nodes[:]:if new.in_range(node.nid):new.append(node)old.remove(node)def __iter__(self):for bucket in self.buckets:yield bucketclass KBucket(object):__slots__ = ("min", "max", "nodes")def __init__(self, min, max):self.min = minself.max = maxself.nodes = []def append(self, node):if node in self:self.remove(node)self.nodes.append(node)else:if len(self) < K:self.nodes.append(node)else:raise BucketFulldef remove(self, node):self.nodes.remove(node)def in_range(self, target):return self.min <= intify(target) < self.maxdef __len__(self):return len(self.nodes)def __contains__(self, node):return node in self.nodesdef __iter__(self):for node in self.nodes:yield nodedef __lt__(self, target):return self.max <= targetclass KNode(object):__slots__ = ("nid", "ip", "port")def __init__(self, nid, ip, port):self.nid = nidself.ip = ipself.port = portdef __eq__(self, other):return self.nid == other.nid#using exampleclass Master(object):def __init__(self, f):self.f = fdef log(self, infohash):try:conn=MySQLdb.connect(host='127.0.0.1',user='',passwd='',port='',charset="UTF8")cur=conn.cursor()conn.select_db('dht')hash_hex=infohash.encode("hex")sql="insert into hash_info(hash,name) values('%s','%s')"%(hash_hex,"")try:cur.execute(sql)mit()except MySQLdb.Error,e:print 'mysql error %d:%s'%(e.args[0],e.args[1])except MySQLdb.Error,e:print 'mysql error %d:%s'%(e.args[0],e.args[1])self.f.write(infohash.encode("hex")+"\n")self.f.flush()try:f = open("infohash.log", "a")m = Master(f)s = Server(Master(f), KTable(random_id()), 80010)s.start()except KeyboardInterrupt:s.socket.close()f.close()
下面是根据hash下载种子并解析的Python程序:
# _*_ coding: utf-8 _*_'''https://zoink.it'''import urllib,urllib2,os,MySQLdb,gzip,base64,timefrom io import BytesIOfrom btdht import Parserimport sysreload(sys) sys.setdefaultencoding('utf8')def save(filename, content):try:file = open(filename, 'wb')file.write(content)file.close()except IOError,e:print edef getTorrents(info_hash):url="https://zoink.it/torrent/%s.torrent"%info_hash.upper()#url="/torrent/%s.torrent"%info_hash.upper()#print urltry:torrent=urllib2.urlopen(url,timeout=30)buffer = BytesIO(torrent.read())gz = gzip.GzipFile(fileobj=buffer)raw_data=gz.read()save("torrents/"+info_hash+".torrent",raw_data)except IOError,e:print e#print "downloading+"+info_hash+".torrent failed"return False#print "downloading+"+info_hash+".torrent success"return Truedef getAllTorrents(table):#try:# os.mkdir("torrents")#except Error,e:#print etry:conn=MySQLdb.connect(host='127.0.0.1',user='',passwd='',port='',charset="UTF8")cur=conn.cursor()conn.select_db('dht')sql="select * from "+table + " where info = '' limit 30"count=cur.execute(sql)print "thers are %s row in table"% countresult=cur.fetchall()i=0for r in result:time.sleep(1)#the torrent info is empty#download the torrent file successstate=getTorrents(r[0])if state:#count the torrent filei=i+1try:parser=Parser.Parser("torrents/"+r[0]+".torrent")except :print 'bt file error'#print parsername=parser.getName()#print '============================================================='#print r[0]#print name#update the tuple#print r[0]encoding=parser.getEncoding()comment=parser.getComments()info = parser.getInfo()info = base64.encodestring(str(info))##多文件还是单文件isFiles = parser.getJeiGou()##根据isFiles获取文件if isFiles == 2:files = parser.getFilesList()else:files = parser.getOneFileList()##获取种子创建日期createDate = parser.getCreateDate()print isFilesprint nameprint filesprint createDate#print commenttry:date = time.strftime("%Y-%m-%d %H:%M:%S", time.localtime())if encoding:if isinstance(name, unicode):name = name.encode('utf-8')info = info.encode('utf-8')filesStr = files[0].encode('utf-8')lengthsStr = files[1].encode('utf-8')createDatesStr = createDate.encode('utf-8')else:filesStr = files[0]lengthsStr = files[1]createDatesStr = createDate#name = (name.decode(encoding)).encode('utf-8')#print name + "=========================="#print encoding sql="update hash_info set hash_info.name='%s',info='%s',create_time='%s',files='%s',lengths='%s',create_date='%s' where hash_info.hash='%s'"%(name,info,date,filesStr,lengthsStr,createDatesStr,r[0])print sqlcur.execute(sql)else:if isinstance(name, unicode):name = name.encode('utf-8')info = info.encode('utf-8')filesStr = files[0].encode('utf-8')lengthsStr = files[1].encode('utf-8')createDatesStr = createDate.encode('utf-8')else:filesStr = files[0]lengthsStr = files[1]createDatesStr = createDate#print name + "0000000000000000000000000"name = name.decode('utf-8')#print name.encode('utf-8')+" "+encoding#sql="update hash_info set hash_info.info='%s' where hash_info.hash='%s'"%(name,r[0])sql="update hash_info set hash_info.name='%s',info='%s',create_time='%s',files='%s',lengths='%s',create_date='%s' where hash_info.hash='%s'"%(name,info,date,filesStr,lengthsStr,createDatesStr,r[0])#print sqlcur.execute(sql)mit()except Exception ,e:print eelse:try:#torrent file download failedsql="delete from hash_info where hash_info.hash='%s'"%(r[0])cur.execute(sql)mit()except:print 'error'cur.close()conn.close()except MySQLdb.Error,e:print 'mysql error %d:%s'%(e.args[0],e.args[1])print 'the torrent files :'+str(i) if __name__=="__main__":getAllTorrents("hash_info")'''info_hash="5302C30A88347F10E1F0A5BF334A8AC85D545AC0"getTorrents(info_hash)'''
