架構(gòu)圖
通過定時任務(wù)采集解析MQ XML數(shù)據(jù)存儲到MYSQL數(shù)據(jù)庫中，當(dāng)前MQ積累值超過100時，說明消費異常，通過企業(yè)微信報警，MQ.php可查詢歷史記錄。

預(yù)覽
告警頁面

查詢頁面，顯示最后1000行數(shù)據(jù)

系統(tǒng)組成
MQchecktouch.py 初始化數(shù)據(jù)庫
MQcheck.py 監(jiān)控主程序
MQ.php 歷史記錄查詢程序

初始化數(shù)據(jù)庫
首先手動創(chuàng)建庫和用戶，通過MQchecktouch.py初始化，生成表

import mysql.connector
mqdb = mysql.connector.connect(
? ?host="127.0.0.1",
? ?user="mquser",
? ?passwd="mqpasswd",
? ?database="mq"
)
mqcursor = mqdb.cursor()
mqcursor.execute("CREATE TABLE mqdata (id INT AUTO_INCREMENT PRIMARY KEY,time VARCHAR(255), name VARCHAR(255), number VARCHAR(255))")
mqcursor.execute("CREATE TABLE configkey (name VARCHAR(255), config VARCHAR(255))")
insert_sql = "INSERT INTO configkey (name, config) VALUES ('config','1')"
mqcursor.execute(insert_sql)
mqdb.commit()
mqcursor.close()

初始化后的數(shù)據(jù)庫

監(jiān)控主程序
通過定時任務(wù)運行主程序

import requests,time
import xml.etree.cElementTree as ET
import mysql.connector

def get_mqxml():
? ?mqreq = requests.post(url='http://你的MQ地址:8161/admin/xml/queues.jsp', auth=('admin', 'admin'))
? ?mqxml = ET.fromstring(mqreq.content.decode())
? ?mqname_list = []
? ?mqnumbers_list = []
? ?for queue in mqxml.iter('queue'):
? ? ? ?mqname_list.append(queue.get("name"))
? ? ? ?mqnumbers_list.append(queue.find('stats').get("size"))
? ?return mqname_list,mqnumbers_list

def post_weixin(num,mqnumber):
? ?if num == 0:
? ? ? ?data = "6啊，MQ恢復(fù)了，當(dāng)前累計值："
? ?else:
? ? ? ?data = "G了，MQ當(dāng)前累計值："

? ?url = 'https://qyapi.weixin.qq.com/cgi-bin/webhook/send?key=你自己的企業(yè)微信機器人'
? ?body = {
? ? ? ?"msgtype": "news",
? ? ? ?"news": {
? ? ? ? ? ?"articles": [
? ? ? ? ? ? ? ?{
? ? ? ? ? ? ? ? ? ?"title": "MQ監(jiān)控機器人",
? ? ? ? ? ? ? ? ? ?"description": data+str(mqnumber),
? ? ? ? ? ? ? ? ? ?"url": "90apt.com",
? ? ? ? ? ? ? ? ? ?"picurl": "你自己的圖片"
? ? ? ? ? ? ? ?}
? ? ? ? ? ?]
? ? ? ?}
? ?}
? ?headers = {"Content-Type": "application/json"}
? ?response = requests.post(url, json=body)
? ?print(response.text)
? ?print(response.status_code)


def save_mysql():
? ?total = 0
? ?mqdb = mysql.connector.connect(
? ? ? ?host="127.0.0.1",
? ? ? ?user="mquser",
? ? ? ?passwd="mqpasswd",
? ? ? ?database="mq"
? ?)
? ?mqcursor = mqdb.cursor()
? ?nowtime = time.asctime()
? ?for ele in range(0, len(mqnumbers_list)):
? ? ? ?sql = "INSERT INTO mqdata (time ,name, number) VALUES (%s, %s, %s)"
? ? ? ?val = (nowtime, mqname_list[ele], mqnumbers_list[ele])
? ? ? ?mqcursor.execute(sql, val)
? ? ? ?total = total + int(mqnumbers_list[ele])
? ? ? ?mqdb.commit()
? ?print(total)
? ?if total > 10:
? ? ? ?getconfig_sql = "SELECT * FROM configkey WHERE name ='config'"
? ? ? ?mqcursor.execute(getconfig_sql)
? ? ? ?mqconfig = mqcursor.fetchall()[0][1]
? ? ? ?if mqconfig == "0":
? ? ? ? ? ?updateconfig_sql = "UPDATE configkey SET config = '1' WHERE name = 'config'"
? ? ? ? ? ?mqcursor.execute(updateconfig_sql)
? ? ? ? ? ?mqdb.commit()
? ? ? ? ? ?mqcursor.close()
? ? ? ? ? ?post_weixin(1,total)
? ? ? ?else:
? ? ? ? ? ?None
? ?else:
? ? ? ?getconfig_sql = "SELECT * FROM configkey WHERE name ='config'"
? ? ? ?mqcursor.execute(getconfig_sql)
? ? ? ?mqconfig = mqcursor.fetchall()[0][1]
? ? ? ?if mqconfig == "1":
? ? ? ? ? ?updateconfig_sql = "UPDATE configkey SET config = '0' WHERE name = 'config'"
? ? ? ? ? ?mqcursor.execute(updateconfig_sql)
? ? ? ? ? ?post_weixin(0, total)
? ? ? ? ? ?mqdb.commit()
? ? ? ? ? ?mqcursor.close()
? ? ? ?else:
? ? ? ? ? ?None

mqname_list = get_mqxml()[0]
mqnumbers_list = get_mqxml()[1]
save_mysql()




歷史記錄查詢程序

<?php

$con=mysqli_connect("localhost","mquser","mqpasswd","mq");
// 檢測連接
if (mysqli_connect_errno())
{
? ?echo "連接失敗: " . mysqli_connect_error();
}

$result = mysqli_query($con,"SELECT * FROM mqdata order by time desc limit 1,1000");
while($row = mysqli_fetch_array($result))
{
? ?echo $row['time'] . " " . $row['name'] . " " . $row['number'];
? ?echo "<br>";
}
$conn = null;
?>