北郵計(jì)算機(jī)網(wǎng)絡(luò)課程設(shè)計(jì)DNS服務(wù)器

本文格式為Word版，下載可任意編輯——北郵計(jì)算機(jī)網(wǎng)絡(luò)課程設(shè)計(jì)DNS服務(wù)器

北郵計(jì)算機(jī)網(wǎng)絡(luò)課程設(shè)計(jì)DNS服務(wù)器1環(huán)境

操作系統(tǒng)隨意,語言python2.72.文件

Socket.py說明完成緩存檢測,確定是回應(yīng),還是轉(zhuǎn)發(fā),假使是回應(yīng),確定是本地回應(yīng)還是外部應(yīng)答轉(zhuǎn)發(fā)

importsocketimportmydicimportcharhandleimportmakeframe

s=socket.socket(socket.AF_INET,socket.SOCK_DGRAMport=53

the_dic=mydic.get_web_ip(client_request={}client_request_index={}reverse_map={}key_record=0client_wait=[]s.bind(('',port

time_rest=0request_general=''print'running'whileTrue:try:

msg,(client,port=s.recvfrom(1024except:print'Timeout!'continuerequest=[]request=list(msg

requre_web=charhandle.get_request(request[12:]website=''.join(requre_webif(port==53:answer=[]answer=list(msg

print\print\

response_ip=msg[-4]+msg[-3]+msg[-2]+msg[-1]

char_ip=socket.inet_ntoa(response_ipprintwebsite+'hastheip:'+char_ipfre=mydic.storeForUpdate(website,char_ipprint'withthefrequenceof'+str(fre

###real_request=client_request[request[0]+request[1]]foreach_clientinclient_wait:

my_key=client_request[request[0]+request[1]+str(each_client]ifclient_request_index.get(my_key!=None:

s.sendto(msg,client_request_index[my_key]print\printclient_request_index[my_key]breakelse:

print\print\print(client,port

###requre_web=charhandle.get_request(request[12:]###website=''.join(requre_webprint\

if(the_dic.get(website!=None:print\re_ip=the_dic.get(websiteprintre_ip

fre=mydic.storeForUpdate(websiteprintre_ip[0]+'withfrequence'+str(frezhen=makeframe.make(re_ip[0],msgs.sendto(zhen,(client,portelse:

print\key_record=key_record+1request_general=key_record

client_request[request[0]+request[1]+str(client]=request_generalclient_request_index[request_general]=(client,portifclientnotinclient_wait:client_wait.append(client

#selectauthorityDNSserverasyouwishs.sendto(msg,('',53time_rest=time_rest+1

try:

if(time_rest==50:print'payattention'

print'######################'mydic.updateCache(

print'######################'the_dic=mydic.get_web_ip(time_rest=0except:

print'notvalidfrequence'print''s.close(

Mydic.py完成本地查詢,LRU算法維護(hù)本地緩存,socket.py第97行的time_request值可以確定更新緩存的頻率,可以直接輸出在dnsrelay.txt內(nèi),但是為了便利觀測變化,我輸出到了dnsrelaycopy.txt里面,運(yùn)行一段時(shí)間之后,可以去看看學(xué)習(xí)到的新條目

importpickleimportosimportthreadingA=[]

d_web_ip={}d_ip_web={}update_dic={}data=open('dnsrelay.txt'foreach_lineindata:try:

(ip,sitecopy=each_line.split('',1(site,nothing=str(sitecopy.split('\\n',1d_web_ip[site]=[ip,1]d_ip_web[ip]=siteexcept:print'fileerror'data.close(try:

withopen('newdnsrelay.pickle','wb'asnewdnsrelay_file:pickle.dump(d_web_ip,newdnsrelay_fileexceptIOErroraserr:print'Fileerror:'+str(errexceptpickle.PickleErrorasperr:

print'Picklingerror:'+str(perrdefget_web_ip(:

withopen('newdnsrelay.pickle','rb'asf:globalupdate_dicupdate_dic=pickle.load(freturnupdate_dic.copy(return(None

defstoreForUpdate(web_site,add=None:globalupdate_dic

if(update_dic.get(web_site!=None:add_frequen=update_dic[web_site]add_frequen[1]=add_frequen[1]+1

printweb_site+'frequenceincrase1,withip'+add_frequen[0]returnadd_frequen[1]else:

update_dic[web_site]=[add,1]print'recordforanewsite'return1

defupdateCache(:globalupdate_dic

m=update_dic.copy(

t=threading.Thread(target=my_thread,kwargs=mprint'readytoupdatelocalcache'

t.start(t.join(

defmy_thread(*argu,**arg:frequence=[]remain_dic={}foreach_keyinarg:tmp=arg[each_key]if(tmp[1]notinfrequence:frequence.append(tmp[1]if(tmp[0]=='0.0.0