getSnmpAugmentTable.java
上传用户:aonuowh
上传日期:2021-05-23
资源大小:35390k
文件大小:9k
源码类别:

SNMP编程

开发平台:

C/C++

  1. /*$Id: getSnmpAugmentTable.src,v 1.1.2.3 2009/01/28 12:45:56 prathika Exp $*/
  2. /*
  3.  * @(#)getSnmpAugmentTable.java
  4.  * Copyright (c) 1996-2009 AdventNet, Inc. All Rights Reserved.
  5.  * Please read the associated COPYRIGHTS file for more details.
  6.  */
  7. /** 
  8.  *  This is an example of using the SnmpAugmentTable class.
  9.  *  This is a command line application that does not require JFC/swing
  10.  *  components.  See the swingapps directory for examples that need
  11.  *  and use swing components.
  12.  *
  13.  * [-d]                - Debug output. By default off.
  14.  * [-c] <community>    - community String. By default "public".
  15.  * [-p] <port>         - remote port no. By default 161.
  16.  * [-t] <Timeout>      - Timeout. By default 5000ms.
  17.  * [-r] <Retries>      - Retries. By default 0.      
  18.  * [-v] <version>      - version(v1 / v2 / v3). By default v1.
  19.  * [-u] <username>     - The v3 principal/userName
  20.  * [-a] <autProtocol>  - The authProtocol(MD5/SHA). Mandatory if authPassword is specified
  21.  * [-w] <authPassword> - The authentication password.
  22.  * [-s] <privPassword> - The privacy protocol password. Must be accompanied with auth password and authProtocol fields.
  23.  * [-n] <contextName>  - The snmpv3 contextName to be used.
  24.  * [-i] <contextID>    - The snmpv3 contextID to be used.
  25.  * [-pp] <privProtocol> - The privacy protocol. Must be accompanied with auth,priv password and authProtocol fields.
  26.  * host Mandatory      - The RemoteHost (agent).Format (string without double qoutes/IpAddress).
  27.  * tableOID  Mandatory - Give the Object Identifier of a Table.
  28.  * mibs               - The mibs to be loaded.Mandatory.
  29.  */
  30. import com.adventnet.snmp.beans.*;
  31. import com.adventnet.snmp.mibs.*;
  32. import com.adventnet.snmp.snmp2.*;
  33. import java.util.*;
  34. public class getSnmpAugmentTable implements SnmpTableListener {
  35.     private static final int COMMUNITY = 1;
  36.     private static final int PORT = 2;
  37.     private static final int RETRIES = 3;
  38.     private static final int TIMEOUT = 4;
  39.     private static final int VERSION = 0;
  40.     private static final int USER_NAME = 5;
  41.     private static final int AUTH_PROTOCOL = 6;
  42.     private static final int AUTH_PASSWORD = 7;
  43.     private static final int PRIV_PASSWORD = 8;
  44. private static final int CONTEXT_NAME = 9;
  45. private static final int CONTEXT_ID = 10;
  46.     private static final int DEBUG = 11;
  47.     private static final int PRIV_PROTOCOL = 12;
  48.     public static void main(String args[]) {
  49.     // Take care of getting options
  50.     String usage = "getSnmpAugmentTable [-v version(v1,v2,v3)] [-c community] [-p port] [-t timeout] [-r retries] [-u user] [-a auth_protocol(MD5/SHA)] [-w auth_password] [-s priv_password] [-n contextname] [-i contextID] [-d debug] [ -pp priv_protocol (DES/AES-128/AES-192/AES-256/3DES) ] host tableOID MIB_files";
  51.     String options[] = { "-v", "-c", "-p", "-r", "-t", "-u", "-a", "-w", "-s", "-n", "-i", "-d", "-pp"};
  52.     String values[] = { null, null, null, null, null, null, null, null, null, null, null, "None", null};
  53.     String authProtocol = new String("NO_AUTH");
  54.     ParseOptions opt = new ParseOptions(args,options,values, usage);
  55.     // check for at least hostname and one OID in remaining arguments
  56.     if (opt.remArgs.length<3) opt.usage_error();    
  57.     
  58.     
  59.  if(values[VERSION] != null)
  60.   {     
  61.  if ((values[VERSION].equals("v3")) && (values[USER_NAME] == null)) opt.usage_error();
  62. }
  63.     // instantiate an SnmpAugmentTable instance
  64.     SnmpAugmentTable table = new SnmpAugmentTable();
  65.  //To load MIBs from compiled file
  66.  table.setLoadFromCompiledMibs(true);
  67.  
  68.  
  69.  if (values[DEBUG].equals("set")) table.setDebug(true);
  70.  
  71.         if(values[VERSION] != null) {  // if SNMP version is specified, set it
  72.             if(values[VERSION].equals("v2"))
  73.                 table.setSnmpVersion( SnmpTarget.VERSION2C ) ;
  74.             else if(values[VERSION].equals("v1"))
  75.                 table.setSnmpVersion( SnmpTarget.VERSION1 );
  76.             else if(values[VERSION].equals("v3"))
  77.                 table.setSnmpVersion( SnmpTarget.VERSION3 );
  78.             else {
  79.                 System.out.println("Invalid Version Number"); 
  80.                 System.exit(1);
  81.             }
  82.         }
  83.     table.setTargetHost( opt.remArgs[0] ); // set the agent hostname
  84.     if (values[COMMUNITY] != null) // set the community if specified
  85.         table.setCommunity( values[COMMUNITY] );
  86.     try { // set the timeout/retries/port parameters, if specified
  87.         if (values[PORT] != null) 
  88.             table.setTargetPort( Integer.parseInt(values[PORT]) );
  89.         if (values[RETRIES] != null) 
  90.             table.setRetries( Integer.parseInt(values[RETRIES]) );
  91.         if (values[TIMEOUT] != null) 
  92.             table.setTimeout( Integer.parseInt(values[TIMEOUT]) );
  93.     } catch (NumberFormatException ex) {
  94.         System.err.println("Invalid Integer Argument "+ex);
  95.     }
  96.     if(table.getSnmpVersion() == table.VERSION3) {
  97.         if (values[USER_NAME] != null) 
  98.             table.setPrincipal(values[USER_NAME]);
  99.         if (values[AUTH_PROTOCOL] != null) {
  100.             //System.out.println("authProtocol = " + authProtocol);
  101.             authProtocol = values[AUTH_PROTOCOL];
  102.         }
  103.         if(authProtocol.equals("SHA"))
  104.             table.setAuthProtocol(SnmpTarget.SHA_AUTH);
  105.         else if(authProtocol.equals("MD5"))
  106.             table.setAuthProtocol(SnmpTarget.MD5_AUTH);
  107.         else
  108.             table.setAuthProtocol(SnmpTarget.NO_AUTH);
  109.         if (values[AUTH_PASSWORD] != null) 
  110.             table.setAuthPassword(values[AUTH_PASSWORD]);
  111.         if (values[PRIV_PASSWORD] != null)
  112.         {
  113.             table.setPrivPassword(values[PRIV_PASSWORD]);
  114.             if(values[PRIV_PROTOCOL] != null)
  115.             {
  116.                     if(values[PRIV_PROTOCOL].equals("AES-128"))
  117.                     {
  118.                        table.setPrivProtocol(table.CFB_AES_128);
  119.                     }
  120.     else if(values[PRIV_PROTOCOL].equals("AES-192"))
  121.                     {
  122.                        table.setPrivProtocol(table.CFB_AES_192);
  123.                     }
  124.     else if(values[PRIV_PROTOCOL].equals("AES-256"))
  125.                     {
  126.                        table.setPrivProtocol(table.CFB_AES_256);
  127.                     }
  128.     else if(values[PRIV_PROTOCOL].equals("3DES"))
  129.                     {
  130.                       table.setPrivProtocol(table.CBC_3DES);
  131.                     }
  132.                     else if(values[PRIV_PROTOCOL].equals("DES"))
  133.                     {
  134.                        table.setPrivProtocol(table.CBC_DES);
  135.                     }
  136.                     else
  137.                     {
  138.                      System.out.println(" Invalid PrivProtocol "+values[PRIV_PROTOCOL]);
  139.                      opt.usage_error();
  140.                     }
  141.             }
  142.         }
  143. if(values[CONTEXT_NAME]!= null)
  144. table.setContextName(values[CONTEXT_NAME]);
  145. if(values[CONTEXT_ID]!= null)
  146. table.setContextID(values[CONTEXT_ID]);
  147.         }
  148.     if (opt.remArgs[2] != null) try { // Load the MIB files 
  149.         System.out.println("Loading MIBs: "+opt.remArgs[2]);
  150.         table.loadMibs(opt.remArgs[2]);
  151.         System.out.println("Done.");
  152.     } catch (Exception ex) {
  153.         System.err.println("Error loading MIBs: "+ex);
  154.     }
  155. if(table.getSnmpVersion() == table.VERSION3){
  156. table.create_v3_tables();
  157. }
  158. if (values[DEBUG].equals("Set"))
  159.     {
  160.         table.setDebug(true);
  161.     }  
  162.     // instantiate this class to receive table events, and register it
  163.     getSnmpAugmentTable gettable = new getSnmpAugmentTable();
  164.     table.addSnmpTableListener(gettable);
  165. // Set the table OID in SnmpAugmentTable.  Once specified,
  166.     // SnmpAugmentTable will automatically get the data and send table events 
  167.     try { 
  168.         table.setTableObjectID( opt.remArgs[1] );
  169.     } catch (Exception ex) {
  170.         System.err.println("Invalid table OID: "+ex);
  171.         System.exit(1);
  172.     }
  173.     System.out.println("Getting table.  Table items:");
  174.     }
  175.     /* This is the listener method which is notified of table changes **/
  176.     public void tableChanged(SnmpTableEvent e) {
  177.     SnmpAugmentTable table = (SnmpAugmentTable)e.getSource();
  178.     if( e.isEndOfTable() || e.getType() == 2){
  179.         if (table.getRowCount() == 0)  // no rows and we're being notified
  180.             System.err.println(table.getErrorString());
  181.         return;
  182.     }
  183.     StringBuffer sb = new StringBuffer();
  184.         
  185.     if (e.getFirstRow() == 0) {  // we're being notified of first row
  186.       for (int i=0;i<table.getColumnCount();i++)  // print column names
  187.         sb.append(table.getColumnName(i)+" t");
  188.       System.out.println(sb.toString());
  189.     }
  190.     // print the rows we're getting
  191.     sb = new StringBuffer();
  192.     for (int j=e.getFirstRow();j<=e.getLastRow();j++) { 
  193.         for (int i=0;i<table.getColumnCount();i++) 
  194.             sb.append(table.getValueAt(j,i)+" t");
  195.     }
  196.     System.out.println(sb.toString());
  197.     }
  198. }