snmp4j snmp4j的使用

  1 package com.main;
  2 
  3 import java.io.IOException;
  4 
  5 import org.snmp4j.CommunityTarget;
  6 import org.snmp4j.PDU;
  7 import org.snmp4j.Snmp;
  8 import org.snmp4j.TransportMapping;
  9 import org.snmp4j.event.ResponseEvent;
 10 import org.snmp4j.event.ResponseListener;
 11 import org.snmp4j.mp.SnmpConstants;
 12 import org.snmp4j.smi.Address;
 13 import org.snmp4j.smi.GenericAddress;
 14 import org.snmp4j.smi.OID;
 15 import org.snmp4j.smi.OctetString;
 16 import org.snmp4j.smi.VariableBinding;
 17 import org.snmp4j.transport.DefaultUdpTransportMapping;
 18 
 19  
 20 /**
 21  *以廣播的方式發送snmp并獲取設備的信息
 22  *
 23  * @author PC
 24  * 
 25  */
 26 public class Manager {
 27 
 28     /**
 29      * @param args
 30      */
 31     public static void main(String[] args) {
 32         // TODO Auto-generated method stub
 33         
 34         System.out.println("管理端启动。。。");
 35         
 36         send();
 37         
 38         System.out.println("success");
 39     }
 40 
 41     // 发送数据到目标机器
 42     public static void send() {
 43 
 44         TransportMapping transport = null;
 45         
 46         try {
 47             // 传输协议为UDP
 48             transport = new DefaultUdpTransportMapping();
 49         } catch (IOException e) {
 50             // TODO Auto-generated catch block
 51             e.printStackTrace();
 52         }
 53         // 创建snmp对象，发送报文
 54         Snmp snmp = new Snmp(transport);
 55 
 56         try {
 57             snmp.listen();
 58         } catch (IOException e1) {
 59             // TODO Auto-generated catch block
 60             e1.printStackTrace();
 61         }
 62 
 63         OID oid = new OID("1.3.6.1.2.2.1.0");
 64         // 报文
 65         PDU pdu = new PDU();
 66         VariableBinding variableBinding = new VariableBinding(oid);
 67         pdu.add(variableBinding);
 68         pdu.setType(PDU.GET);
 69 
 70         // 目标
 71         CommunityTarget target = new CommunityTarget();
 72 
 73         // 设置snmp共同体
 74         OctetString oct = new OctetString("public");
 75         target.setCommunity(oct);
 76 
 77         // 向255.255.255.255发送UPD数据包即为UDP广播，接收端只需绑定UDP广播的端口号即可得到数据
 78         Address address = GenericAddress.parse("udp:192.168.0.254/161");
 79         target.setAddress(address);
 80         target.setRetries(2);
 81         target.setTimeout(5000);
 82         target.setVersion(SnmpConstants.version1);
 83 
 84         // 设置监听对象
 85         ResponseListener listener = new ResponseListener() {
 86             public void onResponse(ResponseEvent event) {
 87                 ((Snmp) event.getSource()).cancel(event.getRequest(), this);
 88                 PDU request = event.getRequest();
 89                 PDU response = event.getResponse();
 90                 if (response != null) {
 91                     System.out.println("request.size()=" + request.size());
 92                     System.out.println("response.size()=" + response.size());
 93                 }
 94             }
 95         };
 96 
 97         try {
 98             snmp.send(pdu, target, null, listener);
 99         } catch (IOException e) {
100             // TODO Auto-generated catch block
101             e.printStackTrace();
102         }
103     }
104 
105 }

  1 package com.main;
  2 
  3 import java.io.IOException;
  4 
  5 import org.snmp4j.CommunityTarget;
  6 import org.snmp4j.PDU;
  7 import org.snmp4j.Snmp;
  8 import org.snmp4j.TransportMapping;
  9 import org.snmp4j.event.ResponseEvent;
 10 import org.snmp4j.mp.SnmpConstants;
 11 import org.snmp4j.smi.Address;
 12 import org.snmp4j.smi.GenericAddress;
 13 import org.snmp4j.smi.OID;
 14 import org.snmp4j.smi.OctetString;
 15 import org.snmp4j.smi.VariableBinding;
 16 import org.snmp4j.transport.DefaultUdpTransportMapping;
 17 
 18 public class Monitor {
 19  
 20     // systemDescr
 21         static final String OID1 = "1.3.6.1.2.1.1.1.0";
 22         // eth0
 23         static final String OID2 = "1.3.6.1.2.1.2.2.1.2.2";
 24         // MAC
 25         static final String OID3 = "1.3.6.1.2.1.2.2.1.6.2";
 26         
 27         static final String OID4 = "1.3.6.1.2.1.1.1";
 28         
 29         //static final int [] OID5 = {1,3,6,1,2,1,1,2}; 与第一个一样
 30         
 31     /**
 32      * @param args
 33      */
 34     public static void main(String[] args) {
 35         // TODO Auto-generated method stub
 36         GetOID();
 37     }
 38 
 39     /**
 40      * 获得本机oid
 41      */
 42     public static void GetOID() {
 43 
 44         TransportMapping transport = null;
 45 
 46         try {
 47             // 传输协议udp
 48             transport = new DefaultUdpTransportMapping();
 49             transport.listen();
 50         } catch (IOException e1) {
 51             // TODO Auto-generated catch block
 52             e1.printStackTrace();
 53         }
 54 
 55         // 構造報文
 56         PDU request = new PDU();        
 57         request.add(new VariableBinding(new OID(OID1)));  
 58         request.add(new VariableBinding(new OID(OID2)));
 59         request.add(new VariableBinding(new OID(OID3)));
 60         
 61         request.add(new VariableBinding(new OID(OID4)));  
 62         //request.add(new VariableBinding(new OID(OID5)));
 63 
 64         request.setType(PDU.GETNEXT);
 65 
 66         // snmp初始化
 67         Snmp snmp = new Snmp(transport);
 68 
 69         // 構造目標
 70         CommunityTarget target = new CommunityTarget();
 71         Address localAddress =GenericAddress.parse("udp:localhost/161");
 72         target.setAddress(localAddress);
 73         OctetString oct = new OctetString("public");
 74         target.setCommunity(oct);
 75         target.setVersion(SnmpConstants.version2c);
 76         target.setRetries(2);
 77         target.setTimeout(5 * 60);
 78 
 79         try {
 80             // 發送報文
 81             ResponseEvent responseEvent = snmp.send(request, target);
 82         
 83                 PDU response = responseEvent.getResponse();
 84                 if (response != null) {
 85                 System.out.println("request.size()=" + request.size());
 86                 System.out.println("response.size()=" + response.size());
 87                 VariableBinding vb1 = response.get(0);
 88                 VariableBinding vb2 = response.get(1);
 89                 VariableBinding vb3 = response.get(2);
 90                 VariableBinding vb4 = response.get(3);
 91                 //VariableBinding vb5 = response.get(4);
 92                 System.out.println(vb1);
 93                 System.out.println(vb2);
 94                 System.out.println(vb3);
 95                 System.out.println(vb4);
 96                 //System.out.println(vb5);
 97                 
 98                 //释放
 99                 transport.close();
100             }
101         } catch (IOException e) {
102             // TODO Auto-generated catch block
103             e.printStackTrace();
104         }
105     }
106 }