使用Java編寫一個簡單的Web的監(jiān)控系統(tǒng)
公司的服務器需要實時監(jiān)控，而且當用戶空間已經(jīng)滿了，操作失敗，或者出現(xiàn)程序Exception的時候就需要實時提醒，便于網(wǎng)管和程序員調(diào)式，這樣就把這個實時監(jiān)控系統(tǒng)分為了兩部分，
第一部分：實時系統(tǒng)監(jiān)控（cpu利用率，cpu溫度，總內(nèi)存大小，已使用內(nèi)存大?。?br />
第二部分：實時告警
由于無刷新實時性，所以只能使用Ajax，這里沒有用到任何ajax框架，因為調(diào)用比較簡單
大家知道，由于java的先天不足，對底層系統(tǒng)的調(diào)用和操作一般用jni來完成，特別是cpu溫度，你在window下是打死用命令行是得不到的， 但由于我們的服務器系統(tǒng)是linux，所以可以不調(diào)用jni完全用java的方式來得到系統(tǒng)信息，這里用到了runtime的exec()函數(shù)，通過解析 本地命令調(diào)用的結果來查詢本地信息，
* 取得linux系統(tǒng)下的cpu、內(nèi)存信息
*
* */
public final class LinuxSystemTool
{
/**
* get memory by used info
*
* @return int[] result
* result.length==4;int[0]=MemTotal;int[1]=MemFree;int[2]=SwapTotal;int[3]=SwapFree;
* @throws IOException
* @throws InterruptedException
*/
public static int [] getMemInfo() throws IOException, InterruptedException
{
File file = new File( "/proc/meminfo" );
BufferedReader br = new BufferedReader( new InputStreamReader(
new FileInputStream(file)));
int [] result = new int [ 4 ];
String str = null ;
StringTokenizer token = null ;
while ((str = br.readLine()) != null )
{
token = new StringTokenizer(str);
if (!token.hasMoreTokens())
continue ;
str = token.nextToken();
if (!token.hasMoreTokens())
continue ;
if (str.equalsIgnoreCase( "MemTotal:" ))
result[0 ] = Integer.parseInt(token.nextToken());
else if (str.equalsIgnoreCase( "MemFree:" ))
result[1 ] = Integer.parseInt(token.nextToken());
else if (str.equalsIgnoreCase( "SwapTotal:" ))
result[2 ] = Integer.parseInt(token.nextToken());
else if (str.equalsIgnoreCase( "SwapFree:" ))
result[3 ] = Integer.parseInt(token.nextToken());
}
return result;
}
/**
* get memory by used info
*
* @return float efficiency
* @throws IOException
* @throws InterruptedException
*/
public static float getCpuInfo() throws IOException, InterruptedException
{
File file = new File( "/proc/stat" );
BufferedReader br = new BufferedReader( new InputStreamReader(
new FileInputStream(file)));
StringTokenizer token = new StringTokenizer(br.readLine());
token.nextToken();
int user1 = Integer.parseInt(token.nextToken());
int nice1 = Integer.parseInt(token.nextToken());
int sys1 = Integer.parseInt(token.nextToken());
int idle1 = Integer.parseInt(token.nextToken());
Thread.sleep(1000 );
br = new BufferedReader(
new InputStreamReader( new FileInputStream(file)));
token = new StringTokenizer(br.readLine());
token.nextToken();
int user2 = Integer.parseInt(token.nextToken());
int nice2 = Integer.parseInt(token.nextToken());
int sys2 = Integer.parseInt(token.nextToken());
int idle2 = Integer.parseInt(token.nextToken());
return ( float )((user2 + sys2 + nice2) - (user1 + sys1 + nice1)) / ( float )((user2 + nice2 + sys2 + idle2) - (user1 + nice1 + sys1 + idle1));
}
}
這里的兩個方法，解釋一下，
方法1文件"/proc/meminfo"里面包含的就是內(nèi)存的信息，還包括了swap的信息。例如：
$ cat /proc/meminfo total: used: free: shared: buffers: cached: Mem: 1057009664 851668992 205340672 0 67616768 367820800 Swap: 2146787328 164429824 1982357504 MemTotal: 1032236 kB MemFree: 200528 kB MemShared: 0 kB
這樣可以用截取字符串的方法，來得到linux內(nèi)存信息.
方法2在文件"/proc/stat"里面就包含了CPU的信息。每一個CPU的每一tick用在什么地方都在這個文件里面記著。后面的數(shù)字含義分 別是： user、nice、sys、idle、iowait。有些版本的kernel沒有iowait這一項。這些數(shù)值表示從開機到現(xiàn)在，CPU的每tick用 在了哪里。例如：
cpu0 256279030 0 11832528 1637168262
就是cpu0從開機到現(xiàn)在有 256279030 tick用在了user消耗，11832528用在了sys消耗。所以如果想計算單位時間（例如1s）里面CPU的負載，那只需要計算1秒前后數(shù)值的差除以每一秒的tick數(shù)量就可以了。
ok這樣還剩下cpu溫度，怎么做呢
發(fā)現(xiàn)了一個文件"cat /proc/acpi/thermal_zone/THM/temperature";可以返回本機的linux溫度，
大概是這樣的：
temperature： 68C
但不是每臺linux機器都有這個THM你要確定你的linux加載了這個THM才能使用這個文件，這樣就用InputStreamReader(new FileInputStream（new File("/proc/acpi/thermal_zone/THM/temperature")）, 去讀取這個文件，后面的相信大家一定會做了吧，就是把內(nèi)容讀出來,然后分割字符串去得到這個68。ok,系統(tǒng)基本信息全部完成，然后ok現(xiàn)在就只有一件事就是用Ajax去調(diào)用這個類來得到 基本信息，然后返回到頁面上，Ajax的用法就不贅言了。
下面是系統(tǒng)監(jiān)控的效果，大概是Ajax每幾秒去linux下去取一次系統(tǒng)信息，然后顯示在jsp頁面上，以下是效果。
到這里第一部分系統(tǒng)監(jiān)控部分已經(jīng)完成，現(xiàn)在開始完成實時告警部分，分析需求
1溫度和cpu超過額定值需要告警
2用戶操作系統(tǒng)失敗，用戶存儲空間不足也需要告警，還有我們公司的業(yè)務操作失敗告警，如果發(fā)生Exception也只能告警，當然要把異常的堆棧的 信息保存在數(shù)據(jù)庫里，我就這樣設計如果用戶在操作中觸發(fā)了這些錯誤，則保存在數(shù)據(jù)庫的告警表里，然后實時監(jiān)控的再取出來這些信息。
3告警是要實時的那么要怎么從告警表里查到當前以后的數(shù)據(jù)呢，一開始想到用當前時間，在當前時間加上Ajax發(fā)送時間間隔，select * from warnlist where date>new Date()+AjaxTime這種形式,后來發(fā)現(xiàn)時間是很不正確的，網(wǎng)絡延遲，程序處理時間，（cpu信息用了sleep函數(shù)），等等你常常會發(fā)現(xiàn)有些 告警信息被無情的放過，而有的時候有重復數(shù)據(jù)，這樣我想到了用id，每次進入告警系統(tǒng)先查詢到最大的告警id,然后保存在session中，然后ajax 從數(shù)據(jù)庫里取告警信息的時候都查這個id之后的數(shù)據(jù)（就是進入監(jiān)控系統(tǒng)后的最新數(shù)據(jù)），然后session再保存新的最大id,下次ajax取還是從這個 session中取最大id,這樣信息就可以當ajax取的時候都保證是最新的，而且沒有重復，very good!就這樣做了
這樣設計了一張告警處理表
CREATE TABLE `warnlist` ( `Id` bigint (20) NOT NULL auto_increment, `warnleave` tinyint(2) NOT NULL default '0' ,//告警級別：告警的嚴重程度 `fromguy` varchar (20) NOT NULL ,//屬于哪個用戶哪個組織的告警 `warncontent` varchar (100) NOT NULL ,//告警內(nèi)容，比如cpu使用率超過80% `aviliablevalue` varchar (12) default NULL ,//允許值 比如85% `warnvalue` varchar (12) default NULL ,//告警值 80 `warntime` datetime NOT NULL ,//告警時間 `stackinfo` varchar (255) default NULL ,//異常的堆棧信息 `dealwith` tinyint(2) NOT NULL default '0' ,//處理結果 `version` int (11) default NULL ,//version `organizerID` varchar (20) default NULL ,//組織id `des` varchar (255) default NULL , PRIMARY KEY (`Id`) ) ENGINE=InnoDB DEFAULT CHARSET=utf8;
假設我ajax從系統(tǒng)取信息后，那么要寫個邏輯，if(cpuTempature>75C)or if(cpuUserd>80%)則寫入數(shù)據(jù)庫，然后再查詢大于上一次發(fā)送Ajax數(shù)據(jù)庫的最大id的告警信息（這期間如果發(fā)生的以下錯誤一并查 出：用戶存儲空間不足，還有我們公司的業(yè)務操作失敗告警，Exception等），循環(huán)插入一個xml解析類中，大概形式是這樣的Ajax返回這個 xml,供頁面提取信息
< response > < cpuUsed > 67 </ cpuUsed > < cpuTemp > 76 < cpuTemp > < Memory > 1023422 </ Memory > < freeMemory > 43244 </ freeMemory > < wannlist > < warnid > 2 </ warnid > < warncontent > 系統(tǒng)存儲空間不足 </ warncontent > < fromguy > kakaluyi </ fromguy > .............. </ wanrlist > < warnlist > < warnid > 3 </ warnid > < warncontent > cpu溫度過高 </ warncontent > < fromguy > 系統(tǒng) </ fromguy > < orgid > 系統(tǒng) </ orgid > < warnvalue > 78 </ warnvalue > ............. </ warnlist > ........ </ response >
系統(tǒng)信息的顯示代碼，就是關聯(lián)上面那個圖片的：
var cpuUsed = req .responseXML.getElementsByTagName('cpuUsed')[0].firstChild.nodeValue;
var totalMemory = req .responseXML.getElementsByTagName('totalMemory')[0].firstChild.nodeValue;
var freeMemory = req .responseXML.getElementsByTagName('freeMemory')[0].firstChild.nodeValue;
var cpuTemp = req .responseXML.getElementsByTagName('cpuTemp')[0].firstChild.nodeValue;
$('cpuUsed').innerHTML = cpuUsed ;
$('totalMemory').innerHTML = totalMemory ;
$('freeMemory').innerHTML = freeMemory ;
$('cpuTemp').innerHTML = cpuTemp ;
//jsp
< tr >
< td class = "label" width = "20%" >
服務器CPU使用率：
</ td > < td class = "text" > < font color = "#FF0000" size = "+2" > < label id = "cpuUsed" > </ label > </ font > < 告警預定閥值: 80% > </ td > </ tr > .........
然后就是頁面展現(xiàn)的問題了這里我用了dom節(jié)點的增刪，一個頁面保持50條記錄，如果超過50條則刪除以前的節(jié)點，代碼為：
var length=req.responseXML.getElementsByTagName( 'warnlist' ).length;
if (length>0)
{
var trlength=document.getElementsByTagName( 'table' )[4].childNodes[0].childNodes.length;
if (trlength+length-1>50) //如果大于50條，則查找告警列表的table，得到
告警信息的子節(jié)點，然后刪除多余的最早的告警信息
{
var tbody=document.getElementsByTagName( 'table' )[4].childNodes[0];
for ( var i=1;i<trlength+length-50;i++)
{
var tr=tbody.childNodes[i];
tr.parentNode.removeChild(tr);
}
然后插入新的告警信息，
for ( var i=0;i<length;i++)
{
var onewarnlist=req.responseXML.getElementsByTagName( 'warnlist' )[i].childNodes;
if (onewarnlist[0].firstChild.nodeValue==0)
{
var leave= "企業(yè)級告警" ;
}
else {
var leave= "運營商級告警" ;
}
var from=onewarnlist[1].firstChild.nodeValue;
var warncontent=onewarnlist[2].firstChild.nodeValue;
var aviliablevalue=onewarnlist[3].firstChild.nodeValue;
var warnvalue=onewarnlist[4].firstChild.nodeValue;
var warntime=onewarnlist[5].firstChild.nodeValue;
var id=onewarnlist[8].firstChild.nodeValue;
if (onewarnlist[6].firstChild.nodeValue==0)
{
var dealwith= "未處理" ;
}
else {
var dealwith= "<font color='red'>已處理</font>" ;
}
var table=document.getElementById( 'warntable' );
var tr=document.createElement( 'tr' );
if (x%2==1)
{
tr.style.backgroundColor="#BFD3F9"
}
else {
tr.style.backgroundColor="#FBFCEB"
}
x++;
table.appendChild(tr);
var td=document.createElement( 'td' );
td.className ='listText' ;
td.innerHTML =x;
tr.appendChild(td);
var td1=document.createElement( 'td' );
td1.className ='listText' ;
td1.innerHTML = leave;
tr.appendChild(td1);
var td2=document.createElement( 'td' );
td2.className ='listText' ;
td2.innerHTML = from;
tr.appendChild(td2);
var td3=document.createElement( 'td' );
td3.className ='listText' ;
td3.innerHTML = warncontent;
tr.appendChild(td3);6
var td4=document.createElement( 'td' );
td4.className ='listText' ;
td4.innerHTML = aviliablevalue;
tr.appendChild(td4);
var td5=document.createElement( 'td' );
td5.className ='listText' ;
td5.innerHTML = '<font color="#FF0000">' +warnvalue+ '</font>' ;
tr.appendChild(td5);
var td6=document.createElement( 'td' );
td6.className ='listText' ;
td6.innerHTML = warntime;
tr.appendChild(td6);
var td7=document.createElement( 'td' );
td7.className ='listText' ;
td7.innerHTML = dealwith;
tr.appendChild(td7);
var td8=document.createElement( 'td' );
td8.className ='listText' ;
td8.innerHTML = id;
tr.appendChild(td8);
}
ok，一切大功告成，以下是最終效果
相關文章
眾所周知,SpringBoot默認會掃描啟動類所在的包及其子包,一般我們都是在需要的類上通過注解的方式去將Bean注冊交給IOC進行管理,但是注冊第三方Bean的方案卻不支持,所以本文給大家介紹了SpringBoot注冊第三方Bean的方法,需要的朋友可以參考下2024-01-01
本篇文章通過實例詳細介紹了重寫與重載，以及他們的區(qū)別，需要的朋友可以參考下2017-04-04
這篇文章主要介紹了java信號量控制線程打印順序的示例,如ABCABC這樣輸出線程，大家參考使用吧2014-01-01
這篇文章主要介紹了 Java 值傳遞和引用傳遞詳解及實例代碼的相關資料,需要的朋友可以參考下2017-03-03
這篇文章主要介紹了Java 存儲模型和共享對象詳解的相關資料,對Java存儲模型，可見性和安全發(fā)布的問題是起源于Java的存儲結構及共享對象安全，需要的朋友可以參考下2017-03-03
使用HttpServletResponse對象獲取請求行信息
這篇文章主要介紹了使用HttpServletResponse對象獲取請求行信息，具有很好的參考價值，希望對大家有所幫助。如有錯誤或未考慮完全的地方，望不吝賜教2022-02-02
Mybatis入門指南之實現(xiàn)對數(shù)據(jù)庫增刪改查
數(shù)據(jù)持久層主要負責數(shù)據(jù)的增、刪、改、查等功能,MyBatis 則是一款優(yōu)秀的持久層框架,下面這篇文章主要給大家介紹了關于Mybatis入門指南之實現(xiàn)對數(shù)據(jù)庫增刪改查的相關資料,需要的朋友可以參考下2022-10-10
這篇文章主要介紹了新版POI獲取日期類型cell值過程圖解,文中通過示例代碼介紹的非常詳細，對大家的學習或者工作具有一定的參考學習價值,需要的朋友可以參考下2020-10-10
JWT(JSON?Web?Token)是目前流行的跨域認證解決方案，是一個開放標準(RFC?7519),它定義了一種緊湊的、自包含的方式，用于作為JSON對象在各方之間安全地傳輸信息。本文將介紹JWT如何實現(xiàn)跨域身份驗證，感興趣的可以學習一下2022-01-01
這篇文章主要介紹了Java png圖片修改像素rgba值的操作，具有很好的參考價值，希望對大家有所幫助。如有錯誤或未考慮完全的地方，望不吝賜教2021-11-11