snmp 4 jを使用してメッセージを傍受および送信する

MultiThreadedTrapReceiverクラス:trapメッセージを受信する
 

package com.snmp.trap;

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

import org.snmp4j.CommandResponder;
import org.snmp4j.CommandResponderEvent;
import org.snmp4j.MessageDispatcherImpl;
import org.snmp4j.Snmp;
import org.snmp4j.TransportMapping;
import org.snmp4j.mp.MPv1;
import org.snmp4j.mp.MPv2c;
import org.snmp4j.mp.MPv3;
import org.snmp4j.security.SecurityModels;
import org.snmp4j.security.SecurityProtocols;
import org.snmp4j.security.USM;
import org.snmp4j.smi.Address;
import org.snmp4j.smi.GenericAddress;
import org.snmp4j.smi.OctetString;
import org.snmp4j.smi.TcpAddress;
import org.snmp4j.smi.UdpAddress;
import org.snmp4j.smi.VariableBinding;
import org.snmp4j.transport.DefaultTcpTransportMapping;
import org.snmp4j.transport.DefaultUdpTransportMapping;
import org.snmp4j.util.MultiThreadedMessageDispatcher;
import org.snmp4j.util.ThreadPool;

/**
 *     ，  162  
 * 
 */
public class MultiThreadedTrapReceiver implements CommandResponder {
	private MultiThreadedMessageDispatcher dispatcher;
	private Snmp snmp = null;
	private Address listenAddress;
	private ThreadPool threadPool;

	public MultiThreadedTrapReceiver() {
	}

	private void init() throws UnknownHostException, IOException {
		threadPool = ThreadPool.create("Trap", 2);
		dispatcher = new MultiThreadedMessageDispatcher(threadPool,
				new MessageDispatcherImpl());
		listenAddress = GenericAddress.parse("udp:127.0.0.1/162"); //   IP     
		TransportMapping transport;
		//  TCP UDP      
		if (listenAddress instanceof UdpAddress) {
			transport = new DefaultUdpTransportMapping(
					(UdpAddress) listenAddress);
		} else {
			transport = new DefaultTcpTransportMapping(
					(TcpAddress) listenAddress);
		}
		snmp = new Snmp(dispatcher, transport);
		snmp.getMessageDispatcher().addMessageProcessingModel(new MPv1());
		snmp.getMessageDispatcher().addMessageProcessingModel(new MPv2c());
		snmp.getMessageDispatcher().addMessageProcessingModel(new MPv3());
		USM usm = new USM(SecurityProtocols.getInstance(), new OctetString(
				MPv3.createLocalEngineID()), 0);
		SecurityModels.getInstance().addSecurityModel(usm);
		snmp.listen();
	}

	public void run() {
		try {
			init();
			snmp.addCommandResponder(this);
			System.out.println("    Trap  !");
		} catch (Exception ex) {
			ex.printStackTrace();
		}
	}

	/**
	 *        ，        
	 */
	public void processPdu(CommandResponderEvent respEvnt) {
		//   Response
		if (respEvnt != null && respEvnt.getPDU() != null) {
			Vector<VariableBinding> recVBs = respEvnt.getPDU()
					.getVariableBindings();
			for (int i = 0; i < recVBs.size(); i++) {
				VariableBinding recVB = recVBs.elementAt(i);
				System.out
						.println(recVB.getOid() + " : " + recVB.getVariable());
			}
		}

	}

	public static void main(String[] args) {
		MultiThreadedTrapReceiver multithreadedtrapreceiver = new MultiThreadedTrapReceiver();
		multithreadedtrapreceiver.run();
	}

}

 
 SendTrapクラス:trapメッセージの送信
 

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;  
  
/** 
 *    ，  trap   
 * 
 */  
public class SendTrap {  
    private Snmp snmp = null;  
  
    private Address targetAddress = null;  
  
    public void initComm() throws IOException {  
  
        //        IP     
        targetAddress = GenericAddress.parse("udp:127.0.0.1/162");  
        TransportMapping transport = new DefaultUdpTransportMapping();  
        snmp = new Snmp(transport);  
        transport.listen();  
  
    }  
  
    /** 
     *        Trap   
     *  
     * @throws IOException 
     */  
    public void sendPDU() throws IOException {  
  
        //    target  
        CommunityTarget target = new CommunityTarget();  
        target.setAddress(targetAddress);  
  
        //              
        target.setRetries(2);  
        //       
        target.setTimeout(1500);  
        // snmp    
        target.setVersion(SnmpConstants.version2c);  
  
        //    PDU  
        PDU pdu = new PDU();  
        pdu.add(new VariableBinding(new OID(".1.3.6.1.2.3377.10.1.1.1.1"),  
                new OctetString("SnmpTrap")));  
        pdu.add(new VariableBinding(new OID(".1.3.6.1.2.3377.10.1.1.1.2"),  
                new OctetString("JavaEE")));  
        pdu.setType(PDU.TRAP);  
  
        //  Agent  PDU，   Response  
        ResponseEvent respEvnt = snmp.send(pdu, target);  
  
        //   Response  
        if (respEvnt != null && respEvnt.getResponse() != null) {  
            Vector<VariableBinding> recVBs = respEvnt.getResponse()  
                    .getVariableBindings();  
            for (int i = 0; i < recVBs.size(); i++) {  
                VariableBinding recVB = recVBs.elementAt(i);  
                System.out  
                        .println(recVB.getOid() + " : " + recVB.getVariable());  
            }  
        }  
    }  
  
    public static void main(String[] args) {  
        try {  
            SendTrap sender = new SendTrap();  
            sender.initComm();  
            sender.sendPDU();  
        } catch (IOException e) {  
            e.printStackTrace();  
        }  
    }  
}

1、M u l tiThreadedTrapReceiverクラスを実行し、「Trap情報の傍受を開始せよ!」と要求し、傍受状態を処理する
 
2、SendTrapクラスを実行し、実行が完了すると、「Trap情報の傍受開始!」の後に表示されます.
1.3.6.1.2.3377.10.1.1.1.1 : SnmpTrap
1.3.6.1.2.3377.10.1.1.1.2 : JavaEE
MultiThreadedTrapReceiver出力パネルには、以上の2行が表示され、テストに成功しました.