一.socketserver的handle方法處理請求
二.實例化socketserver的handle方法
def funzioneDemo():
server = ThreadingServer((HOST,PORT),Handler)
server.serve_forever()
三.創建daemon進程
os.setsid() #該方法做一系列的事：首先它使得該進程成為一個新會話的領導者，接下來它將進程轉變一個新進程組的領導者，最後該進程不再控制終端, 運行的時候，建立一個進程，linux會分配個進程號。然後調用os.fork()創建子進程。若pid>0就是自己，自殺。子進程跳過if語句，通過os.setsid()成為linux中的獨立於終端的進程（不響應sigint，sighup等）
umask的作用：#默認情況下的 umask值是022(可以用umask命令查看），此時你建立的文件默認權限是644(6-0,6-2,6-2)，建立的目錄的默認 權限是755(7-0,7-2,7-2)，可以用ls -l驗證一下哦 現在應該知道umask的用途了，它是為了控制默認權限，不要使默認的文件和目錄具有全權而設的
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()補充：
腳本在服務器上運行，使用supervisor進行管理，使其在後台運行。
在服務器（CentOS6）上安裝supervisor，然後在/etc/supervisor.conf中加入一下配置：
[program:app-monitor]
command = python /root/monitor/app_monitor.py
directory = /root/monitor
user = root然後在終端中運行supervisord啟動supervisor。
在終端中運行supervisorctl，進入shell，運行status查看腳本的運行狀態。
supervisor就是用Python開發的一套通用的進程管理程序，能將一個普通的命令行進程變為後台daemon，並監控進程狀態，異常退出時能自動重啟。
四.運行調用daemon方法
if __name__ == "__main__":
createDaemon()
五.啟動查看進程
python s3.py
netstat -tunlp|grep 1003
六.綜合實例
__author__ = 'rolin'
# -*- coding: utf-8 -*-
from SocketServer import TCPServer,ThreadingMixIn,StreamRequestHandler
import time,os,commands
#import rsa
#HOST = '207.198.106.114'
HOST = '49.213.70.62'
PORT = 1003
def transfertime(ret):
a = filter(str.isdigit,ret)
a = list(a)
c = ''
for i in range(len(a)):
c += a[i]
if i in (3,5):
c += '-'
if i==7:
c += ' '
if i in (9,11):
c += ':'
a = time.mktime(time.strptime(c,'%Y-%m-%d %H:%M:%S'))
return a
def stopjava():
os.popen('pkill java')
def startjava():
os.popen("cd /data/game/pubserver/pubserver/qmrserver && /bin/sh start.sh >/dev/null 2>&1")
os.popen("cd /data/game/kuafu/qmrserver && /bin/sh start.sh >/dev/null 2>&1")
os.popen("cd /data/game/qmrserver_lianfu_10003/qmrserver && /bin/sh start.sh >/dev/null 2>&1")
os.popen("cd /data/game/qmrserver901/qmrserver && /bin/sh start.sh >/dev/null 2>&1")
os.popen("cd /data/game/qmrserver902/qmrserver && /bin/sh start.sh >/dev/null 2>&1")
os.popen("cd /data/game/qmrserver903/qmrserver && /bin/sh start.sh >/dev/null 2>&1")
os.popen("cd /data/game/qmrserver904/qmrserver && /bin/sh start.sh >/dev/null 2>&1")
os.popen("cd /data/game/qmrserver10002/qmrserver && /bin/sh start.sh >/dev/null 2>&1")
def updatejava():
os.popen2('rsync -czrtopg --timeout=10 --password-file=/root/pass.pwd [email protected]::qmrserver /data/game/qmrserver10002/qmrserver > /dev/null 2>&1')
os.popen2('rsync -czrtopg --timeout=10 --password-file=/root/pass.pwd [email protected]::qmrserver /data/game/qmrserver901/qmrserver > /dev/null 2>&1')
os.popen2('rsync -czrtopg --timeout=10 --password-file=/root/pass.pwd [email protected]::qmrserver /data/game/qmrserver902/qmrserver > /dev/null 2>&1')
os.popen2('rsync -czrtopg --timeout=10 --password-file=/root/pass.pwd [email protected]::qmrserver /data/game/qmrserver903/qmrserver > /dev/null 2>&1')
os.popen2('rsync -czrtopg --timeout=10 --password-file=/root/pass.pwd [email protected]::qmrserver /data/game/qmrserver904/qmrserver > /dev/null 2>&1')
os.popen2('rsync -czrtopg --timeout=10 --password-file=/root/pass.pwd [email protected]::qmrserver /data/game/kuafu/qmrserver > /dev/null 2>&1')
os.popen2('rsync -czrtopg --timeout=10 --password-file=/root/pass.pwd [email protected]::qmrserver /data/game/qmrserver_lianfu_10003/qmrserver > /dev/null 2>&1')
os.popen2('rsync -czrtopg --timeout=10 --password-file=/root/pass.pwd [email protected]::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()
七.客戶端請求效果
Python編寫的Socket服務器和客戶端 http://www.linuxidc.com/Linux/2013-08/89299.htm
CentOS上源碼安裝Python3.4 http://www.linuxidc.com/Linux/2015-01/111870.htm
《Python核心編程 第二版》.(Wesley J. Chun ).[高清PDF中文版] http://www.linuxidc.com/Linux/2013-06/85425.htm
《Python開發技術詳解》.( 周偉,宗傑).[高清PDF掃描版+隨書視頻+代碼] http://www.linuxidc.com/Linux/2013-11/92693.htm
Python腳本獲取Linux系統信息 http://www.linuxidc.com/Linux/2013-08/88531.htm
在Ubuntu下用Python搭建桌面算法交易研究環境 http://www.linuxidc.com/Linux/2013-11/92534.htm
Python 語言的發展簡史 http://www.linuxidc.com/Linux/2014-09/107206.htm
Python 的詳細介紹：請點這裡
Python 的下載地址：請點這裡