guizhou-monitorV2.0.1 / agent · Commits

Go to a project

Authored by zhangmingm
Commit 7a2811ce0b18946e14efd37d14910faed197277d 1 parent 3b74fb10

添加日志信息。

Inline Side-by-side
Showing 1 changed file with 23 additions and 20 deletions
1 package com.sitech.jmx; 1 package com.sitech.jmx;
2 2
3 -import javax.management.MBeanServer;  
4 -import javax.management.MBeanServerFactory;  
5 -  
6 -import com.sitech.jmx.adaptor.RmiAdaptor;  
7 -import com.sitech.jmx.manage.*;  
8 -import com.sitech.util.mq.TunnelFactory;  
9 -import org.apache.log4j.Logger;  
10 -  
11 import com.sitech.base.ACommonThread; 3 import com.sitech.base.ACommonThread;
12 import com.sitech.base.AgentProperties; 4 import com.sitech.base.AgentProperties;
13 import com.sitech.base.Config; 5 import com.sitech.base.Config;
14 import com.sitech.database.dao.TbCfgEventDao; 6 import com.sitech.database.dao.TbCfgEventDao;
15 import com.sitech.ismp.messageObject.AgentSyncRequest; 7 import com.sitech.ismp.messageObject.AgentSyncRequest;
16 import com.sitech.jmx.adaptor.JmsAdaptor; 8 import com.sitech.jmx.adaptor.JmsAdaptor;
  9 +import com.sitech.jmx.adaptor.RmiAdaptor;
  10 +import com.sitech.jmx.manage.CollScheduleManager;
  11 +import com.sitech.jmx.manage.CronLogScan;
  12 +import com.sitech.jmx.manage.MBeanManager;
  13 +import com.sitech.jmx.manage.MessageSenderManager;
  14 +import com.sitech.jmx.manage.SwapMonitorThread;
17 import com.sitech.util.mq.MQConstants; 15 import com.sitech.util.mq.MQConstants;
18 -import com.sitech.util.mq.MQSender;  
19 -import com.sitech.util.mq.MQSenderFactory; 16 +import com.sitech.util.mq.TunnelFactory;
  17 +import org.apache.log4j.Logger;
  18 +
  19 +import javax.management.MBeanServer;
  20 +import javax.management.MBeanServerFactory;
20 21
21 public class MasterAgent extends ACommonThread { 22 public class MasterAgent extends ACommonThread {
22 private static Logger logger = Logger.getLogger("LOGER"); 23 private static Logger logger = Logger.getLogger("LOGER");
23 private static Logger error = Logger.getLogger("ERROR"); 24 private static Logger error = Logger.getLogger("ERROR");
  25 + private static Logger log = Logger.getLogger(MasterAgent.class);
24 private MBeanServer server; 26 private MBeanServer server;
25 27
26 public MasterAgent() { 28 public MasterAgent() {
@@ -41,13 +43,14 @@ public class MasterAgent extends ACommonThread { @@ -41,13 +43,14 @@ public class MasterAgent extends ACommonThread {
41 * 启动MBeanServer 43 * 启动MBeanServer
42 */ 44 */
43 private void createMBS() { 45 private void createMBS() {
  46 + log.info("MBeanServer create .....");
44 try { 47 try {
45 server = MBeanServerFactory.createMBeanServer(AgentProperties.MBEAN_SERVER_DOMAIN); 48 server = MBeanServerFactory.createMBeanServer(AgentProperties.MBEAN_SERVER_DOMAIN);
46 MBeanManager manager = MBeanManager.getInstance(); 49 MBeanManager manager = MBeanManager.getInstance();
47 manager.setMBeanServer(server); 50 manager.setMBeanServer(server);
48 - logger.info("MBeanServer create successful."); 51 + log.info("MBeanServer create successful.");
49 } catch (Exception e) { 52 } catch (Exception e) {
50 - logger.error("MBeanServer instance creation failed.", e); 53 + log.error("MBeanServer instance creation failed.", e);
51 } 54 }
52 } 55 }
53 56
@@ -59,9 +62,9 @@ public class MasterAgent extends ACommonThread { @@ -59,9 +62,9 @@ public class MasterAgent extends ACommonThread {
59 CollScheduleManager collschedule = CollScheduleManager.getInstance(); 62 CollScheduleManager collschedule = CollScheduleManager.getInstance();
60 collschedule.setMBeanServer(server); 63 collschedule.setMBeanServer(server);
61 collschedule.startSchedule(); 64 collschedule.startSchedule();
62 - logger.info("Start quartz scheduler successful."); 65 + log.info("Start quartz scheduler successful.");
63 } catch (Exception e) { 66 } catch (Exception e) {
64 - error.error("Exception while start quartz scheduler.", e); 67 + log.error("Exception while start quartz scheduler.", e);
65 } 68 }
66 } 69 }
67 70
@@ -70,22 +73,22 @@ public class MasterAgent extends ACommonThread { @@ -70,22 +73,22 @@ public class MasterAgent extends ACommonThread {
70 * 2012-12-20 改为MQ 73 * 2012-12-20 改为MQ
71 */ 74 */
72 private void registAdapter() { 75 private void registAdapter() {
73 - logger.info("Start MQ adapter..."); 76 + log.info("Start MQ adapter...");
74 String url = Config.WORKSTAITON_CONN_URL; 77 String url = Config.WORKSTAITON_CONN_URL;
75 String queue = "Q_AGENT_" + AgentProperties.AGENT_ID; 78 String queue = "Q_AGENT_" + AgentProperties.AGENT_ID;
76 JmsAdaptor jmsAdaptor = new JmsAdaptor(url, queue); 79 JmsAdaptor jmsAdaptor = new JmsAdaptor(url, queue);
77 jmsAdaptor.start(); 80 jmsAdaptor.start();
78 RmiAdaptor.getInstance().regist(server); 81 RmiAdaptor.getInstance().regist(server);
79 - logger.info("Start MQ adapter ok..."); 82 + log.info("Start MQ adapter ok...");
80 } 83 }
81 84
82 /**s 85 /**s
83 * 启动指标数据和告警数据发送服务 86 * 启动指标数据和告警数据发送服务
84 */ 87 */
85 private void startJmsSender() { 88 private void startJmsSender() {
86 - logger.info("Start all jms sender."); 89 + log.info("Start all jms sender.");
87 new MessageSenderManager().startAllMessageSender(); 90 new MessageSenderManager().startAllMessageSender();
88 - logger.info("Start all jms sender ok."); 91 + log.info("Start all jms sender ok.");
89 } 92 }
90 93
91 /** 94 /**
@@ -94,7 +97,7 @@ public class MasterAgent extends ACommonThread { @@ -94,7 +97,7 @@ public class MasterAgent extends ACommonThread {
94 private void startSwapMonitorThread() { 97 private void startSwapMonitorThread() {
95 SwapMonitorThread swapMonitorThread = new SwapMonitorThread(); 98 SwapMonitorThread swapMonitorThread = new SwapMonitorThread();
96 swapMonitorThread.start(); 99 swapMonitorThread.start();
97 - logger.info("Start swap path monitor thread successful."); 100 + log.info("Start swap path monitor thread successful.");
98 } 101 }
99 102
100 /** 103 /**
@@ -118,7 +121,7 @@ public class MasterAgent extends ACommonThread { @@ -118,7 +121,7 @@ public class MasterAgent extends ACommonThread {
118 // Config.WORKSTAITON_CONN_URL, MQConstants.Q_ROPORT_FROM_AGENT); 121 // Config.WORKSTAITON_CONN_URL, MQConstants.Q_ROPORT_FROM_AGENT);
119 // mqSender.writeData(request); 122 // mqSender.writeData(request);
120 // mqSender.start(); 123 // mqSender.start();
121 - logger.info("Send sync request."); 124 + log.info("Send sync request.");
122 } 125 }
123 126
124 public static void main(String[] args) { 127 public static void main(String[] args) {