test_threads.java

snmp zip 包开发snmp协议

// NAME
//      $RCSfile: test_threads.java,v $
// DESCRIPTION
//      [given below in javadoc format]
// DELTA
//      $Revision: 1.4 $
// CREATED
//      $Date: 2006/01/17 17:49:50 $
// COPYRIGHT
//      Westhawk Ltd
// TO DO
//

/*
 * Copyright (C) 1996 - 1998 by Westhawk Ltd (www.westhawk.nl)
 * Copyright (C) 1998 - 2006 by Westhawk Ltd 
 * <a href="www.westhawk.co.uk">www.westhawk.co.uk</a>
 *
 * Permission to use, copy, modify, and distribute this software
 * for any purpose and without fee is hereby granted, provided
 * that the above copyright notices appear in all copies and that
 * both the copyright notice and this permission notice appear in
 * supporting documentation.
 * This software is provided "as is" without express or implied
 * warranty.
 * author <a href="mailto:[e-mail]">Tim Panton</a>
 */
 
package uk.co.westhawk.examplev1;

import java.awt.Graphics;
import java.awt.Event;
import java.util.*;
import java.net.*;

import uk.co.westhawk.snmp.stack.*;    
import uk.co.westhawk.snmp.pdu.*;    

/**
 * <p>
 * The test_threads application does a MIB tree walk on various hosts.
 * It will start with the OID as configured in the properties file.
 * </p>
 *
 * <p>
 * The hosts, port, oid and community name can be configured 
 * in the properties file. 
 * The name of the properties file can be passed as first argument to
 * this application. If there is no such argument, it will look for
 * <code>test_threads.properties</code>. If this file does not exist, the
 * application will use default parameters.
 * </p>
 *
 * @see uk.co.westhawk.snmp.stack.GetNextPdu
 *
 * @author <a href="mailto:[e-mail]">Birgit Arkesteijn</a>
 * @version $Revision: 1.4 $ $Date: 2006/01/17 17:49:50 $
 */
public class test_threads implements Observer
{
    private static final String     version_id =
        "@(#)$Id: test_threads.java,v 1.4 2006/01/17 17:49:50 birgit Exp $ Copyright Westhawk Ltd";

    public final static String HOSTS = "hosts";
    private static int      retries[] = {250, 500, 1000, 1000};

    public  SnmpContext     contexts[];

    private String          hosts[];
    private int             nrHost=0;
    private SnmpContext     context;

    private int             port;
    private String          community;
    private String          socketType;
    private String          oid;

    private Util            util;

/**
 * Constructor.
 *
 * @param propertiesFilename The name of the properties file. Can be
 * null.
 */
public test_threads(String propertiesFilename)
{
    AsnObject.setDebug(7);
    util = new Util(propertiesFilename, this.getClass().getName());

    String hostsProp = util.getProperty(HOSTS);
    port = util.getPort(SnmpContextBasisFace.DEFAULT_PORT);
    community = util.getCommunity();
    socketType = util.getSocketType();
    oid = util.getOid("1");

    StringTokenizer tok = new StringTokenizer(hostsProp, ",");
    int count = tok.countTokens();
    hosts = new String[count];
    contexts = new SnmpContext[count];

    int n=0;
    while (tok.hasMoreTokens())
    {
        try
        {
            String h = tok.nextToken();
            hosts[n] = h.trim();
System.out.println(n + " " + hosts[n]);
            n++;
        }
        catch (NoSuchElementException exc) { }
    }
}


public void init () 
{
    nrHost=0;
    try 
    {
        contexts[nrHost] = new SnmpContext(hosts[nrHost], port, socketType);
        startWalk(contexts[nrHost]);
    }
    catch (java.io.IOException exc)
    {
        System.out.println("IOException " + exc.getMessage());
        System.exit(0);
    }
    catch (PduException exc)
    {
        System.out.println("PduException " + exc.getMessage());
        System.exit(0);
    }
}

public void startWalk(SnmpContext cont)
throws java.io.IOException, PduException
{
    context = cont;
    context.setCommunity(community);

    System.out.println("startWalk: " 
          + context.getHost() + " " + context.getPort());
    GetNextPdu pdu = new GetNextPdu(context);
    pdu.addObserver(this);
    pdu.addOid(oid);
    pdu.setRetryIntervals(retries);
    pdu.send();
}

/**
 * Implementing the Observer interface. Receiving the response from 
 * the Pdu.
 *
 * @param obs the GetNextPdu variable
 * @param ov the varbind
 *
 * @see uk.co.westhawk.snmp.stack.GetNextPdu
 * @see uk.co.westhawk.snmp.stack.varbind
 */
public void update(Observable obs, Object ov)
{
    try 
    {
        GetNextPdu pdu = (GetNextPdu) obs;
        if (pdu.getErrorStatus() == AsnObject.SNMP_ERR_NOERROR)
        {
            varbind[] vars = pdu.getResponseVarbinds();
            varbind var = vars[0];
            System.out.println(var.toString());

            pdu = new GetNextPdu(context);
            pdu.addObserver(this);
            pdu.addOid(var.getOid());
            pdu.send();
        }
        else
        {
            contexts[nrHost].destroy();
            if (nrHost < hosts.length-1)
            {
                nrHost++;
                contexts[nrHost] = new SnmpContext(hosts[nrHost], 
                    port, socketType);
                startWalk(contexts[nrHost]);
            }
            else
            {
                System.gc();
                System.out.println("gc");
            }
        }
    }
    catch (java.io.IOException exc)
    {
        System.out.println("update(): IOException " + exc.getMessage());
        exc.printStackTrace();
    }
    catch (PduException exc)
    {
        System.out.println("update(): PduException " + exc.getMessage());
        exc.printStackTrace();
    }
}


public static void main(String [] args)
{
    String propFileName = null;
    if (args.length > 0)
    {
        propFileName = args[0];
    }
    test_threads t = new test_threads(propFileName);
    t.init();

    while (true) 
    {
        try 
        { 
            // 1.5 minutes
            Thread.sleep(90000); 
        } 
        catch (Exception x) 
        {
            ;
        }

        System.out.println("tick");
        for (int i=0; i<t.contexts.length; i++)
        {
            if (t.contexts[i] != null)
            {
                System.out.println(t.contexts[i].getHost() 
                    + "\t" + t.contexts[i].getDebugString());
            }
        }
    }
}

}