Linux 端Tomcat监控程序(JAVA版)

Linux 端Tomcat监控程序(JAVA版)

1.一个判断服务是否启动的监控类

1. package com.util;
3. import java.io.BufferedReader;
4. import java.io.InputStreamReader;
5. import java.io.LineNumberReader;
6. import java.net.URL;
7. import java.net.URLConnection;
8. import java.util.HashSet;
9. import java.util.Set;
10. import java.util.regex.Matcher;
11. import java.util.regex.Pattern;
13. publicclass RequestUtil {
14. /**
15. * 网站是否正常运转
16. * @return
17. */
18. publicstaticboolean isWebSiteNormal(String urlStr){
19. try {
20. if(urlStr != null && urlStr.indexOf("://") <= 0 ){
21. urlStr = "http://"+urlStr;
22. }
23. URL url = new URL(urlStr);
24. URLConnection con = url.openConnection();
25. BufferedReader in = new BufferedReader(new java.io.InputStreamReader(con
26. .getInputStream()));
27. con.setConnectTimeout(2000);
28. con.setReadTimeout(6000);
29. String s = "";
30. while ((s = in.readLine()) != null) {
31. if (s.length() > 0) {
32. returntrue;
33. }
34. }
35. in.close();
36. } catch (Exception e) {
37. LogUtil.writerE(e);
38. }
39. returnfalse;
40. }
42. /**
43. * 查看Tomcat7服务是否正在运行
44. * @return
45. */
46. publicstaticboolean isTomcatServiceAlive(){
47. try {
48. Process process = Runtime.getRuntime().exec("lsof -i tcp:80");
49. InputStreamReader ir = new InputStreamReader(process.getInputStream());
50. LineNumberReader input = new LineNumberReader(ir);
51. String line;
52. while ((line = input.readLine()) != null) {
53. if(line != null && !"".equals(line)){
54. returntrue;
55. }
56. }
57. } catch (java.io.IOException e) {
58. LogUtil.writerE(e);
59. }
60. returnfalse;
61. }
63. /**
64. * 获取tomcat监听的进程
65. * @return
66. */
67. publicstatic String getTomcatTcpIpListener(){
68. StringBuffer str = new StringBuffer();
69. try {
70. Process process = Runtime.getRuntime().exec("lsof -i tcp:80");
71. InputStreamReader ir = new InputStreamReader(process.getInputStream());
72. LineNumberReader input = new LineNumberReader(ir);
73. String line;
74. while ((line = input.readLine()) != null) {
75. if(line != null && !"".equals(line)){
76. str.append(line).append("\n");
77. }
78. }
79. } catch (java.io.IOException e) {
80. LogUtil.writerE(e);
81. }
82. return str.toString();
83. }
85. /**
86. * 获取tomcat监听的进程
87. * @param content
88. * @return
89. */
90. publicstatic Set<Integer> getUids(String content){
91. Pattern pattern = Pattern.compile("java\\s*[0-9]*");
92. Matcher matcher = pattern.matcher(content);
93. Pattern pattern2 = Pattern.compile("[0-9]+");
94. Set<Integer> uidSet = new HashSet<Integer>();
95. while(matcher.find()){
96. Matcher matcher2 = pattern2.matcher(matcher.group());
97. if(matcher2.find()){
98. if(matcher2.group() != null && !"".equals(matcher2.group())){
99. uidSet.add(Integer.parseInt(matcher2.group()));
100. }
102. }
103. }
104. return uidSet;
105. }
107. publicstaticboolean isWebCanVisite(String url) {
108. if(url != null && url.lastIndexOf("://") <= 0 ){
109. url = "http://"+url;
110. }
111. LogUtil.writerINF("Check Url:"+url);
112. String content = HttpRequestProxy.doGet(url,"utf-8");
113. // Pattern pattern = Pattern.compile("<title>\\s*[^<>][^<>]*\\s*</title>");
114. // Pattern pattern2 = Pattern.compile("[^x00-xff]*");
115. if(content != null){
116. returntrue;
117. // Matcher matcher = pattern.matcher(content);
118. // String temp = "";
119. // while(matcher.find()){
120. // temp = matcher.group();
121. // temp = temp.trim();
122. // if(temp.length() > 16){
123. // temp = temp.substring(7, temp.length()-8);
124. // Matcher matcher2=pattern2.matcher(temp);
125. // if(matcher2.find()){
126. // return true;
127. // }
128. // }
129. // }
131. }
132. returnfalse;
133. }
136. }

2.一个Tomcat服务控制工具类

1. package com.util;
3. import java.util.Iterator;
4. import java.util.Set;
6. publicclass TomcatUtil {
8. /**
9. * 关闭tomcat7服务
10. * @return
11. */
12. publicstaticboolean stopTomcat() {
13. try {
14. String commandstr = "/usr/local/tomcat7/bin/shutdown.sh";
15. Process p;
16. LogUtil.writerINF("Tomcat7 ShutDown");
17. p = Runtime.getRuntime().exec(commandstr);
18. if (p.waitFor() == 0){
19. LogUtil.writerINF("Tomcat7 ShutDown over");
20. returntrue;
21. }else{
22. LogUtil.writerINF("Tomcat7 ShutDown fail");
23. returnfalse;
24. }
25. } catch (Exception e) {
26. LogUtil.writerINF("Tomcat7 ShutDown fail");
27. LogUtil.writerE(e);
28. returnfalse;
29. }
30. }
32. /**
33. * 开启服务
34. * @return
35. */
36. publicstaticboolean startTomcat() {
37. try {
38. String commandstr = "/usr/local/tomcat7/bin/startup.sh";
39. Process p;
40. LogUtil.writerINF("Tomcat7 startup");
41. p = Runtime.getRuntime().exec(commandstr);
42. if (p.waitFor() == 0){
43. LogUtil.writerINF("Tomcat7 startup over");
44. returntrue;
45. }else{
46. LogUtil.writerINF("Tomcat7 startup fail");
47. returnfalse;
48. }
49. } catch (Exception e) {
50. LogUtil.writerINF("Tomcat7 startup fail");
51. LogUtil.writerE(e);
52. returnfalse;
53. }
54. }
56. /**
57. * 杀掉进程
58. * @param uidSet
59. * @return
60. */
61. publicstaticint killUid(Set<Integer> uidSet){
62. Iterator<Integer> it = uidSet.iterator();
63. int successCount = 0 ;
64. while(it.hasNext()){
65. int uid = it.next();
66. try {
67. String commondStr = "kill -9 "+uid;
68. Process p = Runtime.getRuntime().exec(commondStr);
69. if (p.waitFor() == 0){
70. LogUtil.writerINF("java "+uid+" be Killed");
71. successCount ++;
72. }else{
73. LogUtil.writerINF("java "+uid+" be Kill Failed");
74. }
75. } catch (Exception e) {
76. LogUtil.writerE(e);
77. }
78. }
79. return successCount;
80. }
82. }