java 监控linux服务器cpu、内存、java进程是否存活，发现异常发送邮件提醒

前一段时间在维护一个N年前的项目，这个项目有十几个服务器，每个服务器上有十几个服务。接手后的几个星期天天有事，要不就是服务挂了导致没有数据，要不就是把服务器跑宕机了。因为是老项目，所以不敢有大的动作，只能写一个简单的检测程序，检测一下服务器状态，cpu使用率，磁盘使用率，进程是否存在。程序不复杂，但是解放了自己。现在把这个小工具整理一下分享出来，希望可以帮到有需要的人。

我使用的是qq的发送邮箱，首先要开启QQ邮箱需获取相应的权限，

开启位置：QQ邮箱–>邮箱设置–>账户–>POP3/IMAP/SMTP/Exchange/CardDAV/CalDAV服务 开启POP3/SMTP服务，然后获取16位授权码（注意不要将授权码泄露，一个账户可以拥有多个授权码)

话不多说直接上代码

package com.yyq;import java.util.Properties;import javax.mail.Authenticator;import javax.mail.Message;import javax.mail.PasswordAuthentication;import javax.mail.Session;import javax.mail.Transport;import javax.mail.internet.InternetAddress;import javax.mail.internet.MimeMessage;/*** * @author 杨永琪* @date 8月16日*/public class CheckJava {/*** 邮箱*/public static final String EMAIL = "XXXXXXX@";/*** 密码*/public static final String EMAIL_PWD = "XXXXXXX";/*** 接受邮件的邮箱*/public static final String RECIPIENT = "XXXXXXX@";public static void main(String[] args) {String jarName = "res_compare.jar";//查看程序进程号String process = checkJava(jarName);//查看磁盘使用率checkDisk();//查看总进程使用数量checkPid();if(null == process){return;}//查看进程cpu使用率checkCPU(process);//查看进程内存使用率checkMEM(process);}/*** 检查指定的java进程是否存在 * @param jarName jar包名称* @return 进程号*/public static String checkJava(String jarName){String checkJavaCmd =String.format("ps -ef | grep %s | grep -v grep | awk '{print $2}'|xargs",jarName);String result = MyRuntimeExec.exec(checkJavaCmd);System.out.println("当前程序 "+jarName+" 进程号是："+result);if(null == result || "".equals(result) || " ".equals(result)){sendMail(EMAIL, EMAIL_PWD, RECIPIENT, jarName+"服务挂了",String.format("主人,您的服务挂啦(%s),赶快处理呀!",jarName));return null;}return result.trim();}/*** 检查 cpu是否超过阈值* @param process 进程号*/public static void checkCPU(String process){int cpuMax = 350;//cpu阈值String cpuCmd = String.format("top -b -n 1 | grep %s | awk '{print int($9)}'",process);String cpuResult = MyRuntimeExec.exec(cpuCmd);cpuResult = cpuResult.trim();Integer cpu = Integer.valueOf(cpuResult);System.out.println("当前程序 "+process+" cpu使用率是："+cpu);if(cpu > cpuMax){sendMail(EMAIL, EMAIL_PWD, RECIPIENT, "cpu超过阈值了",String.format("主人,您的服务cpu爆表啦(%s)现在cpu是:%s,赶快处理呀!",process,cpuResult));}}/*** 检查 内存是否超过阈值* @param process 进程号*/public static void checkMEM(String process){int memMax = 50;//内存阈值String memCmd = String.format("top -b -n 1 | grep %s | awk '{print int($10)}'",process);String memResult = MyRuntimeExec.exec(memCmd);memResult = memResult.trim();Integer mem = Integer.valueOf(memResult);System.out.println("当前程序 "+process+" 内存使用率是："+mem);if(mem > memMax){sendMail(EMAIL, EMAIL_PWD, RECIPIENT, "内存超过阈值了",String.format("主人,您的服务内存爆表啦(%s)现在内存是:%s,赶快处理呀!",process,memResult));}}/*** 检查linux 磁盘空间是否超过阈值*/public static void checkDisk(){int diskMax = 90;//磁盘使用阈值(百分比)String diskCmd = "df -h|head -2| awk '{print int($5)}'|xargs";String diskResult = MyRuntimeExec.exec(diskCmd);String useageStr = diskResult.split(" ")[1];Integer usage = Integer.valueOf(useageStr.trim());System.out.println("当前系统磁盘使用率是："+usage);if(usage > diskMax){sendMail(EMAIL, EMAIL_PWD, RECIPIENT, "磁盘超过阈值了",String.format("主人,您的磁盘快使用完啦,现在使用率是:%s,赶快处理呀!",useageStr));}}/*** 检查linux进程数量是否超过阈值*/public static void checkPid(){int pidMax = 5000;//进程数量阈值String pidCmd = "pstree -p|wc -l";String pidResult = MyRuntimeExec.exec(pidCmd);Integer pids = Integer.valueOf(pidResult.trim());System.out.println("当前系统进程使用数量是："+pids);if(pids > pidMax){sendMail(EMAIL, EMAIL_PWD, RECIPIENT, "进程数超过阈值了",String.format("主人,您的进程数超过阈值啦,现在是:%s,赶快处理呀!",pidResult));}}/*** * @param sender 寄件人* @param senderPwd 寄件人密码* @param recipient 收件人* @param text 内容* @param title标题* @return*/public static boolean sendMail(String sender, String senderPwd, String recipient, String text, String title) {try {final Properties props = new Properties();props.put("mail.smtp.auth", "true");props.put("mail.smtp.host", "");// 发件人的账号props.put("mail.user", sender);// 发件人的密码props.put("mail.password", senderPwd);// 构建授权信息，用于进行SMTP进行身份验证Authenticator authenticator = new Authenticator() {@Overrideprotected PasswordAuthentication getPasswordAuthentication() {// 用户名、密码String userName = props.getProperty("mail.user");String password = props.getProperty("mail.password");return new PasswordAuthentication(userName, password);}};// 使用环境属性和授权信息，创建邮件会话Session mailSession = Session.getInstance(props, authenticator);// 创建邮件消息MimeMessage message = new MimeMessage(mailSession);// 设置发件人String username = props.getProperty("mail.user");InternetAddress form = new InternetAddress(username);message.setFrom(form);// 设置收件人InternetAddress toAddress = new InternetAddress(recipient);message.setRecipient(Message.RecipientType.TO, toAddress);// 设置邮件标题message.setSubject(title);// 设置邮件的内容体message.setContent(text, "text/html;charset=UTF-8");// 发送邮件Transport.send(message);System.out.println("给" + recipient + "发送邮件成功");return true;} catch (Exception e) {System.out.println("给" + recipient + "发送邮件失败,错误：" + e.getMessage());e.printStackTrace();}return false;}}

执行linux命令并解析的工具类

package com.yyq;import java.io.BufferedReader;import java.io.InputStream;import java.io.InputStreamReader;/*** * @author 杨永琪* @date 5月9日*/public class MyRuntimeExec {private static String DEFAULTCHART = "UTF-8";public static String exec(String cm){String os = System.getProperty("os.name").toLowerCase();Process ps = null;InputStream er = null;InputStream is = null;String result = null;try {if(os.contains("win")){String[] cmd = { "cmd", "/c", cm };ps = Runtime.getRuntime().exec(cmd);}else if (os.contains("linux")){if(cm.contains("rm ")){System.err.println("不能执行危险命令"+cm);return result;}if(cm.contains("mv ")){System.err.println("不能执行危险命令"+cm);return result;}String[] cmd = { "/bin/sh", "-c", cm };ps = Runtime.getRuntime().exec(cmd);}is = ps.getInputStream();result = getInString(is);//System.err.println("执行命令："+cm+" 执行结果--<"+result+" >--");} catch (Exception e) {System.err.println(e.getMessage());} finally {try {if (null != ps)ps.waitFor();if (null != is)is.close();if (null != er)er.close();if (null != ps)ps.destroy();} catch (Exception e) {System.err.println(e.getMessage());e.printStackTrace();}}return result;}public static String execEnter(String cm){String os = System.getProperty("os.name").toLowerCase();Process ps = null;InputStream er = null;InputStream is = null;String result = null;try {if(os.contains("win")){String[] cmd = { "cmd", "/c", cm };ps = Runtime.getRuntime().exec(cmd);}else if (os.contains("linux")){String[] cmd = { "/bin/sh", "-c", cm };ps = Runtime.getRuntime().exec(cmd);}is = ps.getInputStream();result = getInStringEnter(is);System.err.println("执行命令："+cm+" 执行结果--<"+result+" >--");} catch (Exception e) {System.err.println(e.getMessage());} finally {try {if (null != ps)ps.waitFor();if (null != is)is.close();if (null != er)er.close();if (null != ps)ps.destroy();} catch (Exception e) {System.err.println(e.getMessage());e.printStackTrace();}}return result;}public static String getInString(InputStream is) throws Exception{StringBuffer result = new StringBuffer();BufferedReader reader = new BufferedReader(new InputStreamReader(is,DEFAULTCHART));String line;while ((line = reader.readLine()) != null) {result.append(line + " ");}return result.toString();}public static String getInStringEnter(InputStream is) throws Exception{StringBuffer result = new StringBuffer();BufferedReader reader = new BufferedReader(new InputStreamReader(is,DEFAULTCHART));String line;while ((line = reader.readLine()) != null) {result.append(line + "\n");}return result.toString();}}

效果

用到的jar包

javax.mail-api-1.5.5.jar

javax.mail-1.5.5.jar

maven依赖

<dependency><groupId>javax.mail</groupId><artifactId>javax.mail-api</artifactId><version>1.5.5</version></dependency><dependency><groupId>com.sun.mail</groupId><artifactId>javax.mail</artifactId><version>1.5.5</version></dependency>