zwsolive的ChinaUnix博客
zwsolive
全部博文(16)
2012年(16)
zhengdon
zjc06181
benbenai
分类:
2012-03-04 10:57:22
原文地址:关于一个snmp的具体程序-9k 作者:zhengdong1987
import java.io.IOException; import java.net.InetAddress; import java.net.SocketException; import java.net.SocketTimeoutException; import org.snmp4j.CommunityTarget; import org.snmp4j.PDU; import org.snmp4j.Snmp; import org.snmp4j.event.ResponseEvent; import org.snmp4j.log.LogAdapter; import org.snmp4j.log.LogFactory; import org.snmp4j.mp.SnmpConstants; import org.snmp4j.smi.Address; import org.snmp4j.smi.GenericAddress; import org.snmp4j.smi.OID; import org.snmp4j.smi.OctetString; import org.snmp4j.smi.VariableBinding; import org.snmp4j.transport.DefaultUdpTransportMapping; import snmp.SNMPObject; import snmp.SNMPSequence; import snmp.SNMPVarBindList; import snmp.SNMPv1CommunicationInterface; /** * SNMP管理类 */ public class SnmpManager { private static final LogAdapter log = LogFactory.getLogger(SnmpManager.class); private static int version = 0; // SNMP版本, 0表示版本1 private static String protocol = "udp"; // 监控时使用的协议 private static String port = "161"; // 监控时使用的端口 static String ipAddress = "192.168.100.15"; static String[] returnValueString = null; /** * 获取SNMP节点值 * * @param ipAddress 目标IP地址 * @param community 公同体 * @param oid 对象ID * @return String 监控结果代号 * @throws AppException */ public static String snmpGet( String community, String oid) throws Exception { String resultStat = null; // 监控结果状态 StringBuffer address = new StringBuffer(); address.append(protocol); address.append(":"); address.append(ipAddress); address.append("/"); address.append(port); // Address targetAddress = GenericAddress.parse(protocol + ":" + ipAddress + "/" + port); Address targetAddress = GenericAddress.parse(address.toString()); PDU pdu = new PDU(); pdu.add(new VariableBinding(new OID(oid))); pdu.setType(PDU.GET); // 创建共同体对象CommunityTarget CommunityTarget target = new CommunityTarget(); target.setCommunity(new OctetString(community)); target.setAddress(targetAddress); target.setVersion(SnmpConstants.version1); target.setTimeout(2000); target.setRetries(1); DefaultUdpTransportMapping udpTransportMap = null; Snmp snmp = null; try { // 发送同步消息 udpTransportMap = new DefaultUdpTransportMapping(); udpTransportMap.listen(); snmp = new Snmp(udpTransportMap); ResponseEvent response = snmp.send(pdu, target); PDU resposePdu = response.getResponse(); if (resposePdu == null) { log.info(ipAddress + ": Request timed out."); } else { //errorStatus = resposePdu.getErrorStatus(); Object obj = resposePdu.getVariableBindings().firstElement(); VariableBinding variable = (VariableBinding) obj; resultStat = variable.getVariable().toString(); } } catch (Exception e) { throw new Exception("获取SNMP节点状态时发生错误!", e); } finally { if (snmp != null) { try { snmp.close(); } catch (IOException e) { snmp = null; } } if (udpTransportMap != null) { try { udpTransportMap.close(); } catch (IOException e) { udpTransportMap = null; } } } if (log.isInfoEnabled()) { log.info("IP:" + ipAddress + " resultStat:" + resultStat); } return resultStat; } /** * 走访SNMP节点 * * @param ipAddress 目标IP地址 * @param community 共同体 * @param oid 节点起始对象标志符 * @return String[] 走方结果 * @throws AppException */ public static String[] snmpWalk( String community, String oid) throws Exception { // oid走访结果数组 APPException SNMPv1CommunicationInterface comInterface = null; try { InetAddress hostAddress = InetAddress.getByName(ipAddress); comInterface = new SNMPv1CommunicationInterface( version, hostAddress, community); comInterface.setSocketTimeout(2000); // 返回所有以oid开始的管理信息库变量值 SNMPVarBindList tableVars = comInterface.retrieveMIBTable(oid); returnValueString = new String[tableVars.size()]; // 循环处理所有以oid开始的节点的返回值 for (int i = 0; i < tableVars.size(); i++) { SNMPSequence pair = (SNMPSequence) tableVars.getSNMPObjectAt(i); // 获取SNMP序列对象, 即(OID,value)对 SNMPObject snmpValue = pair.getSNMPObjectAt(1); // 获取某个节点的返回值 String typeString = snmpValue.getClass().getName(); // 获取SNMP值类型名 // 设置返回值 if (typeString.equals("snmp.SNMPOctetString")) { String snmpString = snmpValue.toString(); int nullLocation = snmpString.indexOf('\0'); if (nullLocation >= 0) snmpString = snmpString.substring(0, nullLocation); returnValueString[i] = snmpString; } else { returnValueString[i] = snmpValue.toString(); } } } catch (SocketTimeoutException ste) { if (log.isInfoEnabled()) { log.error("走访IP为" + ipAddress + ", OID为" + oid + " 时超时!"); } returnValueString = null; } catch (Exception e) { throw new Exception("SNMP走访节点时发生错误!", e); } finally { if (comInterface != null) { try { comInterface.closeConnection(); } catch (SocketException e) { comInterface = null; } } } return returnValueString; } }
上一篇:关于一个snmp的具体程序-9k
下一篇:网络远程视频监控系统
登录 注册