snmp4j snmp4j的使用

snmp4j的使用

一.什么是snmp及snmp4j？

snmp是 Simple Network Management Protocol (简单网络管理协议)的简写。

SNMP4J是一个用Java来实现SNMP(简单网络管理协议)协议的开源项目.它支持以命令行的形式进行管理与响应。SNMP4J是纯面向对象设计与SNMP++(用C++实现SNMPv1/v2c/v3)相类似。

参考百度百科：

http://baike.baidu.com/link?url=fzj8rJp06yZBxx4MRVTYu5Iiub45QmK3WVzVC30tDtXFQmMJZkfEA9yfcP2E1HJz4bSYh9oNCc5zQVr7gmceP_

二.步骤：

管理端步骤：

1.设定传输协议
2.snmp初始化
3.构造发送报文
4.构造发送目标
5.构造响应监听（异步）
6.发送

监控端步骤：

1.设定传输协议
2.snmp初始化
3.构造发送报文
4.构造发送目标
5.发送并返回响应
6.处理返回结果

三.snmp常用的类：

import org.snmp4j.CommunityTarget;
import org.snmp4j.PDU;
import org.snmp4j.Snmp;
import org.snmp4j.TransportMapping;
import org.snmp4j.event.ResponseEvent;
import org.snmp4j.mp.SnmpConstants;
import org.snmp4j.smi.Address;
import org.snmp4j.smi.GenericAddress;
import org.snmp4j.smi.OID;
import org.snmp4j.smi.OctetString;
import org.snmp4j.smi.VariableBinding;
import org.snmp4j.transport.DefaultUdpTransportMapping;

别看这么多包就吓怕了，遇事不惊才是站到最后的人，下面我们一起来研究他们的用法，按照如上步骤：

我就以管理端的方式讲解：

工具的重要性不说大家都懂的，能事半功倍的效果：建议大家先下载snmp4j api文档。然后跟着我一起研究：

首先我们把一个大问题划分成几个小问题，个个击破，于是一个大问题就解决了：（参考下面的demo熟悉snmp协议及snmp4j）

1.设定传输协议：

TransportMapping接口：此该接口代表了SNMP4J所使用的传输层协议。这也是SNMP4J一大特色的地方。按照RFC的规定，SNMP是只使用UDP作为传输层协议的。而SNMP4J支持管理端和代理端使用UDP或者TCP进行传输。该接口有两个子接口。（查看api文档）

在Package org.snmp4j.transport这个包下有一个类设定了传输方式为udp:这个类就是DefaultUdpTransportMapping，使用时只需实例化它即可。

2.初始化snmp:

snmp：这个类主要用来收发数据，它主要有一个send方法，这个很重要，有很多重载。查看文档。

3.构造报文（PDU）：

PDU:就是要通信的数据。

4.构造目标：

CommunityTarget：要发送通信数据要去的目标。

5.监听：

ResponseListener：负责监听并回调对应的函数处理。

ResponseListener listener = new ResponseListener() {
   public void onResponse(ResponseEvent event) {
    ((Snmp) event.getSource()).cancel(event.getRequest(), this);
    PDU request = event.getRequest();
    PDU response = event.getResponse();
    if (response != null) {
     System.out.println("request.size()=" + request.size());
     System.out.println("response.size()=" + response.size());
    }
   }
  };

6.发送：

发送:就是指将pdu（数据）发送到target（目标）机器,监听返回的数据并作响应。

snmp.send(pdu, target, null, listener)；

snmp、pdu及target之间的关系可以用一句话概括：

Target就是你远方的恋人，PDU就是你们之间传递的情书、而Snmp就是负责帮你寄信收信的邮差。

四.demo:（以广播的方式）

1.管理端：

  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 }

2.监控端：(获取本地信息)

  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 }

五.MIB：

常用OID:

学习就是学习别人的思维，学习别人遇到问题的处理方式。

-------------思路之重