前言:

Redhat下安装Python2.7

rhel6.4自带的是2.6， 发现有的机器是python2.4。 到python网站下载源代码，解压到Redhat上，然后运行下面的命令：

复制代码 代码如下:

./configure --prefix=/usr/local/python27

make

make install

这样安装之后默认不会启用Python2.7，需要使用/usr/local/python27/bin/python2.7调用新版本的python。

而下面的安装方式会直接接管现有的python

复制代码 代码如下:

./configure

make

make install

开始：

服务子进程被监控主进程创建并监控，当子进程异常关闭，主进程可以再次启动之。使用了python的subprocess模块。就这个简单的代码，居然互联网上没有现成可用的例子。没办法，我写好了贡献出来吧。

首先是主进程代码：service_mgr.py

复制代码 代码如下:

!/usr/bin/python

-- coding: UTF-8 --

cheungmine

stdin、stdout和stderr分别表示子程序的标准输入、标准输出和标准错误。

可选的值有:

subprocess.PIPE - 表示需要创建一个新的管道.

一个有效的文件描述符（其实是个正整数）

一个文件对象

None - 不会做任何重定向工作，子进程的文件描述符会继承父进程的.

stderr的值还可以是STDOUT, 表示子进程的标准错误也输出到标准输出.

subprocess.PIPE

一个可以被用于Popen的stdin、stdout和stderr 3个参数的特输值，表示需要创建一个新的管道.

subprocess.STDOUT

一个可以被用于Popen的stderr参数的特输值，表示子程序的标准错误汇合到标准输出.

################################################################################
import os
import sys
import getopt

import time
import datetime

import codecs

import optparse
import ConfigParser

import signal
import subprocess
import select

logging

require python2.6.6 and later

import logging
from logging.handlers import RotatingFileHandler

log settings: SHOULD BE CONFIGURED BY config

LOG_PATH_FILE = "./my_service_mgr.log"
LOG_MODE = 'a'
LOG_MAX_SIZE = 410241024 # 4M per file
LOG_MAX_FILES = 4 # 4 Files: my_service_mgr.log.1, printmy_service_mgrlog.2, ...
LOG_LEVEL = logging.DEBUG

LOG_FORMAT = "%(asctime)s %(levelname)-10s[%(filename)s:%(lineno)d(%(funcName)s)] %(message)s"

handler = RotatingFileHandler(LOG_PATH_FILE, LOG_MODE, LOG_MAX_SIZE, LOG_MAX_FILES)
formatter = logging.Formatter(LOG_FORMAT)
handler.setFormatter(formatter)

Logger = logging.getLogger()
Logger.setLevel(LOG_LEVEL)
Logger.addHandler(handler)

color output

pid = os.getpid()

def print_error(s):
print '\033[31m[%d: ERROR] %s\033[31;m' % (pid, s)

def print_info(s):
print '\033[32m[%d: INFO] %s\033[32;m' % (pid, s)

def print_warning(s):
print '\033[33m[%d: WARNING] %s\033[33;m' % (pid, s)

def start_child_proc(command, merged):
try:
if command is None:
raise OSError, "Invalid command"

    child = None    

    if merged is True:    
        # merge stdout and stderr    
        child = subprocess.Popen(command,    
            stderr=subprocess.STDOUT, # 表示子进程的标准错误也输出到标准输出    
            stdout=subprocess.PIPE    # 表示需要创建一个新的管道    
        )    
    else:    
        # DO NOT merge stdout and stderr    
        child = subprocess.Popen(command,    
            stderr=subprocess.PIPE,    
            stdout=subprocess.PIPE)    

    return child    

except subprocess.CalledProcessError:    
    pass # handle errors in the called executable    
except OSError:    
    pass # executable not found    

raise OSError, "Failed to run command!"    

def run_forever(command):
print_info("start child process with command: " + ' '.join(command))
Logger.info("start child process with command: " + ' '.join(command))

merged = False    
child = start_child_proc(command, merged)    

line = ''    
errln = ''    

failover = 0    

while True:    
    while child.poll() != None:    
        failover = failover + 1    
        print_warning("child process shutdown with return code: " + str(child.returncode))               
        Logger.critical("child process shutdown with return code: " + str(child.returncode))    

        print_warning("restart child process again, times=%d" % failover)    
        Logger.info("restart child process again, times=%d" % failover)    
        child = start_child_proc(command, merged)    

    # read child process stdout and log it    
    ch = child.stdout.read(1)    
    if ch != '' and ch != '\n':    
        line += ch    
    if ch == '\n':    
        print_info(line)    
        line = ''    

    if merged is not True:    
        # read child process stderr and log it    
        ch = child.stderr.read(1)    
        if ch != '' and ch != '\n':    
            errln += ch    
        if ch == '\n':    
            Logger.info(errln)    
            print_error(errln)    
            errln = ''    

Logger.exception("!!!should never run to this!!!")      

if name == "main":
run_forever(["python", "./testpipe.py"])

然后是子进程代码：testpipe.py

复制代码 代码如下:

!/usr/bin/python

-- coding: UTF-8 --

cheungmine

模拟一个woker进程,10秒挂掉

import os
import sys

import time
import random

cnt = 10

while cnt >= 0:
time.sleep(0.5)
sys.stdout.write("OUT: %s\n" % str(random.randint(1, 100000)))
sys.stdout.flush()

time.sleep(0.5)    
sys.stderr.write("ERR: %s\n" % str(random.randint(1, 100000)))    
sys.stderr.flush()    

#print str(cnt)    
#sys.stdout.flush()    
cnt = cnt - 1    

sys.exit(-1)

Linux上运行很简单：

复制代码 代码如下:

$ python service_mgr.py

Windows上以后台进程运行：

复制代码 代码如下:

start pythonw service_mgr.py

代码中需要修改：

复制代码 代码如下:

run_forever(["python", "testpipe.py"])