java tomcat 监控_java程序监控tomcat实现项目宕机自动重启并发送邮件提醒
最近由于老項目頻繁掛掉，由于項目經過多批人之手，短時間難以定位問題，所以只好寫一個監控程序。 時間比較緊半天時間，而且水平有限大神勿噴，有好的方法還請賜教。 1、問題描述：分兩種情況1.1、tomcat 徹底掛掉端口不會占用進程；1.2、并沒有徹底掛掉 端口仍占用進程，但是接口訪問異常； 2、解決思路：啟動一個java服務輪詢(10秒鐘一次)程序的一個接口(比如獲取當前時間)，如果請求不到則查看該端口是否占用進程，如果占用則殺死進程，然后重啟tomcat ；如果沒有占用進程則直接重啟tomca； 本來考慮的是監控多個程序的 但是時間問題就先監控一個吧
3.1 輪訓接口
@Service
public class SchedulerService {
private static final Logger logger = LoggerFactory.getLogger(SchedulerService.class);
@Autowired
private KillService killService;
@Value("#{system['jiankong.ports']}")
private String portsStr;
@Value("#{system['url']}")
private String url;
/**
* 監控接口是否通 如果接口不通 或者返回結果不對則重啟服務 并發送郵件 每10秒執行一次掃描
* @author gaozemin
* @date 2017年10月18日
* @throws Exception
* @return
*/
public void watch() throws Exception {
String[] ports = portsStr.split(",");
for (String port : ports) {
// 調用測試接口
String ret = HttpUtil.sendPost(url, null);
if (ret == null) {// 如果返回結果為空重啟服務
logger.info("返回結果為null ");
killService.start(Integer.valueOf(port));
} else {
try {
Map retMap = JSONObject.parseObject(ret, Map.class);
String retFlag = String.valueOf(retMap.get("result"));
if (!"200".equals(retFlag)) {// 如果返回結果異常 重啟服務
killService.start(Integer.valueOf(port));
} else {
logger.info("系統運行正常....");
}
} catch (Exception e) {
logger.info("返回值解析異常....");
killService.start(Integer.valueOf(port));
}
}
logger.info("監控執行中..");
}
}
3.2 如果監控到異常則重啟服務
@Service
public class KillService {
private static final Logger logger = LoggerFactory.getLogger(KillService.class);
@Value("#{system['waitTime']}")
private Long waitTime;
@Value("#{system['startTomcatExec']}")
private String startTomcatExec;
@Value("#{system['startLinuxTomcatExec']}")
private String startLinuxTomcatExec;
@Value("#{system['findPid']}")
private String findPid;
@Value("#{system['isLinux']}")
private boolean isLinux;
@Value("#{system['send.emails']}")
private String emails;
@Autowired
private SendMail sendMail;
private Map map = new HashMap();
public void start(int port) {
// 先每10秒 殺死一次進程 然后重啟一次 ，執行重啟后5分鐘后再重新執行掃描,確保程序重新啟動
// 1 獲取 指定端口的進程號
// 如果調用接口失敗則殺死進程并重新啟動 ，并記錄當前時間 ,否則不進行操作
Date lastExecTime = map.get(port);
if (lastExecTime != null) {// 如果存在重啟記錄則判斷重啟時間是否間隔5分鐘
Date nowTome = new Date();
Long subTime = nowTome.getTime() - lastExecTime.getTime();
logger.info("間隔時間:{}", subTime);
if (subTime < waitTime) {
logger.info("間隔時間過短 等待程序啟動！");
return;
} else {
map.put(port, new Date());
restartTomcat(port, isLinux);
}
} else {
map.put(port, new Date());
restartTomcat(port, isLinux);
}
}
private void restartTomcat(int port, boolean isLinux) {
Runtime runtime = Runtime.getRuntime();
try {
if (isLinux) {
// 查找進程號
linuxRestart(port);
StartTomcatThread a = new StartTomcatThread(startLinuxTomcatExec);
a.start();
} else {
Process p = runtime.exec(findPid + port);
InputStream inputStream = p.getInputStream();
List read = read(port, inputStream, "UTF-8");
if (read.size() == 0) {
logger.info("找不到端口:{}的進程", port);
StartTomcatThread a = new StartTomcatThread(startTomcatExec);
a.start();
logger.info("tomcat已重啟");
} else {
logger.info("找到" + read.size() + "個進程，正在準備清理");
kill(read);
StartTomcatThread a = new StartTomcatThread(startTomcatExec);
a.start();
}
}
String dataStr = "admin 服務宕機 現已自動重啟 請及時查看日志 修改錯誤！";
String[] emailStrs = emails.split(",");
for (String email : emailStrs) {
sendMail.sendMsg(email, dataStr);
}
} catch (Exception e) {
e.printStackTrace();
}
}
/**
* 驗證此行是否為指定的端口，因為 findstr命令會是把包含的找出來，例如查找80端口，但是會把8099查找出來
*
* @param str
* @return
*/
private boolean validPort(int port, String str) {
String patternString = "^ *[a-zA-Z]+ +\\S+";
Pattern pattern = Pattern.compile(patternString);
Matcher matcher = pattern.matcher(str);
matcher.find();
String find = matcher.group();
int spstart = find.lastIndexOf(":");
find = find.substring(spstart + 1);
int findport = 0;
try {
findport = Integer.parseInt(find);
} catch (NumberFormatException e) {
System.out.println("查找到錯誤的端口:" + find);
return false;
}
if (port == findport) {
return true;
} else {
return false;
}
}
public void linuxRestart(int port) throws IOException, InterruptedException {
String cmd = "kill -9 $(netstat -tlnp|grep " + port + "|awk '{print $7}'|awk -F '/' '{print $1}')";
String[] command = { "sh", "-c", cmd };
Process pro = Runtime.getRuntime().exec(command);
pro.waitFor();
// cmd = path;
// pro = Runtime.getRuntime().exec(cmd);
// pro.waitFor();
}
/**
* 更換為一個Set，去掉重復的pid值
*
* @param data
*/
public void kill(List data) {
Set pids = new HashSet<>();
logger.info("列表:{}" + pids);
for (String line : data) {
int offset = line.lastIndexOf(" ");
String spid = line.substring(offset);
spid = spid.replaceAll(" ", "");
int pid = 0;
try {
pid = Integer.parseInt(spid);
} catch (NumberFormatException e) {
System.out.println("獲取的進程號錯誤:" + spid);
}
pids.add(pid);
}
killWithPid(pids);
}
/**
* 一次性殺除所有的端口
*
* @param pids
*/
public void killWithPid(Set pids) {
for (Integer pid : pids) {
try {
Process process = Runtime.getRuntime().exec("taskkill /F /pid " + pid + "");
InputStream inputStream = process.getInputStream();
String txt = readTxt(inputStream, "UTF-8");
logger.info(txt);
} catch (IOException e) {
e.printStackTrace();
}
}
}
private List read(int port, InputStream in, String charset) throws IOException {
List data = new ArrayList<>();
BufferedReader reader = new BufferedReader(new InputStreamReader(in, charset));
String line;
while ((line = reader.readLine()) != null) {
boolean validPort = validPort(port, line);
if (validPort) {
data.add(line);
}
}
reader.close();
return data;
}
public String readTxt(InputStream in, String charset) throws IOException {
BufferedReader reader = new BufferedReader(new InputStreamReader(in, charset));
StringBuffer sb = new StringBuffer();
String line;
while ((line = reader.readLine()) != null) {
sb.append(line);
}
reader.close();
return sb.toString();
}
}
總結
以上是生活随笔為你收集整理的java tomcat 监控_java程序监控tomcat实现项目宕机自动重启并发送邮件提醒的全部內容，希望文章能夠幫你解決所遇到的問題。
- 上一篇： 不孕不育无精症需要怎么治疗呢
- 下一篇： java object强制类型转换_sc