-
Notifications
You must be signed in to change notification settings - Fork 6
/
monitor_system.py
221 lines (200 loc) · 8.58 KB
/
monitor_system.py
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
198
199
200
201
202
203
204
205
206
207
208
209
210
211
212
213
214
215
216
217
218
219
220
221
# -*- coding: utf-8 -*-
#流量监测界面
from threading import Thread
from time import time
from PyQt5 import QtCore, QtGui, QtWidgets
from PyQt5.QtCore import QSize
from PyQt5.QtGui import *
from matplotlib.backends.backend_qt5agg import FigureCanvasQTAgg as FigureCanvas
from matplotlib.backends.backend_qt5 import NavigationToolbar2QT as NavigationToolbar
import matplotlib.pyplot as plt
from tools import get_rate, time_to_formal
from flow_monitor import Monitor
class Ui_Form(object):
def setupUi(self, Form):
Form.setWindowTitle("流量监测系统")
Form.resize(1150, 630)
# 设置程序图标
icon = QIcon()
icon.addPixmap(QPixmap("img/logo.png"), QIcon.Normal, QIcon.Off) # 修改图标
Form.setWindowIcon(icon)
self.horizontalLayoutWidget = QtWidgets.QWidget(Form)
self.horizontalLayoutWidget.setGeometry(QtCore.QRect(10, 10, 700, 30))
self.horizontalLayout = QtWidgets.QHBoxLayout(
self.horizontalLayoutWidget)
self.horizontalLayout.setContentsMargins(0, 0, 0, 0)
self.horizontalLayout.setSpacing(10)
Form.setFixedSize(Form.width(), Form.height())
self.monitor = Monitor(self) # 建立流量监测器
"""主字体"""
font = QtGui.QFont()
font.setFamily("Microsoft YaHei")
font.setPointSize(10)
"""应用选择框"""
self.comboBox = QtWidgets.QComboBox(self.horizontalLayoutWidget)
self.comboBox.setFont(font)
self.horizontalLayout.addWidget(self.comboBox)
"""流量预警线设置"""
self.warn_line = QtWidgets.QLineEdit(self.horizontalLayoutWidget)
self.warn_line.setText("1024")
self.horizontalLayout.addWidget(self.warn_line)
self.label = QtWidgets.QLabel(self.horizontalLayoutWidget)
self.label.setText("kb/s")
self.horizontalLayout.addWidget(self.label)
self.start_button = QtWidgets.QPushButton(self.horizontalLayoutWidget)
self.start_button.setText("开始监测")
self.start_button.clicked.connect(self.start)
self.horizontalLayout.addWidget(self.start_button)
self.stop_button = QtWidgets.QPushButton(self.horizontalLayoutWidget)
self.stop_button.setText("停止监测")
self.stop_button.clicked.connect(self.stop)
self.horizontalLayout.addWidget(self.stop_button)
self.stop_button.setEnabled(False)
self.update_button = QtWidgets.QPushButton(self.horizontalLayoutWidget)
self.update_button.setText("更新列表")
self.horizontalLayout.addWidget(self.update_button)
self.horizontalLayout.setStretch(0, 2)
self.horizontalLayout.setStretch(1, 1)
self.horizontalLayout.setStretch(2, 1)
self.horizontalLayout.setStretch(3, 1)
self.horizontalLayout.setStretch(4, 1)
# 右侧进程信息栏
self.APPList_label = QtWidgets.QLabel(Form)
self.APPList_label.setText("进程连接列表")
self.APPList_label.setStyleSheet("font-size: 20px; font-family: 宋体")
self.APPList_label.setGeometry(QtCore.QRect(850, 10, 150, 30))
"""应用树列表"""
self.App_Tree = QtWidgets.QTreeWidget(Form)
self.App_Tree.header().setVisible(False)
self.App_Tree.setFont(font)
self.App_Tree.setStyleSheet("QTreeView::item{margin:2px;}")
self.App_Tree.setGeometry(QtCore.QRect(730, 40, 380, 580))
self.update_button.clicked.connect(self.refresh_process)
self.verticalLayoutWidget = QtWidgets.QWidget(Form)
self.verticalLayoutWidget.setGeometry(QtCore.QRect(10, 60, 700, 570))
self.verticalLayout = QtWidgets.QVBoxLayout(self.verticalLayoutWidget)
self.verticalLayout.setContentsMargins(0, 0, 0, 0)
# 抓包列表
self.conList = QtWidgets.QListWidget(self.verticalLayoutWidget)
self.conList.setFont(font)
self.conList.setStyleSheet("QListView::item{margin:2px;}")
self.conList.setMinimumSize(421, 200)
self.verticalLayout.addWidget(self.conList)
# 实时监控图
self.figure = plt.figure(figsize=(6, 3))
self.upload_plot = self.figure.add_subplot(1, 1, 1)
self.upload_plot.set_xlabel("Time (s)")
self.upload_plot.set_ylabel("Speed (kB/s)")
self.figure.tight_layout()
self.canvas = FigureCanvas(self.figure)
self.toolbar = NavigationToolbar(self.canvas,
self.verticalLayoutWidget)
self.toolbar.hide()
self.verticalLayout.addWidget(self.toolbar)
self.verticalLayout.addWidget(self.canvas)
QtCore.QMetaObject.connectSlotsByName(Form)
self.comboBox.addItems(self.monitor.getProcessList())
self.show_process_tree()
self.timer = QtCore.QTimer(Form)
self.timer.timeout.connect(self.conList.scrollToBottom)
def show_process_tree(self):
"""
添加节点
"""
self.App_Tree.clear()
process_name, process_conn = self.monitor.getProcessConnections() #位于flow_monitor.py，利用psutil.process_iter()获取正在运行的进程信息
for name in process_name:
item1 = QtWidgets.QTreeWidgetItem(self.App_Tree) # 树形item结构
item1.setText(0, name)
for connections in process_conn[name]:
item1_1 = QtWidgets.QTreeWidgetItem(item1)
item1_1.setText(0, connections)
def alert(self, info):
"""
警告信息
"""
alert_font = QtGui.QFont()
alert_font.setFamily("Microsoft YaHei")
alert_font.setPointSize(14)
now = time_to_formal(time())
item = QtWidgets.QListWidgetItem("%s\n%s" % (now, info), self.conList)
item.setForeground(QtGui.QColor('red'))
item.setFont(alert_font)
def refresh_process(self):
"""
刷新进程列表
"""
self.comboBox.clear()
self.comboBox.addItems(self.monitor.getProcessList()) # 更新下拉框进程列表
self.show_process_tree()
def setSpeed(self):
"""
设置速度图
"""
upload = []
download = []
speed = int(self.warn_line.text())
# 警告线
alert = [speed for _ in range(60)] #1024
while not self.monitor.start_flag.is_set(): #一直划线
info = get_rate(None) #位于tools.py，默认设置所有网卡的抓包
plt.cla()
self.upload_plot.set_xlabel("Time (s)")
self.upload_plot.set_ylabel("Speed (kB/s)")
info[1] >>= 10 # 差值，转换B->KB
info[0] >>= 10
upload.append(info[1])
download.append(info[0])
if len(upload) >= 60: #超过60个数据，pop掉第一个数据，FIFO
upload.pop(0)
download.pop(0)
# 画图，每次都根据整个数组重新画图
self.upload_plot.plot(
alert, 'red', linewidth='2', label="Warning")
self.upload_plot.legend(loc='upper right') #图例
self.upload_plot.plot(
upload, 'darkorange', linewidth='1', label="Upload")
self.upload_plot.legend(loc='upper right')
self.upload_plot.plot(
download, 'blue', linewidth='1', label="Download")
self.upload_plot.legend(loc='upper right')
self.canvas.draw()
# 流量警告
# 当速度大于设定值时流量警告
if info[1] > speed or info[0] > speed:
self.alert("警告: 流量已超过预警线 %dkB/s!" % speed)
def start(self):
"""
开始检测
"""
if self.monitor.start_flag.is_set():
self.start_button.setEnabled(False)
self.stop_button.setEnabled(True)
self.comboBox.setEnabled(False)
self.warn_line.setEnabled(False)
self.monitor.start(self.comboBox.currentText())
Thread(target=self.setSpeed, daemon=True).start()
self.timer.start(1000)
def stop(self):
"""
停止检测
"""
if not self.monitor.start_flag.is_set():
self.monitor.stop()
self.timer.stop()
self.start_button.setEnabled(True)
self.stop_button.setEnabled(False)
self.comboBox.setEnabled(True)
self.warn_line.setEnabled(True)
def start_monitor():
"""
调用监测系统
"""
app = QtWidgets.QApplication([])
widget = QtWidgets.QWidget()
ui = Ui_Form()
ui.setupUi(widget)
widget.show()
app.exec()
if __name__ == "__main__":
start_monitor()