CollTomcat.java
3.33 KB
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
package com.sitech.ismp.coll.middleware.tomcat;
import com.sitech.ismp.check.downtime.CheckConnectionState;
import com.sitech.ismp.check.downtime.ParamterBean;
import com.sitech.ismp.coll.basic.TblATO_KPIDETAIL;
import com.sitech.ismp.coll.middleware.tomcat.impl.ICollTomcat;
import com.sitech.ismp.coll.middleware.tomcat.impl.TomcatCollFactory;
import com.sitech.util.Formater;
import java.text.ParseException;
import java.util.Date;
import java.util.HashMap;
import java.util.Vector;
public class CollTomcat implements CollTomcatMBean {
public Vector<TblATO_KPIDETAIL> getMemory(HashMap<String, String> params) {
TomcatCollFactory factory = new TomcatCollFactory();
ICollTomcat coll = factory.getCollInstance(params);
if (coll != null) {
return coll.getMemory(params);
}
return null;
}
public Vector<TblATO_KPIDETAIL> getRuntime(HashMap<String, String> params) {
TomcatCollFactory factory = new TomcatCollFactory();
ICollTomcat coll = factory.getCollInstance(params);
if (coll != null) {
return coll.getRuntime(params);
}
return null;
}
public Vector<TblATO_KPIDETAIL> getSession(HashMap<String, String> params) {
TomcatCollFactory factory = new TomcatCollFactory();
ICollTomcat coll = factory.getCollInstance(params);
if (coll != null) {
return coll.getSession(params);
}
return null;
}
public Vector<TblATO_KPIDETAIL> getThreadPool(HashMap<String, String> params) {
TomcatCollFactory factory = new TomcatCollFactory();
ICollTomcat coll = factory.getCollInstance(params);
if (coll != null) {
return coll.getThreadPool(params);
}
return null;
}
@Override
public Vector<TblATO_KPIDETAIL> getClassLoading(
HashMap<String, String> params) {
TomcatCollFactory factory = new TomcatCollFactory();
ICollTomcat coll = factory.getCollInstance(params);
if (coll != null) {
return coll.getClassLoading(params);
}
return null;
}
/**
* 获取中间件所在主机的ping状态。
* @param params
* @return
*/
@Override
public Vector<TblATO_KPIDETAIL> getPingStatus(HashMap<String, String> params) {
Vector<TblATO_KPIDETAIL> vector=new Vector<TblATO_KPIDETAIL>();
String jmx_url=params.get("JMX_URL");
int start=jmx_url.indexOf("/rmi://");
int end=jmx_url.lastIndexOf(":");
String ip=jmx_url.substring(start+7,end);
String domain_name = params.get("DOMAIN_NAME");
String unitId = "10-12-13-12:" + Formater.neatenunitid(domain_name) + "-MEMORY";
CheckConnectionState server=new CheckConnectionState();
TblATO_KPIDETAIL kpidetail=new TblATO_KPIDETAIL();
try {
kpidetail.setUNIT_ID(unitId);
kpidetail.setKPI_ID("FM-00-12-001-999");
kpidetail.setKPI_VALUE(server.getPingState(new ParamterBean(ip)));
kpidetail.setCLL_TIME(new Date());
vector.add(kpidetail);
} catch (ParseException e) {
e.printStackTrace();
}
return vector;
}
public static void main(String [] args){
String jmx_url="service:jmx:rmi:///jndi/rmi://172.21.1.100:1093/jmxrmi";
int start=jmx_url.indexOf("/rmi://");
int end=jmx_url.lastIndexOf(":");
String ip=jmx_url.substring(start+7,end);
System.out.println(ip);
}
@Override
public Vector<TblATO_KPIDETAIL> getThreading(HashMap<String, String> params) {
TomcatCollFactory factory = new TomcatCollFactory();
ICollTomcat coll = factory.getCollInstance(params);
if (coll != null) {
return coll.getThreading(params);
}
return null;
}
}