python实现监控windows服务并自动启动服务示例

使用python 2.7 + pywin32 + wxpython开发

每隔一段时间检测一下服务是否停止，如果停止尝试启动服务。进行服务停止日志记录

appmain.py

#!/usr/bin/env python
#-*- encoding:utf-8 -*-

"""
1. 每隔一分钟检测一次服务状态
2. 如果发现服务状态已经停止，那么尝试启动服务
3. 自动记录日志
4. 任务栏图标显示
"""

import sys;
reload(sys);
sys.setdefaultencoding('utf-8');

import win32service;
import logging;
from logging.handlers import rotatingfilehandler;
import os.path;
import wx;
import appresource;
import webbrowser;
from appxml import *;

c_app_name = "service moniter 1.0";
c_log_dir = os.path.altsep.join([os.path.curdir,'service.log']);
c_config_path = os.path.altsep.join([os.path.curdir,'config.xml']);
c_log_size = 1048576;
c_log_files = 3;

c_app_site = "http://www.du52.com/?app=service_moniter&version=1.0.0";

class servicecontrol(object):

    def __init__(self):
        self.scm = win32service.openscmanager(none,none,win32service.sc_manager_all_access);

    # 检查服务是否停止
    def isstop(self,name):
        flag = false;
        try:
            handle = win32service.openservice(self.scm,name,win32service.sc_manager_all_access);
            if handle:
                ret = win32service.queryservicestatus(handle);
                flag = ret[1]!=win32service.service_running;
                win32service.closeservicehandle(handle);
        except exception,e:
            logging.error(e);
        return flag;

    # 开启服务
    def start(self,name):
        try:
            handle = win32service.openservice(self.scm,name,win32service.sc_manager_all_access);
            if handle:
                win32service.startservice(handle,none);
                win32service.closeservicehandle(handle);
        except exception,e:
            logging.error(e);

    # 退出
    def close(self):
        try:
            if self.scm:
                win32service.closeservicehandle(self.scm);
        except exception,e:
            logging.error(e);

# 初始化日志
def initlog():
    logging.getlogger().setlevel(logging.error);
    rthandler = rotatingfilehandler(filename=c_log_dir,maxbytes=c_log_size,backupcount=c_log_files);
    rthandler.setlevel(logging.error);
    rthandler.setformatter(logging.formatter('[%(asctime)s][%(levelname)s] %(message)s'));
    logging.getlogger().addhandler(rthandler);
    logging.error('监控开始执行');

# 系统托盘图标
class taskicon(wx.taskbaricon):

    def __init__(self):
        wx.taskbaricon.__init__(self);
        self.seticon(appresource.taskicon.geticon(),c_app_name);
        self.id_name = wx.newid();
        self.id_exit = wx.newid();
        self.id_author = wx.newid();
        self.bind(wx.evt_menu,self.onexitevent,id=self.id_exit);
        self.bind(wx.evt_menu,self.onhelpevent,id=self.id_author);

    def onhelpevent(self,event):
        webbrowser.open_new(c_app_site);

    def onexitevent(self,event):
        wx.exit();

    def createpopupmenu(self,event=none):
        menu = wx.menu();
        menu.append(self.id_name,c_app_name);
        menu.appendseparator();
        menu.append(self.id_author,"技术支持");
        menu.append(self.id_exit,"退出");
        return menu;

# 隐藏窗口
class frame(wx.frame):

    def __init__(self,timelen,services):
        wx.frame.__init__(self,parent=none,title=c_app_name);
        self.timelen = timelen*1000;
        self.services = services;
        self.show(false);
        self.bind(wx.evt_timer,self.ontimerevent);
        self.bind(wx.evt_close,self.onexitevent);
        self.timer = wx.timer(self);
        self.timer.start(self.timelen);

    def ontimerevent(self,event):
        sc = servicecontrol();
        for name in self.services:
            print name;
            if sc.isstop(name):
                logging.error('系统检测到服务[%s]停止'%(name,));
                sc.start(name);
        sc.close();

    def onexitevent(self,event):
        if self.timer:
            self.timer.stop();
            self.timer = none;

# 进程
class application(wx.app):

    def oninit(self):
        # 初始化配置
        xml = xmlnode();
        if not xml.loadfile(c_config_path):
            logging.error('配置文件不存在');
            return false;
        timelen = xml.findnode('time').getint();
        if timelen<=0:
            logging.error('监控间隔时间必须大于0秒');
            return false;
        services = xml.findnode('services').getchildrenlist(tag='item');
        if len(services)==0:
            logging.error('监控服务列表不能为空');
            return false;
        self.taskbar = taskicon();
        self.frame = frame(timelen,services);
        return true;

    def onexit(self):
        logging.error('监控停止执行');
        self.frame.close();
        self.taskbar.removeicon();
        self.taskbar.destroy();

if __name__ == '__main__':
    initlog();
    app = application();
    app.mainloop();

appxml.py

#!/usr/bin/env python
#-*- encoding:utf-8 -*-

"""
xml操作封装
"""

import os.path;
import logging;
import xml.etree.elementtree as elementtree;

class xmlnodevalue(object):
    string = 1;
    int = 2;
    float = 3;
    bool = 4;

class xmlnodemap(object):
    attr = 1;
    text = 2;
    node = 3;

class xmlnode(object):

    def __init__(self,currentnode=none,rootnode=none):
        self.currentnode = currentnode;
        self.rootnode = rootnode;

    # 加载xml文件
    def loadfile(self,path):
        if os.path.isabs(path): path = os.path.abspath(path);
        flag = false;
        try:
            self.rootnode = elementtree.parse(path);
            if self.rootnode is not none: flag = true;
            self.currentnode = self.rootnode;
        except exception,e:
            logging.error("xml文件加载失败");
            logging.error(e.__str__());
        return flag;

    # 加载xml内容
    def loadstring(self,data):
        if data is none or len(data.strip())==0: return false;
        flag = false;
        try:
            self.rootnode = elementtree.fromstring(data);
            if self.rootnode is not none: flag = true;
            self.currentnode = self.rootnode;
        except exception,e:
            logging.error("xml内容加载失败");
            logging.error(e.__str__());
        return flag;

    #  检查数据是否载入正确
    def isload(self):
        return self.currentnode is not none and self.rootnode is not none;

    # 返回根节点对象
    def getroot(self):
        return xmlnode(self.rootnode,self.rootnode);

    # 查找节点,开始为“/”从根节点开始查找,否则从当前节点查找
    def findnode(self,path):
        if path is none or len(path.strip())==0: return xmlnode(none,self.rootnode);
        path = path.strip();
        node = none;
        if path[0]=='/':
            node = self.rootnode.find(path[1:]);
        else:
            node = self.currentnode.find(path);
        return xmlnode(node,self.rootnode);

    # 查找多节点
    def findnodes(self,path):
        if path is none or len(path.strip())==0: return xmlnode(none,self.rootnode);
        if path[0]=='/':
            nodes = self.rootnode.findall(path[1:]);
        else:
            nodes = self.currentnode.findall(path);
        return [xmlnode(node,self.rootnode) for node in nodes];

    # 获取子节点列表
    def getchildrens(self,tag=none):
        return [xmlnode(node,self.rootnode) for node in self.currentnode.iter(tag=tag)];

    # 格式化数据
    def getformatdata(self,node,type):
        if type==xmlnodevalue.string:
            v = node.getstr();
        elif type==xmlnodevalue.int:
            v = node.getint();
        elif type==xmlnodevalue.float:
            v = node.getfloat();
        elif type==xmlnodevalue.bool:
            v = node.getbool();
        else:
            v = node.getdata();
        return v;

    # 获取子节点内容列表
    # valueformat 值类型 1 字符串,2 整数,3 小数,4 布尔值
    def getchildrenlist(self,tag=none,valueformat=xmlnodevalue.string):
        data = [];
        for node in self.getchildrens(tag=tag):
            data.append(self.getformatdata(node,valueformat));
        return data;

    # 获取子节点map表
    # keytype 1 使用属性值 2 使用子节点
    # keyname   属性值名称或子节点名称
    # valuetype 1 使用属性值 2 使用子节点
    # valuename 属性值名称或子节点名称
    def getchildrenmap(self,tag=none,keytype=xmlnodemap.attr,keyname="name",valuetype=xmlnodemap.text,valuename=none,valueformat=xmlnodevalue.string):
        data = {};
        for node in self.getchildrens(tag=tag):
            k,v = none,none;
            if keytype==xmlnodemap.attr:
                if keyname is none or len(keyname.strip())==0: continue;
                k = node.getattrs().getstr(keyname);
            elif keytype==xmlnodemap.node:
                if keyname is none or len(keyname.strip())==0: continue;
                t = node.findnode(keyname);
                if not t.isload(): continue;
                k = t.getstr();
            elif keytype==xmlnodemap.text:
                k = node.getstr();
            else:
                continue;
            if k is none or len(k.strip())==0: continue;
            if valuetype==xmlnodemap.attr:
                if valuename is none or len(valuename.strip())==0: continue;
                v = self.getformatdata(node.getattrs(),valueformat);
            elif valuetype==xmlnodemap.node:
                if valuename is none or len(valuename.strip())==0: continue;
                t = node.findnode(valuename);
                if t.isload():
                    v = self.getformatdata(t,valueformat);
            elif valuetype==xmlnodemap.text:
                v = self.getformatdata(node,valueformat);
            else:
                v = none;
            data[k] = v;
        return data;

    # 获取节点名称
    def gettag(self):
        if self.currentnode is none: return "";
        return self.currentnode.tag;

    # 获取节点内容
    def getdata(self,default=none):
        if self.currentnode is none: return default;
        return self.currentnode.text;

    def getstr(self,default="",strip=true):
        data = self.getdata();
        if data is none: return default;
        try:
            data = str(data.encode("utf-8"));
            if data is none:
                data = default;
            else:
                if strip:
                    data = data.strip();
        except exception,e:
            print e;
            data = default;
        return data;

    def getint(self,default=0):
        data = self.getdata();
        if data is none: return default;
        try:
            data = int(data);
            if data is none: data = default;
        except exception:
            data = default;
        return data;

    def getfloat(self,default=0.0):
        data = self.getdata();
        if data is none: return default;
        try:
            data = float(data);
            if data is none: data = default;
        except exception:
            data = default;
        return data;

    def getbool(self,default=false):
        data = self.getdata();
        if data is none: return default;
        data = false;
        if self.getstr().lower()=="true" or self.getint()==1: data = true;
        return data;

    # 获取节点属性
    def getattrs(self,default={}):
        return xmlattr(self);

class xmlattr(object):

    def __init__(self,node):
        self.node = node;
        self.initattrs();

    # 获取node
    def getnode(self):
        return self.node;

    # 设置node
    def setnode(self,node):
        self.node = node;
        self.initattrs();

    # 初始化node属性列表
    def initattrs(self):
        if self.node is none or self.node.currentnode is none:
            self.attrs = {};
        self.attrs = self.node.currentnode.attrib;

    # 获取属性
    def getattrs(self):
        if self.attrs is none: self.initattrs();
        return self.attrs;

    # 获取指定属性
    def getdata(self,key,default=none):
        data = self.attrs.get(key);
        if data is none : data = default;
        return data;

    def getstr(self,key,default="",strip=true):
        data = self.getdata(key);
        if data is none: return default;
        try:
            data = str(data.encode("utf-8"));
            if data is none:
                data = default;
            else:
                if strip:
                    data = data.strip();
        except exception:
            data = default;
        return data;

    def getint(self,key,default=0):
        data = self.getdata(key);
        if data is none: return default;
        try:
            data = int(data);
            if data is none: data = default;
        except exception:
            data = default;
        return data;

    def getfloat(self,key,default=0.0):
        data = self.getdata(key);
        if data is none: return default;
        try:
            data = float(data);
            if data is none: data = default;
        except exception:
            data = default;
        return data;

    def getbool(self,key,default=false):
        data = self.getdata(key);
        if data is none: return default;
        data = false;
        if self.getstr(key).lower()=="true" or self.getint(key)==1: data = true;
        return data;

# 测试
if __name__ == "__main__":
    node = xmlnode();
    print node.loadfile(r"config.xml");
    print node.findnode("engine/headers").getchildrenmap("header",xmlnodemap.attr,"name",xmlnodemap.text,none,xmlnodevalue.string);

appresource.py

#----------------------------------------------------------------------
# this file was generated by c:\python27\scripts\img2py
#
from wx.lib.embeddedimage import pyembeddedimage

taskicon = pyembeddedimage(
    "ivborw0kggoaaaansuheugaaacaaaaagcayaaabzenr0aaaabhncsvqicagifahkiaaacqdj"
    "refuwixfl31s1euvxz/p7+2+997evve2pzbaqmmhcoil9qvbgsjegsmzohrgjtfmwcymy7ko"
    "wcky+yejy7kha4zmbweo4xadsp0eqqiifueloptsn9rblklbe+/v3vt7e/yhlwfh1iqso8kv"
    "v3++ec73oed8zzmpkfik/o+mzaqqqigndquwxgkxwihejphqsjrxffjqvy0bbszabw1j/f33"
    "/+ztucie6+z8cg9ntuv74gd3limldt4ujktstpbcr7esu/rhzcaxjgixmixlissmkeg0rzjf"
    "sqi4giptv3flfysxrv+za/fwxff42vmnt452ayrcruuzd8zevh5r8twlhyp2pgv5h7sk7wba"
    "r5hatc2clyoaj2skxmegtgxucm2dz65kvc5e0ti44vga3gfpl+6c9+rqpqjirxfb8kj4nwvf"
    "xdgjxujspsfl+ooirmkj5qwp8cs4jssywly9zs9efheo03732lpw8lklceeiqidriytkhorc"
    "+fwjsbow/4oicbgune2jloc6ett2yoctbdvpunmj4tbpqgszgb9cbdttdxp1umcyfq61zutg"
    "kluthcj1bbw7am8o+zewdmm0buztwjrzzlm5crkchaeui2omejkmmglip8hmgela1ihsucqc"
    "ssnmfzwxgxg8xlc9ohjf0201jz29ff3nicubw9xz6hvdmp/onimai+m4oi5dc6tjig1djg2o"
    "a5af1hweqievbxsnyjf6/yp3iyfyrsloqhhi1cnrmzam9q4ppyalln45ao2ts2984bfrx2hd"
    "1xbnre7vthgcrjwgk7cpazjf9hfjf5+j53m4rosis1sz78bxe07f3d5naf1hnsyfw+6a+jrp"
    "66/oj8bvpggqmsszgsmxjhwjdxzyaw7h/pllvz14clrba/cfqwulb21przgd00zgazbiamyc"
    "w7tdtjax0rtj41k8zypebkgh3bjhvkzjpxg2bzeg3lcc1m4e0q9tvydsdcbcavycgqhgeuwb"
    "0bqwtv6mmyp1puemvwa6fycupv27ptr+0b6cm41dhldaenlb8zzg5rfy0v6wxfee61nkciae"
    "lugdeurostjzf9voir+oi9evim3xyogpsporngqpkc6qb0xgioh+y5ohdg3uofeeukrz3fz/"
    "pfnfz/d0xk5jk8fxlvzxxbqz7e7/bx9e0nxcaetiuy65ewrmlmdedvjrjkwewerbhte3faw0"
    "wgncwafcg+qugglcd5gdow7t7emz6r5abuohkx9t+3xhc2mjw17ezwdzfpzl4tg2a85+prg3"
    "eixekc+vjitcctqif3kadah8yyh9rzrcqblxoc+xazgslmblieuox3r7ctu3d7dlkz0lvccl"
    "9iqqvwqwi9ovtzzt9bwpimvz2lanzec4blxgf3cysgadmq+ifd4cbpruin8cuxkynaqrli1d"
    "l6mm0ehqiebmo4phf45qmia8phwsp/0xtwpxlue9i2r4hotvga+01zibexp++lbbpqyicx2y"
    "uxwaeawfzmuhhdc+xlewic4zpumlujfh88ahcoe/w0+kpjty+cws2gjm6dfguuzigua1nyeq"
    "fy8/v+mnbx7z+agumneu55y/d4sfkh1xef2+h1xvwisqwetxkwtbywizxrbxjbhvc0bhvil1"
    "wt+xlb08gcojsmqof+3o4pknxrrfkhqf/cqdaakbmmxhckrcvrt442s/3o09//jhtxw5knp8"
    "qdm7s0aioty6shlzb5y3pexzxmhmijpbs2yscajt7zgdmyq1eir80qxhrcvf6idufwntdiud"
    "yx+hsuoffja8rsygewoe8pv9binbfd4fhuhjy3dgxt58unpven/k5xelod4anp/qtzx3+gka"
    "o4mmguuh2db+5ai+1dthlmnjlfbtqxffknhffsjnasb3brch8ttvpkgjv5op7tu0tcmwdhrd"
    "x+fz4fcfup7elljnwtcecoxwzdkz5auqwd4nsre54y+hu6bj8olggkabooug6aiaqrs1itkl"
    "jbhlpqlnltfrby0tjxkatxhjmtxy9gd1kewopmlomoau6+i6jqeg8ysoy9ytbw373sifn/wr"
    "nm397u0fq4mhczolqnd6qmk6acqogqiggvkdpfhvm4wyo4sysj9acir/echylhl+gp/ssthd"
    "b7gs+eenqecsrvfqvrvn1dffaeoeiccrlfubb99ypae6+vwkeuvaja5tnnmd/iqkudxqjcgc"
    "haklcvh9d+kqegq2q+gomidrbuc/g4w3d4jbpkrywoenacgv14pdcycnlcpfiqkgcbufdvxq"
    "amjpxwndcf28urua07pg66rzcno7g2vetuzftbaicnmigkot1vxhw7kvuqtnf7qtco07qe+c"
    "abicea5gbhbfg1+dkovaedsvmu/huz1z7fvl5qrl5iu4lfkrsksumkkch/yconh9qc/rfucg"
    "tl0kwznqcm4pdhyencwwmu2qp2yx37v1vqkgon3xpqkosbuqtuzed3ldkzo90xqogqgkqgia"
    "1tfs19vvcqycpiu37lqtffznqwcm/z50illtsge874jx/i1mzhj6aisfeapthh6hm+u4bfwb"
    "nqbkuerz+mwehjmcaqm0dvqvhkbrz0rr+smenbjuysb5fvm53y6750spzeojvl60qtckqi+c"
    "zwa/cl+gn1fopo+j4pmjan4cqr/xoezxucmgbatxoyyl7ptvzi8zgw9av5e/i29vn/h8gmah"
    "mulojxljzryh2hvmzcwuvgigub9k3bbennaugmiojbpkt850/owvnc5o9/vdh6kwpazjaijj"
    "ag/ue26t8ru9l/1tjfte6qliueitvpihoihjafm0ycf9wgvx8m9fyp/+9kfvv+/scn1qtlou"
    "t97yhh95jp1yz2frk/zo375oxznl3c0p/fj2vt0cyy95lx5jdkrxccd6tp0ttmvzrsq4lk1a"
    "nxf1hg3znz94mhkwna57de3adx2qqiqu6yoalmxr0bgjqmss1xasbrnes08qhs///f4p5erm"
    "zyolffjk9cz/kh+gakuvvvii73i4kawor6/3hcphkplwz31+qwj8l+0/pb1wioqcfx8aaaaa"
    "suvork5cyii=")

config.xml

<?xml version="1.0" encoding="utf-8" ?>
<config>
    <!-- 需要监控的服务名称列表 -->
    <services>
        <item>dhcp</item>
    </services>
    <!-- 间隔时间(单位秒) -->
    <time>10</time>
</config>