随手写个网络通讯情况监控“微系统”

import subprocess,json,time,sys

sourceip = "localip"

dest = sys.argv[1]

postapi = http://serverip/getping

#获取ping的数据并把数据post到指定的服务器api里面，主要通过urllib2来实现。

def Curlpost(web,data):

values =urllib.urlencode(data)

req =urllib2.Request(web,values)

response =urllib2.urlopen(req)

result =response.read()

#通过ping来获取具体的网络监测情况。Subprocess的作用是新建一个进程来执行我们提供的命令。然后把进行的输出重定向到PIPE,具体的建议大家自己到网络上去搜。然后从获取的输出out中读取我们需要的东西。这个步骤通过re(正则)模块来完成，具体的功能同样建议到网络搜索。主要功能是通过正则表达式来匹配出我们需要的内容如匹配数字123.123 \d+\.\d+ ,我比较少使用正则一些复杂的不会使用。（如果有人有去测试的话，有比较好的匹配方法，请留言）

def getpingdata():

try:

ping = subprocess.Popen(["ping", "-n", "-c60", dest], stdout=subprocess.PIPE, stderr=subprocess.PIPE)

out, error = ping.communicate()

if out:

data={}

#通过re，正则来匹配出我们想要的内容。以后的data[]=m[x] 就是取出具体的哪些数据。

m=re.findall(r"\d+\.\d+",out)

a=re.findall(r"\d+\%",out)

data[‘min‘]=m[-4]

data[‘avg‘]=m[-3]

data[‘max‘]=m[-2]

data[‘loss‘]=a[0].split(‘%‘)[0]

#此处获取当时的时间搓，并通过time生成当天的日期和时间，这三个数据都会存放在服务器上。

t=time.time()

data[‘time‘]=t

data[‘day‘]=time.strftime("%Y-%m-%d",time.localtime(t))

data[‘hour‘]=time.strftime("%H:%M:%S",time.localtime(t))

#存储源IP和目标IP

data[‘destip‘]=dest

data[‘sourceip‘]=sourceip

#所有需要的数据都装到data{}里面了。

returndata

else:

print ‘Noping‘

except:

print "no data"

#无限循环来进行获取，提交数据。

while 1:

data = getpingdata()

Curlpost(postapi,data)

sourceip = models.IPAddressField(null=True)

destip = models.IPAddressField(null=True)

min = models.FloatField(default=1)

max = models.FloatField(default=1)

avg = models.FloatField(default=1)

loss = models.IntegerField(default=0)

day = models.CharField(null=True,max_length=50,default=datetime.datetime.now().strftime("%Y-%m-%d"))

hour =models.CharField(null=True,max_length=50,default=datetime.datetime.now().strftime("%H:%M:%S"))

time = models.FloatField(null=True,default=time.time())

def getpingdata(request):

if request.method == ‘POST‘:

data=request.POST

datamode =PingData(min=float(data[‘min‘]),max=float(data[‘max‘]),avg=float(data[‘avg‘]),sourceip=str(data[‘sourceip‘]),destip=str(data[‘destip‘]),loss=int(data[‘loss‘]),day=str(data[‘day‘]),hour=str(data[‘hour‘]),time=float(data[‘time‘]))

datamode.save()

return HttpResponse("OK")

<form>

<div>

<label for="sourceip">Source IP</label>

<input type="text"id="sourceip" placeholder="eg:192.168.1.1" >

</div>

<div>

<labelfor="destip">Dest IP</label>

<input type="text"id="destip" placeholder="eg:192.168.1.1" >

</div>

<div>

<label for="starttime">Start time</label>

<div class=‘input-group date‘ id=‘datetimepicker1‘>

<input type=‘text‘class="form-control" id="starttime"name="time"  />

<spanclass="input-group-addon"><span></span></span>

</div>

</div>

<div>

<label for="endtime">End time</label>

<div class=‘input-group date‘ id=‘datetimepicker2‘>

<input type=‘text‘class="form-control" id="endtime"name="time"  />

<spanclass="input-group-addon"><span></span></span>

</div>

</div>

<button type="button" id="Goquery"class="btn  btn-primarybtn-sm">查询</button>

</form>

</div>

<div>

<div id="container1"style="min-width:800px;height:400px"></div>

<div id="container2"style="min-width:800px;height:400px"></div>

</div>

#  定义两个highchart对象.

Highchart的话请参考此链接http://blog.csdn.net/splendid_java/article/details/9186681

<script>

在图中对应的是上方的图

function showMscChart(hour,max,min,avg){

$(‘#container1‘).highcharts({

chart: {

type: ‘line‘,

},

title: {

text: ‘Network Responce‘

},

xAxis: {

type:‘datetime‘,

categories: hour  #这边标示x坐标轴，我们通过参数hour来自定义

},

yAxis: {

title: {

text: ‘Network responce:ms‘

}

},

plotOptions: {

line: {

dataLabels: {

enabled: true

},

enableMouseTracking: false

}

},

#series是具体需要显示的数据。我们同样通过传参来进行赋值。

series: [{

name: ‘max‘,

data: max

}, {

name: ‘min‘,

data: min

}, {

name: ‘avg‘,

data: avg

}]

});

}

#在显示的图中对应的是下方的图

function showLossChart(hour,loss){

$(‘#container2‘).highcharts({

chart: {

type: ‘line‘,

},

title: {

text: ‘Network responce‘

},

xAxis: {

type:‘datetime‘,

categories: hour

},

yAxis: {

title: {

text: ‘Network loss:%‘

}

},

plotOptions: {

line: {

dataLabels: {

enabled: true

},

enableMouseTracking: false

}

},

series: [{

name: ‘loss‘,

data: loss

},]

});

}

</script>

$("#Goquery").on("click",function(){

#从我们前端html页面中获取数据。

var Qureydata = {}

Qureydata[‘starttime‘]=$(‘#datetimepicker1‘).data()[‘date‘]

Qureydata[‘endtime‘]=$(‘#datetimepicker2‘).data()[‘date‘]

Qureydata[‘sourceip‘]=$("#sourceip").val()

Qureydata[‘destip‘]=$("#destip").val()

//console.log(Qureydata)

$.ajax({

type:"POST",

url:"testping",  #我们要提交的api接口的url

dataType:"json",

data:Qureydata,   #我们提交的数据

success:function(data){

console.log(data)

$.each(data,function(item,i){

if (item =="max"){max=i }

if (item=="min"){min=i}

if (item=="hour"){hour=i}

if(item=="avg"){avg=i}

if(item=="loss"){loss=i}

})

#进行具体的highchart的实例化。

showMscChart(hour,max,min,avg)

showLossChart(hour,loss)

},

})

})

</script>