import org.snmp4j.util.ThreadPool; //导入依赖的package包/类
@Override
public void startUp() throws IOException {
	log.info("Snmp Trap Receiver Start");
	log.info("listened on " + Configure.getInstance().getUdpTrapIpPort());
	ThreadPool pool = ThreadPool.create(Const.THREAD_POOL_NAME, Const.AGENT_THREAD_NUM);
	MultiThreadedMessageDispatcher dispatcher = new MultiThreadedMessageDispatcher(pool, new MessageDispatcherImpl());
	Address listenAddress = GenericAddress.parse(Configure.getInstance().getUdpTrapIpPort());
	TransportMapping transport = new DefaultUdpTransportMapping((UdpAddress) listenAddress);
	// ����SNMP������ʹ�俪ʼ����
	Snmp snmp = new Snmp(dispatcher, transport);
       snmp.getMessageDispatcher().addMessageProcessingModel(new MPv2c());
       snmp.listen();
       snmp.addCommandResponder(new CommandResponderImpl());
}
 

import org.snmp4j.util.ThreadPool; //导入依赖的package包/类
private void init() throws UnknownHostException, IOException {
	threadPool = ThreadPool.create("Trap", 4);
	dispatcher = new MultiThreadedMessageDispatcher(threadPool,
			new MessageDispatcherImpl());

	listenAddress = GenericAddress.parse("udp:0.0.0.0/"
			+ SnmpPref.getTrapsPort());
	DefaultUdpTransportMapping transport = new DefaultUdpTransportMapping(
			(UdpAddress) 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();
	logger.debug("Listening for traps on "
			+ transport.getListenAddress().toString());
}
 

import org.snmp4j.util.ThreadPool; //导入依赖的package包/类
public void initReceiver(String host) {
    Address address = new UdpAddress(host + "/" + _port);
    try {
        _transport = new DefaultUdpTransportMapping((UdpAddress) address);
    } catch (IOException e) {
        System.out.println("Unable to bind to local IP and port: " + e);
        System.exit(-1);
    }

    _threadPool = ThreadPool.create(this.getClass().getName(), _numThreads);

    MessageDispatcher mtDispatcher =
            new MultiThreadedMessageDispatcher(_threadPool, new MessageDispatcherImpl());

    // add message processing models
    mtDispatcher.addMessageProcessingModel(new MPv1());
    mtDispatcher.addMessageProcessingModel(new MPv2c());

    // add all security protocols
    SecurityProtocols.getInstance().addDefaultProtocols();

    snmp = new Snmp(mtDispatcher, _transport);
    if (snmp != null) {
        snmp.addCommandResponder(this);
    } else {
        System.out.println("Unable to create Target object");
        System.exit(-1);
    }

    if (version == SnmpConstants.version3) {
        mtDispatcher.addMessageProcessingModel(new MPv3());
        MPv3 mpv3 = (MPv3) snmp.getMessageProcessingModel(MessageProcessingModel.MPv3);

        USM usm = new USM(SecurityProtocols.getInstance(), new OctetString(mpv3.createLocalEngineID()), 0);

        SecurityModels.getInstance().addSecurityModel(usm);
        if (_authoritativeEngineID != null) {
            snmp.setLocalEngine(_authoritativeEngineID.getValue(), 0, 0);
        }
        this.addUsmUser(snmp);
    }
}
 

import org.snmp4j.util.ThreadPool; //导入依赖的package包/类
public MockSnmpAgent(final File confFile, final URL moFile) {
    super(BOOT_COUNT_FILE, confFile, new CommandProcessor(new OctetString(MPv3.createLocalEngineID(new OctetString("MOCKAGENT")))));
    m_moLoader.set(new PropertiesBackedManagedObject());
    m_moFile.set(moFile);
    agent.setWorkerPool(ThreadPool.create("RequestPool", 4));
}
 

import org.snmp4j.util.ThreadPool; //导入依赖的package包/类
/**
 * Initializes a new instance of an SNMP agent.
 *
 * @param configuration the configuration for this agent
 */
public SnmpmanAgent(final AgentConfiguration configuration) {
    super(SnmpmanAgent.getBootCounterFile(configuration), SnmpmanAgent.getConfigurationFile(configuration), new CommandProcessor(new OctetString(MPv3.createLocalEngineID())));
    this.agent.setWorkerPool(ThreadPool.create("RequestPool", 3));
    this.configuration = configuration;
}
 

import org.snmp4j.util.ThreadPool; //导入依赖的package包/类
public MockSnmpAgent(final File confFile, final Resource moFile) {
    super(BOOT_COUNT_FILE, confFile, new CommandProcessor(new OctetString(MPv3.createLocalEngineID(new OctetString("MOCKAGENT")))));
    m_moLoader = new PropertiesBackedManagedObject();
    m_moFile = moFile;
    agent.setWorkerPool(ThreadPool.create("RequestPool", 4));
}