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
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
|
package com.nis.nmsclient.thread.plugin;
import java.util.Date;
import java.util.concurrent.ScheduledFuture;
import java.util.concurrent.TimeUnit;
import org.apache.commons.lang.StringUtils;
import org.apache.log4j.Logger;
import com.nis.nmsclient.common.Common;
import com.nis.nmsclient.common.Contants;
import com.nis.nmsclient.config.DetecConfOper;
import com.nis.nmsclient.model.SetInfo;
import com.nis.nmsclient.thread.alarm.AlarmUtil;
import com.nis.nmsclient.util.ProcessUtil;
import com.nis.systeminfo.thread.NewPluginResultMerge;
public class StartPluginRun implements Runnable {
static Logger logger = Logger.getLogger(StartPluginRun.class);
private String name;
private SetInfo setInfo;
public StartPluginRun(SetInfo setInfo, String name) {
this.name = name;
this.setInfo = setInfo;
}
public void run() {
Thread.currentThread().setName(name);
logger.info("启动第三方插件程序开始！");
if ("1".equals(setInfo.getCheckState())
&& "1".equals(setInfo.getCheckWay())
&& "1,2".contains(setInfo.getIsControlStart())) {// 有效,被动方式获取,Agent端启动
Date startTime = null;
if (setInfo.getControlStartTime() != null && setInfo.getControlStartTime().longValue() != 0) {
startTime = new Date(setInfo.getControlStartTime());
} else {
startTime = new Date();
}
/*
* 停止未启动的定时任务/周期任务
*/
Common.stopPluginDetecFuture(setInfo.getId(), Thread.currentThread().getName());
/*
* 首先看进程设置的启动时间是否过时：如果过时，则查看进程是否存在，不存在启动；如果未过时，则定时启动
*/
String cmd = DetecConfOper.getProcess(setInfo);
try {
/**
* 进程存在与否的判断标准：
* 1、先检查PID文件，取出PID，验证PID指定进程是否存在
* PID文件不存在，或者PID文件中内容为空，或者取出的PID进程不存在，都认为不存在，进行下一步检查
* 2、不存在再使用搜索关键字查找进程
* 若未找出进程，不存在，若找出一个进程，正常存在，若找出多个进程，报警
*/
Object[] objArr = ProcessUtil.checkPidAndGetPid(setInfo.getProcessFile(), setInfo.getProcessSearchKeyCode());
int isExistFlag = Integer.parseInt(objArr[0].toString());
String pidInfo = objArr[1].toString();
if (isExistFlag == 0 || isExistFlag == 1) { // 进程不存在/存在一个进程
if (isExistFlag == 1) {// 存在一个进程
logger.info("三方监测进程”" + cmd + "“已存在，重启启动");
ProcessUtil.killProcess(pidInfo);
}
long delay = startTime.getTime() - System.currentTimeMillis();
delay = Math.max(delay, 0);
ScheduledFuture<?> future = null;
if ("1".equals(setInfo.getIsControlStart())) {
future = Common.scheduled.schedule(new ExecProcess(), delay, TimeUnit.MILLISECONDS);
} else if ("2".equals(setInfo.getIsControlStart())) {
long period = setInfo.getCheckGap() * 60 * 1000;
future = Common.scheduled.scheduleAtFixedRate(new ExecProcess2(), delay, period, TimeUnit.MILLISECONDS);
}
Common.putPluginDetecFuture(setInfo.getId(), future);
logger.info("三方监测程序已加入定时器定时启动");
} else { // 找到多个进程，告警
// String alarmMsg = "启动三方监测：" + pidInfo;
String alarmMsg = "i18n_client.StartPluginRun.startupDetecate_n81i：" + pidInfo;
AlarmUtil.sendAlarmMsg(setInfo.getId(), setInfo
.getCheckTypeName(), setInfo.getProcessIden(),
new Date(), new Date(), 1,
Contants.DETECTION_STATUS_FAILURE, alarmMsg);
}
} catch (Exception e) {
logger.error("Start the three party monitoring exception. Please check whether the process execution file and the PID file are set correctly：" + cmd, e);
}
}
logger.info("启动第三方插件程序结束！");
}// run end
class ExecProcess implements Runnable {
public void run() {
Thread.currentThread().setName(name);
String cmd = DetecConfOper.getProcess(setInfo);
try {
// 启动
ProcessUtil.runExec(cmd, null, null, null);
// 检查PID
Object[] objArr = ProcessUtil.checkPidAndGetPid(setInfo.getProcessFile(), setInfo.getProcessSearchKeyCode());
int isExistFlag = Integer.parseInt(objArr[0].toString());
String pidInfo = objArr[1].toString();
if (isExistFlag == 1) {// 存在, 一个进程
logger.info("三方监测程序“" + cmd + "“启动成功");
} else { // 进程不存在 或 找到多个进程，告警
String alarmMsg = null;
if (isExistFlag == 0) {// 进程不存在
// alarmMsg = "三方监测程序启动失败，请检查进程启动文件“" + cmd + "”是否设置正确";
alarmMsg = "i18n_client.StartPluginRun.startupDetecateErr1_n81i “" + cmd + "” i18n_client.StartPluginRun.startupDetecateErr1.isTrue_n81i";
} else {// 找到多个进程
// alarmMsg = "启动三方监测：" + pidInfo;
alarmMsg = "i18n_client.StartPluginRun.startupDetecate_n81i：" + pidInfo;
}
AlarmUtil.sendAlarmMsg(setInfo.getId(), setInfo
.getCheckTypeName(), setInfo.getProcessIden(),
new Date(), new Date(), 1,
Contants.DETECTION_STATUS_FAILURE, alarmMsg);
}
} catch (Exception e) {
logger.error("Start the three party monitoring exception. Please check whether the process execution file and the PID file are set correctly：" + cmd, e);
}
}
}
class ExecProcess2 implements Runnable {
public void run() {
Thread.currentThread().setName(name);
// 三方监测脚本执行命令不存在，获取脚本命令及关键词
// 因脚本下发与配置下发不同步，需要在执行任务中多次获取执行命令
String cmd = Common.generateCommandAndKeyword(setInfo);
try {
boolean executeStatus = true;
// 脚本执行前，清理临时数据目录
new NewPluginResultMerge().clearTmpFile(setInfo);
if (StringUtils.isBlank(cmd)) {
// 三方监测脚本执行命令不存在，当前时间NC上无监测脚本
logger.info("三方监测程序启动失败，监测脚本下发未完成！");
// String alarmMsg = "启动三方监测异常,监测脚本下发未完成！";
String alarmMsg = "i18n_client.StartPluginRun.startupDetecateErr2_n81i";
AlarmUtil.sendAlarmMsg(setInfo.getId(),
setInfo.getCheckTypeName(),
setInfo.getProcessIden(), new Date(), new Date(),
1, Contants.DETECTION_STATUS_FAILURE, alarmMsg);
executeStatus = false;
} else {
// 启动脚本
String msg = ProcessUtil.runExec(cmd, null, null, null);
if (StringUtils.isBlank(msg)) { // 执行成功
logger.info("三方监测程序“" + cmd + "”执行成功");
} else { // 执行失败，返回错误信息
logger.error("Three party monitoring procedure“" + cmd + "”erroneous execution：" + msg);
// String alarmMsg = "启动三方监测异常,监测脚本执行错误！";
String alarmMsg = "i18n_client.StartPluginRun.startupDetecateErr3_n81i";
AlarmUtil.sendAlarmMsg(setInfo.getId(),
setInfo.getCheckTypeName(),
setInfo.getProcessIden(), new Date(),
new Date(), 1,
Contants.DETECTION_STATUS_FAILURE, alarmMsg);
executeStatus = false;
}
}
// 针对执行合并临时文件（ProcessUtil.runExec为同步执行，合并临时文件前已完成脚本执行过程）
if(executeStatus) {
new NewPluginResultMerge().merge(setInfo);
}
} catch (Exception e) {
logger.error("Start the three party monitoring exception. Please check whether the process execution file and the PID file are set correctly：" + cmd, e);
}
}
}
}
|
