使用snmp4j监听和发送消息

news/2024/7/4 8:47:35

MultiThreadedTrapReceiver类：用于接收trap消息

 

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

 

 SendTrap类：用于发送trap消息

 

Java代码   收藏代码
  1. import java.util.Vector;    
  2. import org.snmp4j.CommunityTarget;    
  3. import org.snmp4j.PDU;    
  4. import org.snmp4j.Snmp;    
  5. import org.snmp4j.TransportMapping;    
  6. import org.snmp4j.event.ResponseEvent;    
  7. import org.snmp4j.mp.SnmpConstants;    
  8. import org.snmp4j.smi.Address;    
  9. import org.snmp4j.smi.GenericAddress;    
  10. import org.snmp4j.smi.OID;    
  11. import org.snmp4j.smi.OctetString;    
  12. import org.snmp4j.smi.VariableBinding;    
  13. import org.snmp4j.transport.DefaultUdpTransportMapping;    
  14.     
  15. /**  
  16.  * 代理端，发送trap消息  
  17.  *  
  18.  */    
  19. public class SendTrap {    
  20.     private Snmp snmp = null;    
  21.     
  22.     private Address targetAddress = null;    
  23.     
  24.     public void initComm() throws IOException {    
  25.     
  26.         // 设置管理进程的IP和端口    
  27.         targetAddress = GenericAddress.parse("udp:127.0.0.1/162");    
  28.         TransportMapping transport = new DefaultUdpTransportMapping();    
  29.         snmp = new Snmp(transport);    
  30.         transport.listen();    
  31.     
  32.     }    
  33.     
  34.     /**  
  35.      * 向管理进程发送Trap报文  
  36.      *   
  37.      * @throws IOException  
  38.      */    
  39.     public void sendPDU() throws IOException {    
  40.     
  41.         // 设置 target    
  42.         CommunityTarget target = new CommunityTarget();    
  43.         target.setAddress(targetAddress);    
  44.     
  45.         // 通信不成功时的重试次数    
  46.         target.setRetries(2);    
  47.         // 超时时间    
  48.         target.setTimeout(1500);    
  49.         // snmp版本    
  50.         target.setVersion(SnmpConstants.version2c);    
  51.     
  52.         // 创建 PDU    
  53.         PDU pdu = new PDU();    
  54.         pdu.add(new VariableBinding(new OID(".1.3.6.1.2.3377.10.1.1.1.1"),    
  55.                 new OctetString("SnmpTrap")));    
  56.         pdu.add(new VariableBinding(new OID(".1.3.6.1.2.3377.10.1.1.1.2"),    
  57.                 new OctetString("JavaEE")));    
  58.         pdu.setType(PDU.TRAP);    
  59.     
  60.         // 向Agent发送PDU，并接收Response    
  61.         ResponseEvent respEvnt = snmp.send(pdu, target);    
  62.     
  63.         // 解析Response    
  64.         if (respEvnt != null && respEvnt.getResponse() != null) {    
  65.             Vector<VariableBinding> recVBs = respEvnt.getResponse()    
  66.                     .getVariableBindings();    
  67.             for (int i = 0; i < recVBs.size(); i++) {    
  68.                 VariableBinding recVB = recVBs.elementAt(i);    
  69.                 System.out    
  70.                         .println(recVB.getOid() + " : " + recVB.getVariable());    
  71.             }    
  72.         }    
  73.     }    
  74.     
  75.     public static void main(String[] args) {    
  76.         try {    
  77.             SendTrap sender = new SendTrap();    
  78.             sender.initComm();    
  79.             sender.sendPDU();    
  80.         } catch (IOException e) {    
  81.             e.printStackTrace();    
  82.         }    
  83.     }    
  84. }  

1、运行MultiThreadedTrapReceiver类，提示“开始监听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输出面板中显示以上两行即表示测试成功！


http://www.niftyadmin.cn/n/3311923.html

相关文章

搭建C++编译环境

搭建C++编译环境

2019独角兽企业重金招聘Python工程师标准>>> 安装git&#xff0c;g gcc 并且升级到4.9版本&#xff0c;用premake 从vs工程 输出为makefile 等 --安装git sudo add-apt-repository ppa:git-core/ppa sudo apt-get update sudo apt-get install git --安装g sudo ap…
阅读更多...
php 登陆程序,PHP(10) 用户登录程序(版本2)

php 登陆程序,PHP(10) 用户登录程序(版本2)

用户登录程序(版本2)今天&#xff0c;我们把我们上一篇博文中的小项目做一个升级版本&#xff01;1、产生彩色的验证码在上一篇文中&#xff0c;我们产生了随机的验证码&#xff0c;但是我们在有的网站上看到的验证码是彩色的&#xff0c;那么&#xff0c;我们怎么来产生彩色的…
阅读更多...
【语言处理与Python】3.5正则表达式的有益作用

【语言处理与Python】3.5正则表达式的有益作用

提取字符块 #找到所有的无重叠的匹配指定的正则表达式re.findall(r’[aeiou]’,word)#看看一些文本中的两个或者两个以上的元音序列&#xff0c;并确定他们的相对频率wsfsorted((set(nltk.corpus.treebank.words()))fdnltk.FreqDist(vs for word in wsjfor vs in re.findall(r’…
阅读更多...
yiic.php,执行yiic命令提示’php.exe’将YII添加到系统环境变量

yiic.php,执行yiic命令提示’php.exe’将YII添加到系统环境变量

还有个问题就是每次执行yiic命令时要把yiic的全路径打出来才行,比如我的yii框架在F:\myproject里面,我每次执行的时候都要F:\myproject\yii\framework\yiic webapp yiiblog我们可以把yiic也加入系统环境变量,加入以下代码:假如php.exe这个目录在E:\Server\phpF:\myproject\yii\…
阅读更多...
cvs和svn的区别

cvs和svn的区别

1> cvs是不支持文件的复制 移动和重命名 而svn支持 2> cvs在网络中断等时 提交的部分文件也会生效 而svn当用户全部提交完变更的文件时 才会生效 否则直接回滚 变成最初状态 3> 版本控制上 对于一个文件foo.c 在cvs1.1 版本和1.2版本始终是不相同的 而svn中有可能相…
阅读更多...
2018年哪项AI研究最紧迫？DeepMind联合创始人说是AI伦理

2018年哪项AI研究最紧迫？DeepMind联合创始人说是AI伦理

本文来自AI新媒体量子位&#xff08;QbitAI&#xff09;2018年&#xff0c;正火热的人工智能会朝什么方向发展&#xff1f; DeepMind联合创始人苏莱曼&#xff08;Mustafa Suleyman&#xff09;今天在《连线》上发表文章&#xff0c;给出了他心目中的答案。 苏莱曼在DeepMind主…
阅读更多...
egojit介绍

egojit介绍

姓名&#xff1a;Egojit 出生年月&#xff1a;1989-10-13 QQ&#xff1a;408365330 E-mail&#xff1a;egojitqq.com 这就是我和我对技术的认知&#xff1a;一直在追求技术的提升&#xff0c;从学习C开始爱上IT&#xff0c;从.NET走进IT行业。执迷于Windows内核开发&#xff0c…
阅读更多...
java编写一个类显示出当前日期,Java惯用类库-实例操作-取得当前日期

java编写一个类显示出当前日期,Java惯用类库-实例操作-取得当前日期

import java.util.* ;// 导入需要的工具包class DateTime{// 以后直接通过此类就可以取得日期时间private Calendar calendar null ;// 声明一个Calendar对象&#xff0c;取得时间public DateTime(){// 构造方法中直接实例化对象this.calendar new GregorianCalendar() ;}pub…
阅读更多...
最新文章

Copyright @ 2022~2023