SnmpTerminal

package com.network.snmp;

import java.io.IOException;
import java.util.Vector;

import org.snmp4j.CommunityTarget;
import org.snmp4j.PDU;
import org.snmp4j.Snmp;
import org.snmp4j.TransportMapping;
import org.snmp4j.event.ResponseEvent;
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;

public class SnmpTerminal {
    /**[SnmpConstants.version1,SnmpConstants.version2c,SnmpConstants.version3]*/
    private int version = SnmpConstants.version1;
    private static final int DEFAULT_SNMP_PORT = 161;
    private Snmp snmp = null;
    private Address targetAddress = null;
    /**
     * init snmp use default snmp port
     * @param ip
     * @throws IOException
     */
    public SnmpTerminal(String ip) throws IOException {
        this(ip, DEFAULT_SNMP_PORT);
    }
    /**
     *
     * @param ip
     * @param port
     * @throws IOException
     */
    public SnmpTerminal(String ip, int port) throws IOException {
        targetAddress = GenericAddress.parse("udp:" + ip + "/" + port);
        TransportMapping<?> transport = new DefaultUdpTransportMapping();
        snmp = new Snmp(transport);
        transport.listen();
    }

    /**
     *
     * @param community
     * @param oid
     * @return
     * @throws Exception
     */
    public String sendPDU(String community,int[] oid) throws Exception {
        StringBuffer buffer = new StringBuffer();
        //分区
        CommunityTarget target = new CommunityTarget();
        target.setCommunity(new OctetString(community));
        target.setAddress(targetAddress);
        // 通信不成功时的重试次数
        target.setRetries(3);
        // 超时时间
        target.setTimeout(3000);
        target.setVersion(version);
        // 创建 PDU
        PDU pdu = new PDU();
        pdu.add(new VariableBinding(new OID(oid)));
        // MIB的访问方式
        pdu.setType(PDU.GET);
        // 向Agent发送PDU，并接收Response
        ResponseEvent respEvnt = snmp.send(pdu, target);
        // 解析Response
        if (respEvnt != null && respEvnt.getResponse() != null) {
            @SuppressWarnings("unchecked")
            Vector<VariableBinding> recVBs = (Vector<VariableBinding>) respEvnt.getResponse().getVariableBindings();
            for (int i = 0; i < recVBs.size(); i++) {
                VariableBinding recVB = recVBs.elementAt(i);
                buffer.append(recVB.getVariable());
            }
        }
        return buffer.toString();
    }
    public int getVersion() {
        return version;
    }
    public void setVersion(int version) throws Exception {
        if(version != SnmpConstants.version1 && version != SnmpConstants.version2c && version != SnmpConstants.version3)
            throw new Exception("Unsupported snmp protocol version");
        this.version = version;
    }
}