现在的位置: 首页 > 综合 > 正文

利用SNMP4J编写 snmp trap的接收程序实现短信报警

2014年02月13日 ⁄ 综合 ⁄ 共 6152字 ⁄ 字号 小 中 大 ⁄ 评论关闭
代码部分来自于互联网

  1. /** *//**
  2.  * 测试snmp4j 中trap的接收方法.这里只测试了v1和v2的trap.
  3.  * trap接收原理:snmp实例在注册了实现CommandResponder的listener之后,可以通过异步调用的方法
  4.     * 将收到内容输出.
  5.  * listen()启动监听线程,该线程中的操作是监听指定端口,在收到trap告警之后将调用
  6.  * listener.processPdu(CommandResponderEvent event)方法,由processPdu来处理trap信息.
  7.  */
  8. import java.sql.Connection;
  9. import java.sql.DriverManager;
  10. import java.sql.ResultSet;
  11. import java.sql.Statement;
  13. import org.snmp4j.CommandResponder;
  14. import org.snmp4j.CommandResponderEvent;
  15. import org.snmp4j.PDU;
  16. import org.snmp4j.Snmp;
  17. import org.snmp4j.TransportMapping;
  18. import org.snmp4j.smi.UdpAddress;
  19. import org.snmp4j.transport.DefaultUdpTransportMapping;
  20. import org.jsmsengine.*;
  23. public class TrapTest{
  24.     public static void main(String[] args){
  25.         
  26.         try{
  27.             //snmp4j通过transportmapping的监听端口接收SNMP信息,所以这里初始化一个
  28.                 //transportmapping,
  29.             //注明本机的IP地址及接收trap的端口.
  30.             TransportMapping transport = new DefaultUdpTransportMapping(new UdpAddress("192.168.10.2/162"));
  31.             //创建一个处理消息的snmp实例
  32.             Snmp snmp = new Snmp(transport);
  34.             //CommandResponder是一个listener,用以处理获取的trap消息
  35.             CommandResponder trapPrinter = new CommandResponder(){
  36.                 public synchronized void processPdu(CommandResponderEvent e){
  37.                     PDU command = e.getPDU();
  38.                     if(command!=null){
  39.                         //这里示例输出trap的内容.具体的trap解析等工作在这里进行.
  40.                         System.out.println(command.toString());
  41.                       
  42.                         sendmesg(command.toString());
  43.                         try{
  44.                          DriverManager.registerDriver(new oracle.jdbc.OracleDriver());
  45.                           try{
  46.                               Class.forName("oracle.jdbc.driver.OracleDriver");
  47.                             }catch(Exception e3){
  48.                               System.out.println("No Driver!");
  49.                             }
  50.                             String url = "jdbc:oracle:thin:@local:1521:date";
  51.                             String userName = "user;
  52.                             String password = "pass";
  53.                             Connection conn =DriverManager.getConnection (url, userName, password);
  54.                             // Create a Statement
  55.                             Statement stmt = conn.createStatement ();
  57.                            // Select the ENAME column from the EMP table
  58.                         
  59.                             
  60.                           }catch(Exception e2)
  61.                         {
  62.                             System.out.println(e2);
  63.                         } 
  64.                     }
  65.                 }
  66.             };
  67.             
  68.             //在snmp实例中添加CommandResponder listener
  69.             snmp.addCommandResponder(trapPrinter);
  70.         
  71.             System.out.println("start listening!");
  72.             //开始启动trap监听.listen()方法内部启动了一个线程,这个线程监听发送到transport中定义的端口
  73.                 //的消息.
  74.             transport.listen();
  75.             System.out.println(transport.isListening());//测试监听是否正常
  76.             
  77.             //等待一段测试时间,在这段时间可以发送trap信息测试.
  78.             Thread.sleep(180000);
  80.         } catch (Exception e) {
  81.             e.printStackTrace();
  82.         }
  83.     }
  84.     public static  void sendmesg(String meesage)
  85.     {
  86.         
  88.         CService srv = new CService("COM3", 9600, "Nokia", "6310i");
  90.         System.out.println();
  91.         System.out.println("SendMessage(): sample application.");
  92.         System.out.println("  Using " + srv._name + " " + srv._version);
  93.         System.out.println();
  94.         try
  95.         {
  96.              
  97.             srv.setSimPin("0000");
  98.             srv.connect();
  100.             srv.setSmscNumber("");
  102.             System.out.println("Mobile Device Information: ");
  103.             System.out.println("    Manufacturer  : " + srv.getDeviceInfo().getManufacturer());
  104.             System.out.println("    Model         : " + srv.getDeviceInfo().getModel());
  105.             System.out.println("    Serial No     : " + srv.getDeviceInfo().getSerialNo());
  106.             System.out.println("    IMSI          : " + srv.getDeviceInfo().getImsi());
  107.             System.out.println("    S/W Version   : " + srv.getDeviceInfo().getSwVersion());
  108.             System.out.println("    Battery Level : " + srv.getDeviceInfo().getBatteryLevel() + "%");
  109.             System.out.println("    Signal Level  : " + srv.getDeviceInfo().getSignalLevel() + "%");
  110.             
  111.             try{
  112.                  DriverManager.registerDriver(new oracle.jdbc.OracleDriver());
  113.                   try{
  114.                       Class.forName("oracle.jdbc.driver.OracleDriver");
  115.                     }catch(Exception e){
  116.                       System.out.println("No Driver!");
  117.                     }
  118.                     String url = "jdbc:oracle:thin:@loacl:1521:data";
  119.                     String userName = "user";
  120.                     String password = "pass";
  121.                     Connection conn =DriverManager.getConnection (url, userName, password);
  122.                     // Create a Statement
  123.                     Statement stmt = conn.createStatement ();
  125.                    // Select the ENAME column from the EMP table
  126.                     ResultSet rset = stmt.executeQuery ("select * from WARNING");
  127.                     // Iterate through the result and print the employee names
  128.                     String number=null;
  129.                     while(rset.next())
  130.                     {   
  131.                     number=rset.getString("WARTEL");
  132.                     
  133.                     COutgoingMessage msg = new COutgoingMessage(number,meesage");
  134.                     msg.setMessageEncoding(CMessage.MESSAGE_ENCODING_7BIT);
  135.                     msg.setSourcePort(15000);
  136.                     msg.setDestinationPort(16000);
  138.                     srv.sendMessage(msg);
  140.                     srv.disconnect();
  141.                     }
  142.                    
  143.                     rset.clearWarnings();
  144.                     rset.close();
  145.                     stmt.clearWarnings();
  146.                     stmt.close();
  147.                     conn.clearWarnings();
  148.                     conn.close();
  149.             }catch(Exception e2)
  150.             {
  151.                 System.out.println(e2);
  152.             } 
  153.         }
  154.         catch (Exception e)
  155.         {
  156.             e.printStackTrace();
  157.         }
  158.         System.exit(0);
  159.     }
  160. }
返回
【上篇】
【下篇】

作者:

抱歉!评论已关闭.

返回首页

Copyright © 2013-2018 学步园  保留所有权利.
软文销售 QQ客服：2265327166 点击这里给我发消息（其他合作也可洽谈）
必威体育
必威电竞