下面是两个用于发送和接收Trap报文信息的类:

1. import java.io.IOException;
2. import java.net.UnknownHostException;
3. import java.util.Vector;
4. import org.snmp4j.CommandResponder;
5. import org.snmp4j.CommandResponderEvent;
6. import org.snmp4j.MessageDispatcherImpl;
7. import org.snmp4j.Snmp;
8. import org.snmp4j.TransportMapping;
9. import org.snmp4j.mp.MPv1;
10. import org.snmp4j.mp.MPv2c;
11. import org.snmp4j.mp.MPv3;
12. import org.snmp4j.security.SecurityModels;
13. import org.snmp4j.security.SecurityProtocols;
14. import org.snmp4j.security.USM;
15. import org.snmp4j.smi.Address;
16. import org.snmp4j.smi.GenericAddress;
17. import org.snmp4j.smi.OctetString;
18. import org.snmp4j.smi.TcpAddress;
19. import org.snmp4j.smi.UdpAddress;
20. import org.snmp4j.smi.VariableBinding;
21. import org.snmp4j.transport.DefaultTcpTransportMapping;
22. import org.snmp4j.transport.DefaultUdpTransportMapping;
23. import org.snmp4j.util.MultiThreadedMessageDispatcher;
24. import org.snmp4j.util.ThreadPool;
25. /**
26. * 本类用于监听代理进程的Trap信息
27. *
28. * @author zhanjia
29. *
30. */
31. public class MultiThreadedTrapReceiver implements CommandResponder {
32. private MultiThreadedMessageDispatcher dispatcher;
33. private Snmp snmp = null;
34. private Address listenAddress;
35. private ThreadPool threadPool;
36. public MultiThreadedTrapReceiver() {
37. // BasicConfigurator.configure();
38. }
39. private void init() throws UnknownHostException, IOException {
40. threadPool = ThreadPool.create("Trap", 2);
41. dispatcher = new MultiThreadedMessageDispatcher(threadPool,
42. new MessageDispatcherImpl());
43. listenAddress = GenericAddress.parse(System.getProperty(
44. "snmp4j.listenAddress", "udp:192.168.1.23/162")); // 本地IP与监听端口
45. TransportMapping transport;
46. // 对TCP与UDP协议进行处理
47. if (listenAddress instanceof UdpAddress) {
48. transport = new DefaultUdpTransportMapping(
49. (UdpAddress) listenAddress);
50. } else {
51. transport = new DefaultTcpTransportMapping(
52. (TcpAddress) listenAddress);
53. }
54. snmp = new Snmp(dispatcher, transport);
55. snmp.getMessageDispatcher().addMessageProcessingModel(new MPv1());
56. snmp.getMessageDispatcher().addMessageProcessingModel(new MPv2c());
57. snmp.getMessageDispatcher().addMessageProcessingModel(new MPv3());
58. USM usm = new USM(SecurityProtocols.getInstance(), new OctetString(MPv3
59. .createLocalEngineID()), 0);
60. SecurityModels.getInstance().addSecurityModel(usm);
61. snmp.listen();
62. }
63. public void run() {
64. try {
65. init();
66. snmp.addCommandResponder(this);
67. System.out.println("开始监听Trap信息!");
68. } catch (Exception ex) {
69. ex.printStackTrace();
70. }
71. }
72. /**
73. * 实现CommandResponder的processPdu方法, 用于处理传入的请求、PDU等信息
74. * 当接收到trap时，会自动进入这个方法
75. *
76. * @param respEvnt
77. */
78. public void processPdu(CommandResponderEvent respEvnt) {
79. // 解析Response
80. if (respEvnt != null && respEvnt.getPDU() != null) {
81. Vector<VariableBinding> recVBs = respEvnt.getPDU().getVariableBindings();
82. for (int i = 0; i < recVBs.size(); i++) {
83. VariableBinding recVB = recVBs.elementAt(i);
84. System.out.println(recVB.getOid() + " : " + recVB.getVariable());
85. }
86. }
87. }
88. public static void main(String[] args) {
89. MultiThreadedTrapReceiver multithreadedtrapreceiver = new MultiThreadedTrapReceiver();
90. multithreadedtrapreceiver.run();
91. }
92. }