SNMP4j实现Trap的示例

作者: Michael 日期: 2012 年 7 月 20 日发表评论 (9) 查看评论

目录：

环境参数
代码示例

[一]、环境参数

jdk 1.6.0_18
snmp4j 1.11.3

[二]、代码示例

1. Trap接收器的实现

代码：SnmpTrapMultiThreadReceiver.java

package com.micmiu.snmp4j.demo1x;

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;

/**
 * 演示SNMP Trap多线程接收解析信息
 *
 * @blog http://www.micmiu.com
 * @author Michael
 */
public class SnmpTrapMultiThreadReceiver implements CommandResponder {
	private MultiThreadedMessageDispatcher dispatcher;
	private Snmp snmp = null;
	private Address listenAddress;
	private ThreadPool threadPool;

	public SnmpTrapMultiThreadReceiver() {
	}

	private void init() throws UnknownHostException, IOException {
		threadPool = ThreadPool.create("TrapPool", 2);
		dispatcher = new MultiThreadedMessageDispatcher(threadPool,
				new MessageDispatcherImpl());
		listenAddress = GenericAddress.parse(System.getProperty(
				"snmp4j.listenAddress", "udp:127.0.0.1/162"));
		TransportMapping transport;
		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() {
		System.out.println("----> Trap Receiver run ... <----");
		try {
			init();
			snmp.addCommandResponder(this);
			System.out.println("----> 开始监听端口，等待Trap message  <----");
		} catch (Exception ex) {
			ex.printStackTrace();
		}
	}

	@SuppressWarnings("unchecked")
	public void processPdu(CommandResponderEvent event) {
		System.out.println("----> 开始解析ResponderEvent: <----");
		if (event == null || event.getPDU() == null) {
			System.out.println("[Warn] ResponderEvent or PDU is null");
			return;
		}
		Vector<VariableBinding> vbVect = event.getPDU().getVariableBindings();
		for (VariableBinding vb : vbVect) {
			System.out.println(vb.getOid() + " = " + vb.getVariable());
		}
		System.out.println("---->  本次ResponderEvent 解析结束 <----");
	}

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

package com.micmiu.snmp4j.demo1x;

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;

/**

* 演示SNMP Trap多线程接收解析信息

* @blog http://www.micmiu.com

* @author Michael

public class SnmpTrapMultiThreadReceiver implements CommandResponder {

private MultiThreadedMessageDispatcher dispatcher;

private Snmp snmp = null;

private Address listenAddress;

private ThreadPool threadPool;

public SnmpTrapMultiThreadReceiver() {

}

private void init() throws UnknownHostException, IOException {

threadPool = ThreadPool.create("TrapPool", 2);

dispatcher = new MultiThreadedMessageDispatcher(threadPool,

new MessageDispatcherImpl());

listenAddress = GenericAddress.parse(System.getProperty(

"snmp4j.listenAddress", "udp:127.0.0.1/162"));

TransportMapping transport;

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() {

System.out.println("----> Trap Receiver run ... <----");

try {

init();

snmp.addCommandResponder(this);

System.out.println("----> 开始监听端口，等待Trap message <----");

} catch (Exception ex) {

ex.printStackTrace();

}

@SuppressWarnings("unchecked")

public void processPdu(CommandResponderEvent event) {

System.out.println("----> 开始解析ResponderEvent: <----");

if (event == null || event.getPDU() == null) {

System.out.println("[Warn] ResponderEvent or PDU is null");

return;

}

Vector<VariableBinding> vbVect = event.getPDU().getVariableBindings();

for (VariableBinding vb : vbVect) {

System.out.println(vb.getOid() + " = " + vb.getVariable());

}

System.out.println("----> 本次ResponderEvent 解析结束 <----");

}

public static void main(String[] args) {

SnmpTrapMultiThreadReceiver trapReceiver = new SnmpTrapMultiThreadReceiver();

trapReceiver.run();

}

运行结果：

----> Trap Receiver run ... <----
----> 开始监听端口，等待Trap message  <----

1 2	----> Trap Receiver run ... <---- ----> 开始监听端口，等待Trap message <----

2. Trap 发送消息的模拟实现

代码：SnmpTrapSendDemo.java

package com.micmiu.snmp4j.demo1x;

import java.io.IOException;

import org.snmp4j.CommunityTarget;
import org.snmp4j.PDU;
import org.snmp4j.Snmp;
import org.snmp4j.TransportMapping;
import org.snmp4j.mp.SnmpConstants;
import org.snmp4j.smi.GenericAddress;
import org.snmp4j.smi.OID;
import org.snmp4j.smi.OctetString;
import org.snmp4j.smi.TimeTicks;
import org.snmp4j.smi.UnsignedInteger32;
import org.snmp4j.smi.VariableBinding;
import org.snmp4j.transport.DefaultUdpTransportMapping;

/**
 * 模拟Trap发送消息
 * @blog http://www.micmiu.com
 * @author Michael
 */
public class SnmpTrapSendDemo {

	public static final int DEFAULT_VERSION = SnmpConstants.version2c;
	public static final long DEFAULT_TIMEOUT = 3 * 1000L;
	public static final int DEFAULT_RETRY = 3;

	private Snmp snmp = null;
	private CommunityTarget target = null;

	public void init() throws IOException {
		System.out.println("----> 初始 Trap 的IP和端口 <----");
		target = createTarget4Trap("udp:127.0.0.1/162");
		TransportMapping transport = new DefaultUdpTransportMapping();
		snmp = new Snmp(transport);
		transport.listen();
	}

	/**
	 * 向接收器发送Trap 信息
	 *
	 * @throws IOException
	 */
	public void sendPDU() throws IOException {
		PDU pdu = new PDU();
		pdu.add(new VariableBinding(
				new OID(".1.3.6.1.2.1.1.1.0"),
				new OctetString("SNMP Trap Test.see more:http://www.micmiu.com")));
		pdu.add(new VariableBinding(SnmpConstants.sysUpTime, new TimeTicks(
				new UnsignedInteger32(System.currentTimeMillis() / 1000)
						.getValue())));
		pdu.add(new VariableBinding(SnmpConstants.snmpTrapOID, new OID(
				".1.3.6.1.6.3.1.1.4.3")));

		// 向Agent发送PDU
		pdu.setType(PDU.TRAP);
		snmp.send(pdu, target);
		System.out.println("----> Trap Send END <----");
	}

	/**
	 * 创建对象communityTarget
	 *
	 * @param targetAddress
	 * @param community
	 * @param version
	 * @param timeOut
	 * @param retry
	 * @return CommunityTarget
	 */
	public static CommunityTarget createTarget4Trap(String address) {
		CommunityTarget target = new CommunityTarget();
		target.setAddress(GenericAddress.parse(address));
		target.setVersion(DEFAULT_VERSION);
		target.setTimeout(DEFAULT_TIMEOUT); // milliseconds
		target.setRetries(DEFAULT_RETRY);
		return target;
	}

	/**
	 * @param args
	 */
	public static void main(String[] args) {
		try {
			SnmpTrapSendDemo demo = new SnmpTrapSendDemo();
			demo.init();
			demo.sendPDU();
		} catch (IOException e) {
			e.printStackTrace();
		}

	}

}

package com.micmiu.snmp4j.demo1x;

import java.io.IOException;

import org.snmp4j.CommunityTarget;

import org.snmp4j.PDU;

import org.snmp4j.Snmp;

import org.snmp4j.TransportMapping;

import org.snmp4j.mp.SnmpConstants;

import org.snmp4j.smi.GenericAddress;

import org.snmp4j.smi.OID;

import org.snmp4j.smi.OctetString;

import org.snmp4j.smi.TimeTicks;

import org.snmp4j.smi.UnsignedInteger32;

import org.snmp4j.smi.VariableBinding;

import org.snmp4j.transport.DefaultUdpTransportMapping;

/**

* 模拟Trap发送消息

* @blog http://www.micmiu.com

* @author Michael

public class SnmpTrapSendDemo {

public static final int DEFAULT_VERSION = SnmpConstants.version2c;

public static final long DEFAULT_TIMEOUT = 3 * 1000L;

public static final int DEFAULT_RETRY = 3;

private Snmp snmp = null;

private CommunityTarget target = null;

public void init() throws IOException {

System.out.println("----> 初始 Trap 的IP和端口 <----");

target = createTarget4Trap("udp:127.0.0.1/162");

TransportMapping transport = new DefaultUdpTransportMapping();

snmp = new Snmp(transport);

transport.listen();

}

/**

* 向接收器发送Trap 信息

* @throws IOException

public void sendPDU() throws IOException {

PDU pdu = new PDU();

pdu.add(new VariableBinding(

new OID(".1.3.6.1.2.1.1.1.0"),

new OctetString("SNMP Trap Test.see more:http://www.micmiu.com")));

pdu.add(new VariableBinding(SnmpConstants.sysUpTime, new TimeTicks(

new UnsignedInteger32(System.currentTimeMillis() / 1000)

.getValue())));

pdu.add(new VariableBinding(SnmpConstants.snmpTrapOID, new OID(

".1.3.6.1.6.3.1.1.4.3")));

// 向Agent发送PDU

pdu.setType(PDU.TRAP);

snmp.send(pdu, target);

System.out.println("----> Trap Send END <----");

}

/**

* 创建对象communityTarget

* @param targetAddress

* @param community

* @param version

* @param timeOut

* @param retry

* @return CommunityTarget

public static CommunityTarget createTarget4Trap(String address) {

CommunityTarget target = new CommunityTarget();

target.setAddress(GenericAddress.parse(address));

target.setVersion(DEFAULT_VERSION);

target.setTimeout(DEFAULT_TIMEOUT); // milliseconds

target.setRetries(DEFAULT_RETRY);

return target;

}

/**

* @param args

public static void main(String[] args) {

try {

SnmpTrapSendDemo demo = new SnmpTrapSendDemo();

demo.init();

demo.sendPDU();

} catch (IOException e) {

e.printStackTrace();

}

运行结果：

----> 初始 Trap 的IP和端口 <----
----> Trap Send END <----

1 2	----> 初始 Trap 的IP和端口 <---- ----> Trap Send END <----

同时接收器的日志变成如下：

----> Trap Receiver run ... <----
----> 开始监听端口，等待Trap message  <----
----> 开始解析ResponderEvent: <----
1.3.6.1.2.1.1.1.0 = SNMP Trap Test.see more:http://www.micmiu.com
1.3.6.1.2.1.1.3.0 = 155 days, 9:52:04.80
1.3.6.1.6.3.1.1.4.1.0 = 1.3.6.1.6.3.1.1.4.3
---->  本次ResponderEvent 解析结束 <----

----> Trap Receiver run ... <----

----> 开始监听端口，等待Trap message <----

----> 开始解析ResponderEvent: <----

1.3.6.1.2.1.1.1.0 = SNMP Trap Test.see more:http://www.micmiu.com

1.3.6.1.2.1.1.3.0 = 155 days, 9:52:04.80

1.3.6.1.6.3.1.1.4.1.0 = 1.3.6.1.6.3.1.1.4.3

----> 本次ResponderEvent 解析结束 <----

到此基本演示结束。

原创文章，转载请注明： 转载自micmiu – 软件开发+生活点滴[ http://www.micmiu.com/ ]

本文链接地址: http://www.micmiu.com/enterprise-app/snmp/snmp4j-trap/

SNMPSNMP, snmp4j, Trap

← SNMP4j实现同步和异步的Walk的示例

org.codehaus.xfire.XFireRuntimeException: Could not invoke service.. Nested exception is org.codehaus.xfire.fault.XFireFault: There must be a method name element. →

发表评论？

9 条评论。

hans 2020 年 4 月 16 日在下午 3:10

SNMP4j实现SET的示例
SNMP4j实现GETBLUK的示例

这两篇博文催更了？？ 😆 😆

回复
杨 2019 年 1 月 16 日在下午 2:59

snmp1.11.3这个版本就没有啊，亲.其他版本
Vector<VariableBinding> vbVect = event.getPDU().getVariableBindings();
这句会出错

回复
- 杨 2019 年 1 月 16 日在下午 5:05
  
  好了，不用回复了
  
  回复
biscuit 2016 年 12 月 19 日在下午 5:32

请问你这个INtellij Idea的主题名称叫什么？

回复
- Michael 2017 年 2 月 14 日在下午 9:40
  
  这个是mac osx 下idea默认就是这个黑色的主题
  
  回复
simonqian 2014 年 11 月 17 日在下午 5:11

你这个日志信息在哪个目录下查看呀？

回复
- Michael 2014 年 11 月 24 日在下午 4:29
  
  该示例中得日志应该是控制台输出的，在实际项目中可以配置具体的日志输出路径
  
  回复
人生精彩 2014 年 1 月 24 日在下午 12:09

这个demo再同一台机器上，可以调通。当前将服务端安装在一台Linux环境中，客户端demo放在本地windows环境，将服务端拉起来，用客户端去发trap报文，服务端的代码进程没有收到trap报文，而在服务端用linux命令tcpdump udp是可以捕获到trap报文的，不知道原因是？碰到这种问题的兄弟，请协助！谢谢！

回复
- Michael 2014 年 1 月 26 日在上午 9:11
  
  我暂时没办法给你这个问题定位原因，如果服务端和客户端换一下试试，然后在windows 中 debug 下试试？
  
  回复

micmiu – 软件开发+生活点滴