topg --timeout=10 --password-file=/root/pass.pwd qmrrsync@10.30.71.2::qmrserver /data/game/kuafu/qmrserver > /dev/null 2>&1')
? ? os.popen2('rsync -czrtopg --timeout=10 --password-file=/root/pass.pwd qmrrsync@10.30.71.2::qmrserver /data/game/qmrserver_lianfu_10003/qmrserver > /dev/null 2>&1')
? ? os.popen2('rsync -czrtopg --timeout=10 --password-file=/root/pass.pwd qmrrsync@10.30.71.2::qmrserver /var/ftp/qmrserver')
#? ? time.sleep(3)
#? ? os.popen('sh /var/ftp/qmrserver/s.sh > /dev/null 2>&1')
logfile = open('name1.txt','a')
def log(msg):
? ? datenow = time.strftime('%Y-%m-%d %H:%M:%S',time.localtime())
? ? logstr = '%s : %s \n' %(datenow, msg)
? ? #print(logstr)
? ? logfile.write(logstr)
class Server(ThreadingMixIn,TCPServer):
? ? pass
class ThreadingServer(ThreadingMixIn,TCPServer):
? ? allow_reuse_address = True
class Handler(StreamRequestHandler):
? ? def handle(self):
? ? ? ? while True:
? ? ? ? ? ? try:
? ? ? ? ? ? ? ? ip = self.client_address[0]
#? ? ? ? ? ? ? ? print ip
? ? ? ? ? ? ? ? ret = self.request.recv(2048).strip()
? print ret
?
? ? ? ? ? ? ? ? log('ret %s' % ret)
? ? ? ? ? ? ? ? if ip == '221.237.152.208' or ip == '221.237.152.108' or ip == '127.0.0.1' or ip == '125.71.211.205':
? ? ? ? ? ? ? ? ? ? if ret == 'reboot':
? ? ? ? ? ? ? ? ? ? ? ? self.request.send('请求收到，成功处理.....')
? ? ? ? ? ? ? ? ? ? ? ? stopjava()
? ? ? ? ? ? ? ? ? ? ? ? time.sleep(38)
? ? ? ? ? ? ? ? ? ? ? ? startjava()
? ? ? ? ? ? ? ? ? ? elif ret == 'banben':
? ? ? ? ? ? ? ? ? ? ? ? self.request.send('请求收到，成功处理')
? ? ? ? ? ? ? ? ? ? ? ? updatejava()
? ? ? ? ? ? ? ? ? ? elif ret == 'time':
? ? ? ? ? ? ? ? ? ? ? ? shijian = os.popen('date +"%Y-%m-%d %H:%M:%S"').read()
? ? ? ? ? ? ? ? ? ? ? ? self.request.send(shijian)
? ? ? ? ? ? ? ? ? ? elif not ret:
#? ? ? ? ? ? ? ? ? ? ? ? print '没有数据'
? ? ? ? ? ? ? ? ? ? ? ? break
? ? ? ? ? ? ? ? ? ? else:
? ? ? ? ? ? ? ? ? ? ? ? self.request.send('请求收到，成功处理....')
? ? ? ? ? ? ? ? ? ? ? ? try:
? ? ? ? ? ? ? ? ? ? ? ? ? ? global time1
? ? ? ? ? ? ? ? ? ? ? ? ? ? time1 = transfertime(ret)
? ? ? ? ? ? ? ? ? ? ? ? ? ? timett = commands.getoutput('date "+%Y-%m-%d %H:%M:%S"')
? ? ? ? ? ? ? ? ? ? ? ? ? ? time2 = transfertime(timett)
? ? ? ? ? ? ? ? ? ? ? ? except Exception,e:
? ? ? ? ? ? ? ? ? ? ? ? ? ? print e
? ? ? ? ? ? ? ? ? ? ? ? ? ? log('时间格式错误')
? ? ? ? ? ? ? ? ? ? ? ? ? ? self.request.send('时间格式错误')
? ? ? ? ? ? ? ? ? ? ? ? if int(time1) > int(time2):
? ? ? print ret
? ? ? ? ? ? ? ? ? ? ? ? ? ? os.popen('date -s "%s"' % ret).read()
? ? ? ? ? ? ? ? ? ? ? ? ? ? self.request.send('时间修改成功')
? ? ? ? ? ? ? ? ? ? ? ? else:
? ? ? print ret
? ? ? ? ? ? ? ? ? ? ? ? ? ? self.request.send('已经收到请求，成功处理...')
? ? ? ? ? ? ? ? ? ? ? ? ? ? stopjava()
? ? ? ? ? ? ? ? ? ? ? ? ? ? time.sleep(38)
? ? ? ? ? ? ? ? ? ? ? ? ? ? os.popen('date -s "%s"' % ret).read()
? ? ? ? ? ? ? ? ? ? ? ? ? ? startjava()
? ? ? ? ? ? ? ? ? ? ? ? ? ? time.sleep(10)
? ? ? ? ? ? ? ? else:
? ? ? ? ? ? ? ? ? ? log('the source is wrong')
? ? ? ? ? ? ? ? ? ? pass
? ? ? ? ? ? except KeyboardInterrupt:
? ? ? ? ? ? ? ? log('键盘错误')
#server = Server((HOST,PORT),Handler)
def funzioneDemo():
? ? server = ThreadingServer((HOST,PORT),Handler)
? ? server.serve_forever()
def createDaemon():
? ? #脱离父进程
? ? try:
? ? ? ? pid = os.fork()
? ? ? ? if pid > 0:
? ? ? ? ? ? os._exit(0)
? ? except OSError,error:
? ? ? ? print "fork #1 failed: %d (%s)" % (error.errno, error.strerror)
? ? ? ? os._exit(1)
? ? #修改当前的工作目录
? ? os.chdir('/')
? ? #脱离终端
? ? os.setsid()
? ? #重设文件创建权限
? ? os.umask(0)
? ? #第二次创建进程，禁止进程重新打开终端文件
? ? try:
? ? ? ? pid = os.fork()
? ? ? ? if pid > 0:
? ? ? ? ? ? print 'Daemon PID %d' % pid
? ? ? ? ? ? os._exit(0)
? ? except OSError,error:
? ? ? ? print "fork #1 failed: %d (%s)" % (error.errno, error.strerror)
? ? ? ? os._exit(1)
? ? funzioneDemo()
if __name__ == "__main__":
? ? createDaemon()
七.客户端请求效果