最近公司專案經常出現訪問超時的情況， 各種原因都有。 因此用python 寫了個檢測專案訪問是否超時，並郵件提醒的指令碼 。

想到還有其他專案以及依賴的上游介面也需要做檢測提醒，所以用django做成了個web 專案 ，讓公司其他人自己配置需要檢測的專案 ，順便學習下python多執行緒的使用

原理很簡單， 使用 urllib 迴圈請求需檢測的網站，一旦超時發出郵件提醒

Django後臺使用 threading ，每個檢測專案發起一個執行緒來處理檢測以及郵件傳送的任務 。

後臺可以檢視專案檢測狀態 ，配置郵件，檢測頻率以及超時時間，開啟。停止監控等。

沒有前端 ，所以貼下 models 程式碼， 以及threading 的實現類

專案目錄：

models.py

# -*- coding: utf-8 -*-
from __future__ import unicode_literals

from django.db import models
from django.contrib import admin
import threading
from epgtest.jiankong import Jiankong
import Threads
# Create your models here.

class Monitor(models.Model):
    sname = models.CharField(max_length = 150,verbose_name=u"監控名")
    link = models.TextField(blank=True,verbose_name=u"監控地址")
    rate = models.IntegerField(blank=False,verbose_name=u"監控頻率（秒/次）")
    timeout = models.IntegerField(blank=False,verbose_name=u"超時時間（超時N秒後告警）")
    tomail = models.TextField(blank=True,verbose_name=u"告警郵件接受地址")
    title = models.TextField(blank=True,verbose_name=u"告警郵件標題")
    contents = models.TextField(blank=True,verbose_name=u"告警郵件正文")
    GENDER_CHOICES = (
        (0, u'停止監控'),
        (1, u'開啟監控'),
    )
    start = models.IntegerField(default=1 ,choices=GENDER_CHOICES)   
    def my_property(self):
        thread = Threads.GetThreads().get(self.id)
        if  not thread is None:
            if thread.is_alive():
                return '正在監控中！'
        return '監控已停止'
    my_property.short_description = "監控狀態"
    statu = property(my_property)
class MonitorAdmin(admin.ModelAdmin):
    list_display = ('sname','link','tomail','rate','timeout','title','contents','statu')
  
    def delete_model(self, request, obj):
        thread = Threads.GetThreads().get(obj.id)
        if  not thread is None:
                    if thread.is_alive():
                        thread.stop()
                        del Threads.GetThreads()[obj.id]
        obj.delete() 
 
    def save_model(self, request, obj, form, change):
        if change:# 更改的時候
            obj_original = self.model.objects.get(pk=obj.pk)
            obj.save()
            if obj.start == 1:#開啟監控
                thread = Threads.GetThreads().get(obj.id)
                if  not thread is None:
                    if thread.is_alive():
                        thread.stop()
                        del Threads.GetThreads()[obj.id]    
                t = Jiankong(rate=obj.rate,timeout=obj.timeout,link=obj.link,tomail=obj.tomail,title=obj.title,contents=obj.contents,flag=True)
                t.start()
                Threads.GetThreads()[obj.id] = t
            else : #關閉監控
                thread = Threads.GetThreads().get(obj.id)
                if  not thread is None:
                    if thread.is_alive():
                        thread.stop()
                        del Threads.GetThreads()[obj.id]
                
        else:# 新增的時候
            obj_original = None
            obj.save()
            if obj.start == 1:
                t = Jiankong(rate=obj.rate,timeout=obj.timeout,link=obj.link,tomail=obj.tomail,title=obj.title,contents=obj.contents,flag=True)
                t.start()  
                Threads.GetThreads()[obj.id] = t
                 
admin.site.register(Monitor,MonitorAdmin)
 

# coding=utf-8

__threads__ = {}


    
def GetThreads():
    return __threads__

監控類  jiankong.py

#coding:utf-8
import urllib,socket
import time
import smtplib ,sys,datetime
from email.mime.text import MIMEText
from email.mime.multipart import MIMEMultipart
from email.header import Header
import threading
reload(sys)
sys.setdefaultencoding("utf-8")

class Jiankong(threading.Thread):
    def __init__(self,rate,timeout,link,tomail,title,contents,flag):
        threading.Thread.__init__(self)
        self.rate = rate
        self.timeout = timeout
        self.link = link
        self.tomail = tomail
        self.title = title
        self.contents = contents
        self.flag = flag
    def sendMail(self):
        # 第三方 SMTP 服務
        mail_host="smtp.xxxxx.cn"  #設定伺服器
        mail_user="xxxxx.cn"    #使用者名稱
        mail_pass="xxxxxx"   #口令 
         
         
        sender = '
 
[email protected]'
        receivers = [self.tomail]  # 接收郵件，可設定為你的QQ郵箱或者其他郵箱
         
        #建立一個帶附件的例項
        message = MIMEMultipart()
         
        message['From'] = Header("xx", 'utf-8')
        message['To'] =  Header(" , ".join(receivers), 'utf-8')
        today = datetime.datetime.today();
        subject = self.title + today.strftime('%Y-%m-%d %H:%M:%S')
        message['Subject'] = Header(subject, 'utf-8')
         
        #郵件正文內容
        message.attach(MIMEText(self.contents, 'plain', 'utf-8'))
        #設定郵件名片（html格式）
        # html =  file('qianming.html').read().decode("utf-8")
        # message.attach(MIMEText(html, 'html', 'utf-8'))
        
        
        try:
            smtpObj = smtplib.SMTP() 
            smtpObj.connect(mail_host, 25)    # 25 為 SMTP 埠號
            smtpObj.login(mail_user,mail_pass)  
            smtpObj.sendmail(sender, receivers, message.as_string())
            print "郵件傳送成功"
        except smtplib.SMTPException,e:
            print "Error: 無法傳送郵件" + repr(e)

    def run(self):
        socket.setdefaulttimeout(self.timeout)
        while self.flag:
            status = 0
            try:
                status=urllib.urlopen(self.link).code
            except Exception:
                print ""
            if status != 200:
                self.sendMail()
            time.sleep(self.rate)
            
    def stop(self):
        self.flag = False