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

SNMP编程

开发平台:

C/C++

  1. /* $Id: corbatable.src,v 1.3 2002/09/09 05:45:01 tonyjpaul Exp $ */
  2. /*
  3.  * @(#)corbatable.java
  4.  * Copyright (c) 1996-2002 AdventNet, Inc. All Rights Reserved.
  5.  * Please read the associated COPYRIGHTS file for more details.
  6.  */
  7. /**
  8.  * This is an example program to explain how to write an application to do
  9.  * the table operation using com.adventnet.snmp.corba of AdventNetSNMP2 api.
  10.  * The user could run this application by giving any one of the following usage.
  11.  *  
  12.  * java corbatable [ options ] host tableOID
  13.  *
  14.  *<img SRC="images/v3only.jpg" ALT="v3 only"> v3 request:
  15.  * java corbatable [-SnmpServer hostName] [-ORBInitialPort orbPort] [-ORBInitialHost orbHost] [-v version(v1,v2,v3)] [-m MIB_files] [-c community] [-p port] [-t timeout] [-r retries] [-u user] [-a auth_protocol] [-w auth_password] [-s priv_password] [-i context_id] [-n context_name] host tableOID  ...
  16.  * e.g. 
  17.  * java corbatable -v v3  -a MD5 -w passwd -u username -p 2000 -c public -m ....mibsrfc1213-mib localhost tcpConnTable
  18.  *
  19.  *<img SRC="images/v2candv3only.jpg" ALT="v2c and v3 only"> v2c request:
  20.  * java corbatable [-SnmpServer hostName] [-ORBInitialPort orbPort] [-ORBInitialHost orbHost] [-v version(v1,v2)] [-m MIB_files] [-c community] [-p port] [-t timeout] [-r retries] host tableOID  ...
  21.  * e.g.
  22.  * java corbatable  -v v2 -c public -m ....mibsrfc1213-mib  localhost tcpConnTable
  23.  * 
  24.  * v1 request:
  25.  * java corbaget [-SnmpServer hostName] [-ORBInitialPort orbPort] [-ORBInitialHost orbHost] [-m MIB_files] [-c community] [-p port] [-t timeout] [-r retries] host OID [OID] ...
  26.  * e.g.
  27.  * java corbatable -m ....mibsrfc1213-mib  localhost tcpConnTable
  28.  * 
  29.  *
  30.  * Options:
  31.  * [-SnmpServer ] <hostName>      - SnmpServer SERVER option to specify the
  32. CORBA server host.
  33.  * [-ORBInitialPort ] <orbPort>   - port on which transient name server is running
  34.  * [-ORBInitialHost ] <orbHost>   - host name of transient name server
  35.  * [-c] <community>    - community String. By default "public".
  36.  * [-p] <port>         - remote port no. By default 161.
  37.  * [-t] <Timeout>      - Timeout. By default 5000ms.
  38.  * [-r] <Retries>      - Retries. By default 0. 
  39.  * [-m] <MIBfile>      - MIB files.To load multiple mibs give within double quotes files seperated by a blank space.       
  40.  *<img SRC="images/v3only.jpg" ALT="v3 only"> [-v] <version>      - version(v1 / v2 / v3). By default v1.
  41.  * [-u] <username>     - The v3 principal/userName
  42.  * [-a] <autProtocol>  - The authProtocol(MD5/SHA). Mandatory if authPassword is specified
  43.  * [-w] <authPassword> - The authentication password.
  44.  * [-s] <privPassword> - The privacy protocol password. Must be accompanied with auth password and authProtocol fields.
  45.  * [-i] <contextID>  - The contextID to be used for the v3 pdu.
  46.  * [-n] <contextName>  - The contextName to be used for the v3 pdu.
  47.  * host Mandatory      - The RemoteHost (agent).Format (string without double qoutes/IpAddress).
  48.  * tableOID  Mandatory      - Give multiple no. of table Object Identifiers.
  49.  */
  50. import org.omg.CosNaming.*;
  51. import java.lang.*;
  52. import java.util.*;
  53. import java.net.*;
  54. import org.omg.CORBA.*;
  55. import com.adventnet.snmp.corba.*;
  56. import ParseOptions;
  57. import com.adventnet.snmp.mibs.*;
  58. import com.adventnet.snmp.snmp2.*;
  59. public class corbatable {
  60.     static SnmpTable table;
  61.     public static void main(String args[]) {
  62.         String usage = "corbatable [-SnmpServer hostName] [-ORBInitialPort orbPort] [-ORBInitialHost orbHost] [-v version(v1,v2,v3)] [-m MIB_files] [-c community] [-p port] [-t timeout] [-r retries] [-u user] [-a auth_protocol] [-w auth_password] [-s priv_password] [-i context_id] [-n context_name]  host tableOID  ...";
  63.         String options[] = { "-SnmpServer", "-ORBInitialPort", "-ORBInitialHost", "-c", "-p", "-r", "-t", "-m","-v", "-u", "-a", "-w", "-s", "-i", "-n"};
  64.         String values[] = {  null,null,null, null, null, null, null, null, null, null,null,null,null,null,null};
  65.     
  66.         String userName = new String("");
  67.         String authProtocol = new String("NO_AUTH");
  68.         String authPassword = new String ("");
  69.         String privPassword = new String ("");
  70.         String contextID = new String ("");
  71.         String contextName = new String ("");
  72. final int USM_SECURITY_MODEL = 3;
  73.                 
  74.         ParseOptions opt = new ParseOptions(args,options,values, usage);
  75.         // check for at least hostname and one OID in remaining arguments
  76.         if (opt.remArgs.length<2) opt.usage_error();
  77.         try
  78.         {
  79.             // Initialise the ORB
  80.             System.out.println( "Initialising the ORB" );
  81.             org.omg.CORBA.ORB orb = org.omg.CORBA.ORB.init( args, null );
  82.             // Use Naming Service
  83.             org.omg.CORBA.Object objRef = orb.resolve_initial_references( 
  84.                                                                         "NameService" ); 
  85.             System.out.println( "Resolved NameService" );
  86.             NamingContext ncRef = NamingContextHelper.narrow( objRef ); 
  87.             // bind the Object Reference in Naming
  88.             NameComponent nc = new NameComponent( "AdventnetSnmpFactory" , "" );
  89.             NameComponent[] path = { nc };
  90.             
  91.             // Bind to the SnmpTarget object 
  92.             //System.out.println( "Binding to the Factory object" );
  93.             //CORBAsnmp.SnmpTargetFactory factory = CORBAsnmp.SnmpTargetFactoryHelper.
  94.                             //bind( orb, "AdventnetSnmpTargetFactory" );
  95.             System.out.println( "Binding to the Factory object" );
  96.             com.adventnet.snmp.corba.SnmpFactory factory = com.adventnet.snmp.corba.SnmpFactoryHelper.narrow( ncRef.resolve( path ) );
  97.             System.out.println( "Bound to the Factory object" );
  98.             // Get a Target object
  99.                     table = factory.createTable();
  100.             System.out.println( "Got the SnmpTarget object" );
  101.             //call SNMP methods from client
  102.             //call SNMP methods from client
  103.             if(values[8] != null)
  104.             {  // if SNMP version is specified, set it
  105.                 if(values[8].equals("v1"))
  106.                     table.setSnmpVersion( com.adventnet.snmp.beans.SnmpTarget.VERSION1 ) ;
  107.                 else if(values[8].equals("v2"))
  108.                     table.setSnmpVersion( com.adventnet.snmp.beans.SnmpTarget.VERSION2C );            
  109.                 else if(values[8].equals("v3"))
  110.                     table.setSnmpVersion( com.adventnet.snmp.beans.SnmpTarget.VERSION3 );
  111.                 else
  112.                 {
  113.                     System.out.println("Invalid Version Number");
  114.                     System.exit(1);
  115.                 }
  116.             }
  117.             else
  118.                 table.setSnmpVersion( com.adventnet.snmp.beans.SnmpTarget.VERSION1 );
  119.     
  120.             table.setTargetHost( opt.remArgs[0] );  // set the agent hostname
  121.             if (values[3] != null) // set the community if specified
  122.                 table.setCommunity( values[3] );
  123.             // set the timeout/retries/port parameters, if specified
  124.             if (values[4] != null)
  125.                 table.setTargetPort( Integer.parseInt(values[4]) );
  126.             if (values[5] != null)
  127.                 table.setRetries( Integer.parseInt(values[5]) );
  128.             if (values[6] != null)
  129.                 table.setTimeout( Integer.parseInt(values[6]) );    
  130.             if (values[9] != null)
  131.                 userName = values[9];
  132.             if (values[10] != null) 
  133.                 authProtocol = values[10];
  134.             if (values[11] != null)
  135.                 authPassword = values[11];
  136.             if (values[12] != null) 
  137.                 privPassword = values[12];
  138.             if (values[13] != null) 
  139.                 contextID = values[13];
  140.             if (values[14] != null) 
  141.                 contextName = values[14];
  142.             
  143.             
  144.             if(table.getSnmpVersion() == com.adventnet.snmp.beans.SnmpTarget.VERSION3) 
  145.             {
  146.                 table.setPrincipal(userName);
  147.                 table.setAuthPassword(authPassword);
  148.                 table.setPrivPassword(privPassword);
  149.                 table.setContextID(contextID);
  150.                 table.setContextName(contextName);
  151.                 if(authProtocol.equals("SHA"))
  152. {
  153.                   table.setAuthProtocol(com.adventnet.snmp.beans.SnmpTarget.SHA_AUTH);
  154. }
  155.                 else
  156. {
  157.                   table.setAuthProtocol(com.adventnet.snmp.beans.SnmpTarget.MD5_AUTH);
  158. }
  159. table.create_v3_tables();
  160.             }
  161.             if (values[7] != null) 
  162.                 // Load the MIB files 
  163.             {
  164.             System.err.println("Loading MIBs: "+values[7]);
  165.             table.loadMibs(values[7]);
  166.             }
  167.             // instantiate this class to receive table events, and register it
  168.             com.adventnet.snmp.corba.SnmpTableListener listener = new SnmpTableListenerImpl( table );
  169.             orb.connect( listener );
  170.             table.addSnmpTableListener(listener);
  171.             // Set the table OID in SnmpTable.  Once specified,
  172.             // SnmpTable will automatically get the data and send table events 
  173.             try { 
  174.                 table.setTableOID( opt.remArgs[1] );
  175.             } catch (Exception ex) {
  176.                 System.err.println("Invalid table OID: "+ex);
  177.                 System.exit(1);
  178.             }
  179.             System.out.println("Getting table.  Table items:");
  180.             /*
  181.             java.lang.Object sync = new java.lang.Object();
  182.             //System.out.println( "Waiting for traps ... " );
  183.             synchronized ( sync )
  184.             {
  185.             sync.wait();
  186.             }
  187.             */
  188.             try { Thread.sleep(300000); }  // allow some time to get all rows
  189.             catch (InterruptedException ex) {}  
  190.             // All done; destroy the server-side Target object
  191.             factory.destroyTable( table.getName() );
  192.     } catch (Exception ex) {
  193.         System.err.println("Failed: "+ ex);
  194.         ex.printStackTrace();
  195.     }
  196.     System.exit(0);
  197.     }
  198. }