snmpwalkmv.java

opennms得相关源码 请大家看看

//
// Copyright (C) 1999-2001 Oculan Corp.  All rights reserved.
//  
// This program is free software; you can redistribute it and/or modify
// it under the terms of the GNU General Public License as published by
// the Free Software Foundation; either version 2 of the License, or
// (at your option) any later version.
// 
// This program is distributed in the hope that it will be useful,
// but WITHOUT ANY WARRANTY; without even the implied warranty of
// MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
// GNU General Public License for more details.
// 
// You should have received a copy of the GNU General Public License
// along with this program; if not, write to the Free Software 
// Foundation, Inc., 59 Temple Place - Suite 330, Boston, MA 02111-1307, USA.
// 
// For more information contact: 
//	Brian Weaver	<[e-mail]>
//	http://www.opennms.org/
//
//
// Tab Size = 8
//
// snmpwalkmv.java,v 1.1.1.1 2001/11/11 17:35:57 ben Exp
//
//

package org.opennms.test;

import java.lang.*;
import java.io.*;
import java.net.*;
import org.opennms.protocols.snmp.*;

/**
 * <P>This class is designed to provide an example of how to use
 * the JoeSNMP libraries from <A HREF="http://www.opennms.org">OpenNMS</A>.
 * This example illustrates the code required to walk an SNMP tree
 * of an individual agent on a remote host.</P>
 *
 * <P>The class will walk the entire agent tree, or a subsection, as
 * defined by the command line arguments. Through the command line
 * options it is possible to set the community string, timeouts, retries,
 * and other options used by the JoeSNMP library.</P>
 *
 * <P>Usage: java org.opennms.test.snmpwalk [options] remote-host [object-id]</P>
 * <P>The command line options are as follows:
 * 	<TABLE>
 *	<TR>
 *	 	<TD nowrap>-v</TD>
 *	 	<TD nowrap>1 || 2 || 2c</TD>
 *	 	<TD>Sets the SNMP protocol version. 2 & 2c are identical and stand for
 *	 	    SNMPv2 community string based.
 *	 	</TD>
 * 	</TR>
 *	<TR>
 *		<TD nowrap>-c</TD>
 *		<TD nowrap>community</TD>
 *		<TD>Sets the community string used to authenticate</TD>
 *	</TR>
 *	<TR>
 *		<TD nowrap>-r</TD>
 *		<TD nowrap>retries</TD>
 *		<TD>Sets the number of time the SNMP message is retransmitted before
 *		    the communication times out.</TD>
 * 	</TR>
 *	<TR>
 *		<TD nowrap>-t</TD>
 *		<TD nowrap>timeout (seconds)</TD>
 *		<TD>Sets the timeout value. Fraction of a second is acceptable, but
 *		    a millisecond resolution is the smallest supported. For example:
 *		    .8 is equalivant to 800 milliseconds.</TD>
 *	</TR>
 *	<TR>
 *		<TD nowrap>-p</TD>
 *		<TD nowrap>port</TD>
 *		<TD>The remote port to communicate with the remote agent on.</TD>
 *	</TR>
 *	</TABLE>
 * </P>
 *
 * @version	1.1.1.1
 * @author	<A HREF="mailto:[e-mail]">Brian Weaver</A>
 * @author	<A HREF="http://www.opennms.org/">OpenNMS</A>
 */
public class snmpwalkmv extends Object implements SnmpHandler
{
	/**
	 * The version of the SNMP protocol used to communicate
	 */
	int		m_version 	= SnmpSMI.SNMPV1;	// -v
	
	/**
	 * The community string used to "authenticate" the request.
	 */
	String		m_community  	= null;			// -c
	
	/**
	 * The number of retries to use.
	 */
	int		m_retries 	= -1;			// -r
	
	/**
	 * The time period to wait before considering the last transmission
	 * a failure. This should be in milliseconds.
	 */
	int		m_timeout	= -1;			// -t
	
	/**
	 * The port where request are sent & received from.
	 */
	int		m_port		= -1;			// -p
	
	/**
	 * The remote agent to communicate with.
	 */
	String		m_host		= "127.0.0.1";
	
	/**
	 * The default location to start querying the table.
	 * This is the entire iso(1).org(3) tree by default.
	 */
	String		m_startOid	= ".1.3";
	
	/**
	 * The object identifier where the walk of 
	 * the tree should stop.
	 */
	SnmpObjectId	m_stopAt	= null;
	
	/**
	 * <P>The keys that will be supported by default from the 
	 * TreeMap base class. Each of the elements in the list
	 * are an instance of the SNMP Interface table. Objects
	 * in this list should be used by multiple instances of
	 * this class.</P>
	 */
	private static NamedSnmpVar[]	ms_elemList = null;

	/**
	 * Lookup strings for specific table entries
	 */
	public final static	String	IF_INDEX 	= "ifIndex";
	public final static	String	IF_DESCR	= "ifDescr";
	public final static	String	IF_TYPE 	= "ifType";
	public final static	String	IF_MTU 		= "ifMtu";
	public final static	String	IF_SPEED 	= "ifSpeed";
	public final static	String	IF_PHYS_ADDR	= "ifPhysAddr";
	public final static	String	IF_ADMIN_STATUS = "ifAdminStatus";
	public final static	String	IF_OPER_STATUS 	= "ifOperStatus";
	public final static	String	IF_LAST_CHANGE 	= "ifLastChange";
	public final static	String	IF_IN_OCTETS 	= "ifInOctets";
	public final static	String	IF_IN_UCAST 	= "ifInUcastPkts";
	public final static	String	IF_IN_NUCAST 	= "ifInNUcastPkts";
	public final static	String	IF_IN_DISCARDS 	= "IfInDiscards";
	public final static	String	IF_IN_ERRORS 	= "IfInErrors";
	public final static	String	IF_IN_UKNOWN_PROTOS 	= "ifInUnknownProtos";
	public final static	String	IF_OUT_OCTETS 	= "ifOutOctets";
	public final static	String	IF_OUT_UCAST 	= "ifOutUcastPkts";
	public final static	String	IF_OUT_NUCAST 	= "ifOutNUcastPkts";
	public final static	String	IF_OUT_DISCARDS = "IfOutDiscards";
	public final static	String	IF_OUT_ERRORS 	= "IfOutErrors";
	public final static 	String	IF_OUT_QLEN	= "ifOutQLen";
	public final static 	String	IF_SPECIFIC	= "ifSpecific";

	/**
	 * <P>Initialize the element list for the class. This
	 * is class wide data, but will be used by each instance.</P>
	 */
	static
	{
		ms_elemList = new NamedSnmpVar[22];
		int ndx = 0;
		
		ms_elemList[ndx++] = new NamedSnmpVar(NamedSnmpVar.SNMPINT32, 		IF_INDEX, 		".1.3.6.1.2.1.2.2.1.1",  1);
		ms_elemList[ndx++] = new NamedSnmpVar(NamedSnmpVar.SNMPOCTETSTRING, 	IF_DESCR, 		".1.3.6.1.2.1.2.2.1.2",  2);
		ms_elemList[ndx++] = new NamedSnmpVar(NamedSnmpVar.SNMPINT32, 		IF_TYPE, 		".1.3.6.1.2.1.2.2.1.3",  3);
		ms_elemList[ndx++] = new NamedSnmpVar(NamedSnmpVar.SNMPINT32, 		IF_MTU, 		".1.3.6.1.2.1.2.2.1.4",  4);
		ms_elemList[ndx++] = new NamedSnmpVar(NamedSnmpVar.SNMPGAUGE32,		IF_SPEED, 		".1.3.6.1.2.1.2.2.1.5",  5);
		ms_elemList[ndx++] = new NamedSnmpVar(NamedSnmpVar.SNMPOCTETSTRING,	IF_PHYS_ADDR,		".1.3.6.1.2.1.2.2.1.6",  6);
		ms_elemList[ndx++] = new NamedSnmpVar(NamedSnmpVar.SNMPINT32, 		IF_ADMIN_STATUS,	".1.3.6.1.2.1.2.2.1.7",  7);
		ms_elemList[ndx++] = new NamedSnmpVar(NamedSnmpVar.SNMPINT32, 		IF_OPER_STATUS, 	".1.3.6.1.2.1.2.2.1.8",  8);
		ms_elemList[ndx++] = new NamedSnmpVar(NamedSnmpVar.SNMPTIMETICKS, 	IF_LAST_CHANGE, 	".1.3.6.1.2.1.2.2.1.9",  9);
		ms_elemList[ndx++] = new NamedSnmpVar(NamedSnmpVar.SNMPCOUNTER32, 	IF_IN_OCTETS,		".1.3.6.1.2.1.2.2.1.10", 10);
		ms_elemList[ndx++] = new NamedSnmpVar(NamedSnmpVar.SNMPCOUNTER32,	IF_IN_UCAST,		".1.3.6.1.2.1.2.2.1.11", 11);
		ms_elemList[ndx++] = new NamedSnmpVar(NamedSnmpVar.SNMPCOUNTER32,	IF_IN_NUCAST,	 	".1.3.6.1.2.1.2.2.1.12", 12);
		ms_elemList[ndx++] = new NamedSnmpVar(NamedSnmpVar.SNMPCOUNTER32,	IF_IN_DISCARDS, 	".1.3.6.1.2.1.2.2.1.13", 13);
		ms_elemList[ndx++] = new NamedSnmpVar(NamedSnmpVar.SNMPCOUNTER32,	IF_IN_ERRORS, 		".1.3.6.1.2.1.2.2.1.14", 14);
		ms_elemList[ndx++] = new NamedSnmpVar(NamedSnmpVar.SNMPCOUNTER32,	IF_IN_UKNOWN_PROTOS,	".1.3.6.1.2.1.2.2.1.15", 15);
		ms_elemList[ndx++] = new NamedSnmpVar(NamedSnmpVar.SNMPCOUNTER32,	IF_OUT_OCTETS, 		".1.3.6.1.2.1.2.2.1.16", 16);
		ms_elemList[ndx++] = new NamedSnmpVar(NamedSnmpVar.SNMPCOUNTER32,	IF_OUT_UCAST, 		".1.3.6.1.2.1.2.2.1.17", 17);
		ms_elemList[ndx++] = new NamedSnmpVar(NamedSnmpVar.SNMPCOUNTER32,	IF_OUT_NUCAST, 		".1.3.6.1.2.1.2.2.1.18", 18);
		ms_elemList[ndx++] = new NamedSnmpVar(NamedSnmpVar.SNMPCOUNTER32,	IF_OUT_DISCARDS,	".1.3.6.1.2.1.2.2.1.19", 19);
		ms_elemList[ndx++] = new NamedSnmpVar(NamedSnmpVar.SNMPCOUNTER32,	IF_OUT_ERRORS, 		".1.3.6.1.2.1.2.2.1.20", 20);
		ms_elemList[ndx++] = new NamedSnmpVar(NamedSnmpVar.SNMPGAUGE32,		IF_OUT_QLEN, 		".1.3.6.1.2.1.2.2.1.21", 21);
		ms_elemList[ndx++] = new NamedSnmpVar(NamedSnmpVar.SNMPOBJECTID,	IF_SPECIFIC,	 	".1.3.6.1.2.1.2.2.1.22", 22);
	}
	
	
	/**
	 * <P>The TABLE_OID is the object identifier that represents
	 * the root of the interface table in the MIB forest.</P>
	 */
	public static final String	TABLE_OID	= ".1.3.6.1.2.1.2.2.1";	// start of table (GETNEXT)
	
	/**
	 * <P>The SnmpObjectId that represents the root of the 
	 * interface tree. It is created when the class is 
	 * initialized and contains the value of TABLE_OID.
	 *
	 * @see #TABLE_OID
	 */
	public static final SnmpObjectId ROOT = new SnmpObjectId(TABLE_OID);

	
	/**
	 * <P>Parse the command line options. If there is an illegal
	 * option then an exception is thrown.</P>
	 *
	 * <P>The command line options are as follows:
	 * 	<TABLE>
	 *	<TR>
	 *	 	<TD nowrap>-v</TD>
	 *	 	<TD nowrap>1 || 2 || 2c</TD>
	 *	 	<TD>Sets the SNMP protocol version. 2 & 2c are identical and stand for
	 *	 	    SNMPv2 community string based.
	 *	 	</TD>
	 * 	</TR>
	 *	<TR>
	 *		<TD nowrap>-c</TD>
	 *		<TD nowrap>community</TD>
	 *		<TD>Sets the community string used to authenticate</TD>
	 *	</TR>
	 *	<TR>
	 *		<TD nowrap>-r</TD>
	 *		<TD nowrap>retries</TD>
	 *		<TD>Sets the number of time the SNMP message is retransmitted before
	 *		    the communication times out.</TD>
	 * 	</TR>
	 *	<TR>
	 *		<TD nowrap>-t</TD>
	 *		<TD nowrap>timeout (seconds)</TD>
	 *		<TD>Sets the timeout value. Fraction of a second is acceptable, but
	 *		    a millisecond resolution is the smallest supported. For example:
	 *		    .8 is equalivant to 800 milliseconds.</TD>
	 *	</TR>
	 *	<TR>
	 *		<TD nowrap>-p</TD>
	 *		<TD nowrap>port</TD>
	 *		<TD>The remote port to communicate with the remote agent on.</TD>
	 *	</TR>
	 *	</TABLE>
	 * </P>	 
	 *
	 * @params args	The command line arguments from the main program.
	 * @exceception IllegalArgumentException Thrown if there is an
	 * 	unknown or malformed argument.
	 *
	 */
	void parseOptions(String[] args) throws IllegalArgumentException
	{
		int lastArg = 0;
		for(int x = 0; x < args.length; x++)
		{
			if(args[x].startsWith("-"))
			{
				if(args[x].equals("-c"))
				{
					m_community = args[++x];
				}
				else if(args[x].equals("-v"))
				{
					if(args[++x].equals("1"))
					{
						m_version = SnmpSMI.SNMPV1;
					}
					else if(args[x].equals("2") ||
						args[x].equals("2c"))
					{
						m_version = SnmpSMI.SNMPV2;
					}
				}
				else if(args[x].equals("-r"))
				{
					try
					{
						m_retries = Integer.parseInt(args[++x]);
					}
					catch(NumberFormatException e)
					{
						throw new IllegalArgumentException("Malformed retry number");
					}
				}
				else if(args[x].equals("-t"))
				{
					try
					{
						float f = Float.parseFloat(args[++x]);
						m_timeout = (int)(f * 1000);
					}
					catch(NumberFormatException e)
					{
						throw new IllegalArgumentException("Malformed timeout period");