网站开发中职教材,浙江网站建设抖音seo优化,淘宝网官方网,wordpress 多标签大体思路#xff0c;有n台mc#xff0c;要dump出数据#xff0c;n台进行对比#xff0c;看数据是否一致#xff0c;设计到同时dump的问题#xff0c;server断发条指令给这n台mc#xff0c;mc同时去dump把结果返回给server端#xff0c;server端把这些结果进行对比serve… 大体思路有n台mc要dump出数据n台进行对比看数据是否一致设计到同时dump的问题server断发条指令给这n台mcmc同时去dump把结果返回给server端server端把这些结果进行对比server段#!/usr/bin/python#coding:utf8import socketimport osimport threadingimport timeimport sysdef work_1(ip,conn): global should_stop while True: if should_stop: print should_stop break time.sleep(10) conn.send(ip) client_dataconn.recv(1024) data1client_data.split( )[0] try: data2client_data.split( )[1] except IndexError, e: print should_stop set should_stop True bbopen(/home/text.txt,a) bb.write(client_data\n) print time.time(),client_datassocket.socket(socket.AF_INET,socket.SOCK_STREAM)s.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR, 1)s.bind((10.13.144.224,9999))s.listen(10)s.setblocking(0)s.settimeout(10)ip10.13.144.224list_1[]should_stop Falsewhile True: if should_stop: break try: conn,addrs.accept() except socket.timeout: continue print client timeout: ,conn.gettimeout() a0 aathreading.Thread(targetwork_1,args(ip,conn)) list_1.append(aa) print list_1 aa.start()print joinfor i in list_1: i.join()print ccopen(/home/text.txt,r)cdopen(/home/text1.txt,w)cacc.readlines()for ii in ca: if ii : break elif ii \n: pass else: cd.write(ii)cd.close()cgopen(/home/text1.txt,r)cfcg.readlines()dict_1{}for iiii in cf: print ok dict_1[iiii.split( )[0]]iiii.split( )[1]print dict_1print int(dict_1[dict_1.keys()[0]])-int(dict_1[dict_1.keys()[1]])czopen(/home/text.txt,w)cz.truncate()cyopen(/home/text1.txt,w)cy.truncate()print exit client断#!/usr/bin/python#coding:utf8import socketimport timeimport telnetlibdef mem_status(ip,port): print ip print port tntelnetlib.Telnet(ip,port) tn.set_debuglevel(1) tn.write(dump /data0/logs/b.log\n) tn.write(quit\n) return okdef work_lines(file): print file open_fileopen(file,r) print open_file file_linesopen_file.readlines() return file_linescsocket.socket(socket.AF_INET,socket.SOCK_STREAM)c.connect((10.13.144.224,9999))file/data0/logs/b.logrecc.recv(1024)if rec 10.13.144.224: return_valuemem_status(10.67.15.11,22224) time.sleep(10) if return_value: aopen(/data0/logs/b.log,r) file_linesa.readlines() over10.67.15.11 str(len(file_lines)) print over #over10.13.144.224,str(len(file_lines)) c.send(str(over)) 转载于:https://blog.51cto.com/4249964/1557426
