Java程序实现监听VMware的SNMP服务发出的告警信息

以下可以应用于&＃xff1a;Linux、Windows、Mac系统。

我因为网上的文章走了很多弯路&＃xff0c;这里如果只是做监听&＃xff0c;不需要开启SNMP服务&＃xff0c;只需要看下面的代码即可&＃xff0c;如果是发出告警是需要开启SNMP服务的。

实现时有以下几个问题需要注意&＃xff1a;

1.VMware中配置的SNMP接收方IP和端口&＃xff0c;这里的IP是你程序所在服务器的IP&＃xff0c;端口一般是162。

  注意&＃xff1a;要遵循1024 以下的端口要用root启动&＃xff0c;这个是windows、Linux、mac通用原则

2.如果本地只是监听消息&＃xff0c;不发出消息的话&＃xff0c;本地不需要开启SNMP服务。

3.SNMP发出的消息都是通过MIB文件来翻译的&＃xff0c;根据OID号来找到对应的消息&＃xff0c;即可得到想要的消息&＃xff0c;MIB文件也不需要导入到程序中&＃xff0c;只需要做对应即可。

在pom.xml文件中引入snmp4j包&＃xff0c;如下

org.snmp4jsnmp4j2.8.2

以下是代码实现&＃xff1a;

import java.io.IOException;
import com.alibaba.fastjson.JSON;
import com.fit2cloud.commons.utils.LogUtil;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.snmp4j.CommandResponder;
import org.snmp4j.CommandResponderEvent;
import org.snmp4j.MessageDispatcher;
import org.snmp4j.MessageDispatcherImpl;
import org.snmp4j.PDU;
import org.snmp4j.Snmp;
import org.snmp4j.TransportMapping;
import org.snmp4j.mp.MPv1;
import org.snmp4j.mp.MPv2c;
import org.snmp4j.mp.MPv3;
import org.snmp4j.security.AuthSHA;
import org.snmp4j.security.PrivAES128;
import org.snmp4j.security.SecurityProtocols;
import org.snmp4j.security.USM;
import org.snmp4j.security.UsmUser;
import org.snmp4j.smi.GenericAddress;
import org.snmp4j.smi.OctetString;
import org.snmp4j.smi.UdpAddress;
import org.snmp4j.transport.DefaultUdpTransportMapping;
import org.snmp4j.util.MultiThreadedMessageDispatcher;
import org.snmp4j.util.ThreadPool;public class SnmpTrapHandler implements CommandResponder{private static Logger log &＃61; LoggerFactory.getLogger(SnmpTrapHandler.class);private static int threadNum &＃61; 200;//这里的ip是指程序所在IP&＃xff0c;这里是&＃xff1a;192.168.0.1//1162指的是端口号&＃xff0c;因为162需要root权限&＃xff0c;所以测试的时候我用1162端口&＃xff0c;需要两边的IP和端口保持一致private static String ipAddress &＃61; "udp:192.168.0.1/1162";private Snmp snmp &＃61; null;public void init(){//1、初始化多线程消息转发类ThreadPool threadPool &＃61; ThreadPool.create("SnmpTrap", threadNum);MessageDispatcher messageDispatcher &＃61; new MultiThreadedMessageDispatcher(threadPool, new MessageDispatcherImpl());//其中要增加三种处理模型。如果snmp初始化使用的是Snmp(TransportMapping transportMapping) ,就不需要增加messageDispatcher.addMessageProcessingModel(new MPv1());messageDispatcher.addMessageProcessingModel(new MPv2c());OctetString localEngineID &＃61; new OctetString(MPv3.createLocalEngineID());USM usm &＃61; new USM(SecurityProtocols.getInstance().addDefaultProtocols(), localEngineID, 0);UsmUser user &＃61; new UsmUser(new OctetString("SNMPV3"), AuthSHA.ID, new OctetString("authPassword"),PrivAES128.ID, new OctetString("privPassword"));usm.addUser(user.getSecurityName(), user);messageDispatcher.addMessageProcessingModel(new MPv3(usm));//2、创建transportMappingTransportMapping transportMapping &＃61; null;try {UdpAddress updAddr &＃61; (UdpAddress) GenericAddress.parse(System.getProperty("snmp4j.listenAddress", ipAddress));transportMapping &＃61; new DefaultUdpTransportMapping(updAddr);//3、正式创建snmpsnmp &＃61; new Snmp(messageDispatcher, transportMapping);//开启监听snmp.listen();} catch (IOException e) {log.error("初始化transportMapping失败&＃xff1a;", e.getMessage());e.printStackTrace();}}public void start() {init();//一定要将当前对象添加至commandResponderListeners中snmp.addCommandResponder(this);System.out.println("开始监听trap信息&＃xff1a;");}/*** 处理信息方法*/&＃64;Overridepublic void processPdu(CommandResponderEvent event) {String version &＃61; null ;String community &＃61; null;LogUtil.info("接收到的告警信息&＃xff1a;"&＃43; JSON.toJSONString(event));if (event.getPDU().getType() &＃61;&＃61; PDU.V1TRAP) {version &＃61; "v1";community &＃61; new String(event.getSecurityName());} else if (event.getPDU().getType() &＃61;&＃61; PDU.TRAP){if (event.getSecurityModel() &＃61;&＃61; 2) {version &＃61; "v2";community &＃61; new String(event.getSecurityName());}else {version &＃61; "v3";}}System.out.println("接收到的trap信息&＃xff1a;[发送来源&＃61;"&＃43;event.getPeerAddress()&＃43;",snmp版本&＃61;"&＃43;version&＃43;",团体名&＃61;"&＃43;community&＃43;", 携带的变量&＃61;"&＃43;event.getPDU().getVariableBindings()&＃43;"]");}public static void main(String[] args) {SnmpTrapHandler handler &＃61; new SnmpTrapHandler();handler.start();}
}