summaryrefslogtreecommitdiff
path: root/src/com/nis/nmsclient/thread/plugin/StartPluginRun.java
diff options
context:
space:
mode:
Diffstat (limited to 'src/com/nis/nmsclient/thread/plugin/StartPluginRun.java')
-rw-r--r--src/com/nis/nmsclient/thread/plugin/StartPluginRun.java191
1 files changed, 191 insertions, 0 deletions
diff --git a/src/com/nis/nmsclient/thread/plugin/StartPluginRun.java b/src/com/nis/nmsclient/thread/plugin/StartPluginRun.java
new file mode 100644
index 0000000..43ed9bc
--- /dev/null
+++ b/src/com/nis/nmsclient/thread/plugin/StartPluginRun.java
@@ -0,0 +1,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);
+ }
+ }
+ }
+
+}
generated by cgit v1.2.3 (git 2.39.1) at 2025-12-30 11:55:07 +0000