1、修改 snmp trap告警功能，可以接收trap告警信息并页面显示

3 files changed, 129 insertions, 175 deletions

diff --git a/src/com/nms/server/common/Common.java b/src/com/nms/server/common/Common.java
index 5c533d5..f8b33e0 100644
--- a/src/com/nms/server/common/Common.java
+++ b/src/com/nms/server/common/Common.java
@@ -950,7 +950,7 @@ public class Common {
 		datas[5] = System.currentTimeMillis()+"";
 		datas[6] = level+"";
 		datas[7] = state+"";//正常、异常
-		datas[8] = exInfo==null?"":exInfo.length()>250?exInfo.substring(0, 250):exInfo;
+		datas[8] = exInfo==null?"":exInfo;
 		return datas;
 	}
 	
diff --git a/src/com/nms/server/snmp/trap/TrapServer.java b/src/com/nms/server/snmp/trap/TrapServer.java
index 25dbea8..856b091 100644
--- a/src/com/nms/server/snmp/trap/TrapServer.java
+++ b/src/com/nms/server/snmp/trap/TrapServer.java
@@ -1,12 +1,12 @@
 package com.nms.server.snmp.trap;
 
 import java.io.IOException;
-import java.util.HashMap;
 import java.util.Iterator;
-import java.util.Map;
 import java.util.Vector;
 
 import org.apache.log4j.Logger;
+import org.nutz.json.Json;
+import org.nutz.json.JsonFormat;
 import org.snmp4j.CommandResponder;
 import org.snmp4j.CommandResponderEvent;
 import org.snmp4j.MessageDispatcherImpl;
@@ -48,40 +48,43 @@ import com.nms.server.dao.CommonDao;
 import com.nms.server.service.CommonService;
 import com.nms.server.util.SNMP4JUtils;
 
-
 /**
  * 本类用于监听代理进程的Trap信息
  * 
  * @author YJS
  * 
  */
-public class TrapServer /**extends Service*/
-implements CommandResponder{// implements CommandResponder, extends Service
+public class TrapServer /** extends Service */
+		implements CommandResponder {// implements CommandResponder, extends
+										// Service
 	private static Logger logger = Logger.getLogger(TrapServer.class);
 	private static TrapServer ts = null;
-	public static TrapServer getInstance() throws IOException{
-		if(ts == null){
+
+	public static TrapServer getInstance() throws IOException {
+		if (ts == null) {
 			ts = new TrapServer();
 			logger.info("SNMP Trap Server 启动成功");
-		}else{
+		} else {
 			logger.info("SNMP TrapServer 已启动");
 		}
 		return ts;
 	}
-	
-	private TrapServer() throws IOException{
+
+	private TrapServer() throws IOException {
 		ThreadPool threadPool = ThreadPool.create("Trap", Constants.SNMP_TRAP_THREAD_POOL_SIZE);
-		MultiThreadedMessageDispatcher dispatcher = new MultiThreadedMessageDispatcher(threadPool,	new MessageDispatcherImpl());
-		Address listenAddress = GenericAddress.parse(System.getProperty("snmp4j.listenAddress", "udp:" + Common.getLocalIp() + "/" + Constants.SNMP_TRAP_PORT)); // 本地IP与监听端口
+		MultiThreadedMessageDispatcher dispatcher = new MultiThreadedMessageDispatcher(threadPool,
+				new MessageDispatcherImpl());
+		Address listenAddress = GenericAddress.parse(System.getProperty("snmp4j.listenAddress",
+				"udp:" + Common.getLocalIp() + "/" + Constants.SNMP_TRAP_PORT)); // 本地IP与监听端口
 		TransportMapping transport = null;
-		
-//	    			 对TCP与UDP协议进行处理
+
+		// 对TCP与UDP协议进行处理
 		if (listenAddress instanceof UdpAddress) {
 			transport = new DefaultUdpTransportMapping((UdpAddress) listenAddress);
 		} else {
 			transport = new DefaultTcpTransportMapping((TcpAddress) listenAddress);
 		}
-		
+
 		Snmp snmp = new Snmp(dispatcher, transport);
 		snmp.getMessageDispatcher().addMessageProcessingModel(new MPv1());
 		snmp.getMessageDispatcher().addMessageProcessingModel(new MPv2c());
@@ -90,56 +93,44 @@ implements CommandResponder{// implements CommandResponder, extends Service
 		SecurityModels.getInstance().addSecurityModel(usm);
 		snmp.listen();
 		snmp.addCommandResponder(this);
-//	    	        OID authProtocol = getAuthProtocol(Constants.SNMP_V3_AUTH_PROTOCOL);	//认证协议
-//	    	        OID privProtocol = getPrivProtocol(Constants.SNMP_V3_PRIV_PROTOCOL);	//加密协议
-//	    	        OctetString securityName = new OctetString(Constants.SNMP_V3_SECURITY_NAME);	//认证用户
-//	    	        OctetString authPassphrase = new OctetString(Constants.SNMP_V3_AUTH_PASSPHRASE);	//认证密码明文
-//	    	        OctetString privPassphrase = new OctetString(Constants.SNMP_V3_PRIV_PASSPHRASE);	//加密密码明文
-//	    	    	snmp.getUSM().addUser(securityName, new UsmUser(securityName, authProtocol, authPassphrase,privProtocol, privPassphrase));
 	}
-	 
-    private OID getAuthProtocol(String auth){
-    	if (auth.equals("MD5")) {
-  		 	return  AuthMD5.ID;
-        } else if (auth.equals("SHA")) {
-        	return  AuthSHA.ID;
-        }else{
-        	return null;
-        }
-    }
-    
-    private OID getPrivProtocol(String priv){
-        if (priv.equals("DES")) {
-      	  return PrivDES.ID;
-        } else if ((priv.equals("AES128"))
-                || (priv.equals("AES"))) {
-      	  return PrivAES128.ID;
-        } else if (priv.equals("AES192")) {
-      	  return PrivAES192.ID;
-        } else if (priv.equals("AES256")) {
-      	  return PrivAES256.ID;
-        }else{
-        	return null;
-        }
-    }
 
-	
-	
-	
+	private OID getAuthProtocol(String auth) {
+		if (auth.equals("MD5")) {
+			return AuthMD5.ID;
+		} else if (auth.equals("SHA")) {
+			return AuthSHA.ID;
+		} else {
+			return null;
+		}
+	}
+
+	private OID getPrivProtocol(String priv) {
+		if (priv.equals("DES")) {
+			return PrivDES.ID;
+		} else if ((priv.equals("AES128")) || (priv.equals("AES"))) {
+			return PrivAES128.ID;
+		} else if (priv.equals("AES192")) {
+			return PrivAES192.ID;
+		} else if (priv.equals("AES256")) {
+			return PrivAES256.ID;
+		} else {
+			return null;
+		}
+	}
+
 	/**
 	 * 实现CommandResponder的processPdu方法, 用于处理传入的请求、PDU等信息 当接收到trap时，会自动进入这个方法
 	 * 
 	 * @param respEvnt
 	 */
-	
-	public void processPdu(CommandResponderEvent commandresponderevent)
-	{
+
+	public void processPdu(CommandResponderEvent commandresponderevent) {
 		CommonDao dao = null;
-		try
-		{
+		try {
 			dao = new CommonDao();
 			logger.debug((new StringBuilder("接收到snmp event：")).append(commandresponderevent.getPDU()).toString());
-			UdpAddress udpaddress = (UdpAddress)commandresponderevent.getPeerAddress();
+			UdpAddress udpaddress = (UdpAddress) commandresponderevent.getPeerAddress();
 			String s = udpaddress.getInetAddress().getHostAddress();
 			PDU pdu = commandresponderevent.getPDU();
 			logger.debug((new StringBuilder("接收到TRap:")).append(pdu).toString());
@@ -148,9 +139,8 @@ implements CommandResponder{// implements CommandResponder, extends Service
 			setOIDList(trapmessageinfo, pdu);
 			setValueList(trapmessageinfo, pdu);
 			trapmessageinfo.setOriginalPDU(pdu);
-			if (pdu instanceof PDUv1)
-			{
-				PDUv1 pduv1 = (PDUv1)pdu;
+			if (pdu instanceof PDUv1) {
+				PDUv1 pduv1 = (PDUv1) pdu;
 				trapmessageinfo.setTrapVersion(1);
 				String s1 = pduv1.getEnterprise().toString();
 				trapmessageinfo.setTrapOID(s1);
@@ -159,154 +149,136 @@ implements CommandResponder{// implements CommandResponder, extends Service
 				trapmessageinfo.setTrapV1SpecificType(pduv1.getSpecificTrap());
 				trapmessageinfo.setTrapV1GenericType(pduv1.getGenericTrap());
 				trapmessageinfo.setTrapName(trapmessageinfo.getTrapOID());
-				switch (pduv1.getGenericTrap())
-				{
+				switch (pduv1.getGenericTrap()) {
 				case 0: // '\0'
-//					trapmessageinfo.setTrapName("设备冷启动");
-//					trapmessageinfo.setTrapName("Device Cold Start");
+					// trapmessageinfo.setTrapName("设备冷启动");
 					trapmessageinfo.setTrapName("i18n_server.UpgradeService.coldStart_n81i");
 					break;
-
 				case 1: // '\001'
-//					trapmessageinfo.setTrapName("设备热启动");
-//					trapmessageinfo.setTrapName("Device Hot Start");
+					// trapmessageinfo.setTrapName("设备热启动");
 					trapmessageinfo.setTrapName("i18n_server.UpgradeService.hotStart_n81i");
 					break;
-
 				case 2: // '\002'
-//					trapmessageinfo.setTrapName("接口关闭");
-//					trapmessageinfo.setTrapName("The Interface Is Closed");
+					// trapmessageinfo.setTrapName("接口关闭");
 					trapmessageinfo.setTrapName("i18n_server.UpgradeService.interClose_n81i");
 					break;
-
 				case 3: // '\003'
-//					trapmessageinfo.setTrapName("接口启用");
-//					trapmessageinfo.setTrapName("Interface Enabled");
+					// trapmessageinfo.setTrapName("接口启用");
 					trapmessageinfo.setTrapName("i18n_server.UpgradeService.interUsed_n81i");
 					break;
-
 				case 4: // '\004'
-//					trapmessageinfo.setTrapName("SNMP认证失败");
-//					trapmessageinfo.setTrapName("SNMP Authentication Failed");
+					// trapmessageinfo.setTrapName("SNMP认证失败");
 					trapmessageinfo.setTrapName("i18n_server.UpgradeService.snmp_n81i");
 					break;
-
 				case 5: // '\005'
-//					trapmessageinfo.setTrapName("EGP邻居丢失");
-//					trapmessageinfo.setTrapName("EGP Neighbor Lost");
+					// trapmessageinfo.setTrapName("EGP邻居丢失");
 					trapmessageinfo.setTrapName("i18n_server.UpgradeService.egp_n81i");
 					break;
 				}
-			} else
-			{
+			} else {
 				trapmessageinfo.setTrapVersion(2);
 				Variable variable = trapmessageinfo.getOIDValue(SnmpConstants.snmpTrapAddress.toString());
-				logger.debug("pdu.snmpTrapAddress() =-=-= "+variable);
-				if (variable != null)
+				logger.debug("pdu.snmpTrapAddress() =-=-= " + variable);
+				if (variable != null) {
 					trapmessageinfo.setPduAgentIP(variable.toString());
+				}
 				Variable variable1 = trapmessageinfo.getOIDValue(SnmpConstants.snmpTrapOID.toString());
-				if (variable1 != null)
+				if (variable1 != null) {
 					trapmessageinfo.setTrapOID(variable1.toString());
+				}
 				trapmessageinfo.setTrapName(trapmessageinfo.getTrapOID());
-				if (variable1 != null)
-					if (variable1.equals(SnmpConstants.coldStart))
-//						trapmessageinfo.setTrapName("设备冷启动");
-//						trapmessageinfo.setTrapName("Device Cold Start");
+				if (variable1 != null){
+					if (variable1.equals(SnmpConstants.coldStart)) {
+						// trapmessageinfo.setTrapName("设备冷启动");
 						trapmessageinfo.setTrapName("i18n_server.UpgradeService.coldStart_n81i");
-					else
-					if (variable1.equals(SnmpConstants.warmStart))
-//						trapmessageinfo.setTrapName("设备热启动");
+					} else if (variable1.equals(SnmpConstants.warmStart)) {
+						// trapmessageinfo.setTrapName("设备热启动");
 						trapmessageinfo.setTrapName("i18n_server.UpgradeService.hotStart_n81i");
-					else
-					if (variable1.equals(SnmpConstants.linkDown))
-//						trapmessageinfo.setTrapName("接口关闭");
-//						trapmessageinfo.setTrapName("The Interface Is Closed");
+					} else if (variable1.equals(SnmpConstants.linkDown)) {
+						// trapmessageinfo.setTrapName("接口关闭");
 						trapmessageinfo.setTrapName("i18n_server.UpgradeService.interClose_n81i");
-					else
-					if (variable1.equals(SnmpConstants.linkUp))
-//						trapmessageinfo.setTrapName("接口启用");
-//						trapmessageinfo.setTrapName("Interface Enabled");
+					} else if (variable1.equals(SnmpConstants.linkUp)) {
+						// trapmessageinfo.setTrapName("接口启用");
 						trapmessageinfo.setTrapName("i18n_server.UpgradeService.interUsed_n81i");
-					else
-					if (variable1.equals(SnmpConstants.authenticationFailure))
-//						trapmessageinfo.setTrapName("SNMP认证失败");
-//						trapmessageinfo.setTrapName("SNMP Authentication Failed");
+					} else if (variable1.equals(SnmpConstants.authenticationFailure)) {
+						// trapmessageinfo.setTrapName("SNMP认证失败");
 						trapmessageinfo.setTrapName("i18n_server.UpgradeService.snmp_n81i");
-					else //系统默认的类别不能匹配时，再使用自定义的trap信息库。是否需要分别自定义snmpV1和snmpValue2的trap信息库（定义到文件或者定义到数据库，必须体统重新加载的界面接口）
-					if(getTrapName(variable1)!=null &&!variable1.equals("")){
+					} else if (getTrapName(variable1) != null && !variable1.equals("")) {
+						// 系统默认的类别不能匹配时，再使用自定义的trap信息库。是否需要分别自定义snmpV1和snmpValue2的trap信息库（定义到文件或者定义到数据库，必须体统重新加载的界面接口）
 						trapmessageinfo.setTrapName(getTrapName(variable1));
-					}else{
-//						throw new Exception("未被定义的SNMPTRAP类型！");
+					} else {
 						throw new Exception("Undefined SNMPTRAP type!");
 					}
+				}
 			}
 			StringBuffer trapInfo = new StringBuffer();
-			trapInfo.append("trapmessageinfo.getTrapName()："+trapmessageinfo.getTrapName());
-			trapInfo.append("；trapmessageinfo.getAgentSendIP()："+trapmessageinfo.getAgentSendIP());
-			trapInfo.append("；trapmessageinfo.getOriginalPDU()："+trapmessageinfo.getOriginalPDU());
-			trapInfo.append("；trapmessageinfo.getTrapVersion()："+trapmessageinfo.getTrapVersion());
-			trapInfo.append("；trapmessageinfo.getTrapOID()："+trapmessageinfo.getTrapOID());
-			trapInfo.append("；trapmessageinfo.getPduAgentIP()："+trapmessageinfo.getPduAgentIP());
-			trapInfo.append("；trapmessageinfo.getTrapV1GenericType()："+trapmessageinfo.getTrapV1GenericType());
-			trapInfo.append("；trapmessageinfo.getTrapV1SpecificType()："+trapmessageinfo.getTrapV1SpecificType());
-			logger.debug("agent IP："+s+"  trap信息："+trapInfo.toString());
-			new CommonService(dao).newClientCheck(s,trapmessageinfo.getTrapVersion());
+			if(!trapmessageinfo.getTrapName().equals(trapmessageinfo.getTrapOID())){
+				trapInfo.append("TrapName：" + trapmessageinfo.getTrapName());
+				trapInfo.append(Constants.COMMON_DATA_POINT);
+			}
+			trapInfo.append(" AgentSendIP：" + trapmessageinfo.getAgentSendIP());
+			trapInfo.append(Constants.COMMON_DATA_POINT);
+			trapInfo.append(" OriginalPDU：" + trapmessageinfo.getOriginalPDU());
+			trapInfo.append(Constants.COMMON_DATA_POINT);
+			trapInfo.append(" TrapVersion：" + trapmessageinfo.getTrapVersion());
+			trapInfo.append(Constants.COMMON_DATA_POINT);
+			trapInfo.append(" TrapOID：" + trapmessageinfo.getTrapOID());
+			trapInfo.append(Constants.COMMON_DATA_POINT);
+			trapInfo.append(" PduAgentIP：" + trapmessageinfo.getPduAgentIP());
+			trapInfo.append(Constants.COMMON_DATA_POINT);
+			trapInfo.append(" TrapV1GenericType：" + trapmessageinfo.getTrapV1GenericType());
+			trapInfo.append(Constants.COMMON_DATA_POINT);
+			trapInfo.append(" TrapV1SpecificType：" + trapmessageinfo.getTrapV1SpecificType());
+			logger.debug("agent IP：" + s + "  trap信息：" + trapInfo.toString());
+			new CommonService(dao).newClientCheck(s, trapmessageinfo.getTrapVersion());
 			SetInfo info = Common.getSnmpTrapSetInfo();
-			String [] dsb = Common.alarmExceptionInfo(info.getId(), s, info.getCheckTypeName(), info.getProcessIden(), trapmessageinfo.getReceiverTime().getTime(), 1,Constants.DETECTION_INFO_ALARM_WRONG, trapInfo.toString());
+			logger.debug(String.format("snmp setInfo : %s", Json.toJson(info, JsonFormat.tidy())));
+			//snmp trap 默认告警级别为：0紧急
+			String[] dsb = Common.alarmExceptionInfo(info.getId(), s, info.getCheckTypeName(), info.getProcessIden(),
+					trapmessageinfo.getReceiverTime().getTime(), 0, Constants.DETECTION_INFO_ALARM_WRONG,
+					trapInfo.toString());
 			Common.addAlarmData(dsb);
-			
-		}
-		catch (Exception exception)
-		{
-			logger.debug((new StringBuilder("解析UDP TRAP发生错误:")).append(exception.getMessage()).toString());
-		}finally{
-			if(dao!=null){
+
+		} catch (Exception e) {
+			logger.error("解析UDP TRAP发生错误:", e);
+		} finally {
+			if (dao != null) {
 				dao.close();
-				dao=null;
+				dao = null;
 			}
 		}
 	}
-	
-	public String getTrapName(Variable variable1){
-		String trapName = "";
-		Map allTrapTypeDefine = new HashMap();
-		trapName = allTrapTypeDefine.get(variable1.toString()).toString();
-		return trapName;
+
+	public String getTrapName(Variable variable1) {
+		return variable1.toString();
 	}
-	
-	void setOIDList(TrapMessageInfo trapmessageinfo, PDU pdu)
-	{
+
+	void setOIDList(TrapMessageInfo trapmessageinfo, PDU pdu) {
 		Vector vector = pdu.getVariableBindings();
 		String s;
-//		for(int i=0;i<vector.size();i++){
-//			VariableBinding vbing = (VariableBinding)vector.elementAt(i);
-//			s = vbing.getOid().toString();
-//			trapmessageinfo.getTrapPDUOIDs().add(s);
-//		}
-		for (Iterator iterator = vector.iterator(); iterator.hasNext(); trapmessageinfo.getTrapPDUOIDs().add(s))
-		{
-			VariableBinding variablebinding = (VariableBinding)iterator.next();
+		// for(int i=0;i<vector.size();i++){
+		// VariableBinding vbing = (VariableBinding)vector.elementAt(i);
+		// s = vbing.getOid().toString();
+		// trapmessageinfo.getTrapPDUOIDs().add(s);
+		// }
+		for (Iterator iterator = vector.iterator(); iterator.hasNext(); trapmessageinfo.getTrapPDUOIDs().add(s)) {
+			VariableBinding variablebinding = (VariableBinding) iterator.next();
 			s = variablebinding.getOid().toString();
 		}
 
 	}
 
-	void setValueList(TrapMessageInfo trapmessageinfo, PDU pdu)
-	{
+	void setValueList(TrapMessageInfo trapmessageinfo, PDU pdu) {
 		Vector vector = pdu.getVariableBindings();
 		Variable variable;
-		for (Iterator iterator = vector.iterator(); iterator.hasNext(); trapmessageinfo.getTrapPDUOIDValues().add(variable))
-		{
-			VariableBinding variablebinding = (VariableBinding)iterator.next();
+		for (Iterator iterator = vector.iterator(); iterator.hasNext(); trapmessageinfo.getTrapPDUOIDValues()
+				.add(variable)) {
+			VariableBinding variablebinding = (VariableBinding) iterator.next();
 			variable = variablebinding.getVariable();
 		}
 
 	}
-	
-/*	public static void main(String[] args) {
-		TrapServer multithreadedtrapreceiver = new TrapServer();
-		multithreadedtrapreceiver.run();
-	}*/
+
 
 	/** */
 	/**
@@ -325,22 +297,6 @@ implements CommandResponder{// implements CommandResponder, extends Service
 		}
 	}
 
-	/** 
-	 * 将十进六制转换成为中文 
-	 *//*
-	private static String hexString = "0123456789ABCDEF";
-
-	public static String toStringHex(String bytes) {
-
-		ByteArrayOutputStream baos = new ByteArrayOutputStream(
-				bytes.length() / 2);
-		//将每2位16进制整数组装成一个字节 
-		for (int i = 0; i < bytes.length(); i += 2) {
-			baos.write((hexString.indexOf(bytes.charAt(i)) << 4 | hexString
-					.indexOf(bytes.charAt(i + 1))));
-		}
-		return new String(baos.toByteArray());
-	}*/
 
 	protected static String printVariableBindings(PDU response) {
 		String strCom = "";
@@ -356,18 +312,16 @@ implements CommandResponder{// implements CommandResponder, extends Service
 			}
 			strCom += vb.getVariable();
 			if (str.length != 1) {
-				logger.debug("==第行=vb.getVariable()=" + SNMP4JUtils.toStringHex(strOut));//显示中文 
+				logger.debug("==第行=vb.getVariable()=" + SNMP4JUtils.toStringHex(strOut));// 显示中文
 			}
 		}
 		return strCom;
 
 	}
-	public static void  main(String [] args) {
+
+	public static void main(String[] args) {
 		try {
 			TrapServer.getInstance();
-			TrapServer.getInstance();
-			TrapServer.getInstance();
-			
 		} catch (IOException e) {
 			e.printStackTrace();
 		}
diff --git a/src/myconfig.properties b/src/myconfig.properties
index 4b2fdd1..d1721c5 100644
--- a/src/myconfig.properties
+++ b/src/myconfig.properties
@@ -2,7 +2,7 @@
 ##--公共数据存放父目录（*部署需修改*）
 common.datas.dir = D:/nms/nmsdata
 ##--系统SNMP监测，指定服务器IP 指本机（*部署需修改*）
-system.inet.address = 127.0.0.1
+system.inet.address = 192.168.11.229
 ##--NMSWeb端 通讯IP  指WEB（*部署需修改*）
 web.socket.ip = 10.0.6.114
 #--数据库驱动
@@ -10,7 +10,7 @@ web.socket.ip = 10.0.6.114
 db.driver=com.mysql.jdbc.Driver
 ##--数据库 地址（*部署需修改*）
 #db.url = jdbc:oracle:thin:@10.0.6.100:1521:ict
-db.url = jdbc:mysql://localhost:3306/nms?useUnicode=true&characterEncoding=utf-8&useOldAliasMetadataBehavior=true&rewriteBatchedStatements=true
+db.url = jdbc:mysql://192.168.10.182:3306/nms?useUnicode=true&characterEncoding=utf-8&useOldAliasMetadataBehavior=true&rewriteBatchedStatements=true
 ##--数据库 用户名（*部署需修改*）
 #db.username = nms
 db.username = nms