gfwleak/nms-nmsserver
Archived
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

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

Browse Source
This commit is contained in:
fangshunjian
2019-02-22 16:24:16 +08:00
parent 1eacc059de
commit bd3ab7b608
4 changed files with 130 additions and 176 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
.classpath
View File

@@ -1,7 +1,7 @@
<?xml version="1.0" encoding="UTF-8"?>
<classpath>
<classpathentry kind="src" path="src"/>
<classpathentry kind="con" path="org.eclipse.jdt.launching.JRE_CONTAINER/org.eclipse.jdt.internal.debug.ui.launcher.StandardVMType/jdk1.7.0_80"/>
<classpathentry kind="con" path="org.eclipse.jdt.launching.JRE_CONTAINER"/>
<classpathentry kind="lib" path="lib/commons-beanutils-1.7.jar"/>
<classpathentry kind="lib" path="lib/commons-collections.jar"/>
<classpathentry kind="lib" path="lib/commons-io.jar"/>

2
src/com/nms/server/common/Common.java
View File

@@ -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;
}

298
src/com/nms/server/snmp/trap/TrapServer.java
View File

@@ -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();
}

4
src/myconfig.properties
View File

@@ -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