snmp 协议 --- Java使用 snmp4j 获取 数据(linux)


通过yum安装服务

yum install -y net-snmp
yum install -y net-snmp-devel
yum install -y net-snmp-libs
yum install -y net-snmp-perl
yum install -y net-snmp-utils
yum install -y mrtg

修改配置,使之可用查看机器的数据

cd /etc/snmp
vim snmpd.conf 

找到具体位置 然后改成这样

####
# First, map the community name "public" into a "security name"
#       sec.name  source          community
com2sec notConfigUser  default       public
com2sec notConfigUser  localhost     public

####
# Second, map the security name into a group name:
#       groupName      securityModel securityName
group   notConfigGroup v1           notConfigUser
group   notConfigGroup v2c           notConfigUser

# Second, map the security name into a group name:
#       groupName      securityModel securityName
group   notConfigGroup v1           notConfigUser
group   notConfigGroup v2c           notConfigUser

####
# Third, create a view for us to let the group have rights to:
# Make at least  snmpwalk -v 1 localhost -c public system fast again.
#       name           incl/excl     subtree         mask(optional)
view    all    included   .1
view    systemview    included   .1.3.6.1.2.1.1
view    systemview    included   .1.3.6.1.2.1.25.1.1

####
# Finally, grant the group read-only access to the systemview view.
#       group          context sec.model sec.level prefix read   write  notif
access  notConfigGroup ""      any       noauth    exact  all    none   none

# -----------------------------------------------------------------------------

然后 esc :wq 保存退出

启动snmp

输入 service snmpd start 并用 service snmpd status 查看服务状态。

Java代码

 		<dependency>
            <groupId>org.snmp4j</groupId>
            <artifactId>snmp4j</artifactId>
            <version>2.8.2</version>
        </dependency>



import java.io.IOException;

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;

/**
 * 

* ClassName: GetOID *

*

* Description:获得本机的信息 *

* */ public class testSNMP { public static void main(String[] args) throws Exception { try { // 设定CommunityTarget CommunityTarget myTarget = new CommunityTarget(); // 定义远程主机的地址 // Address deviceAdd = // GenericAddress.parse("udp:192.168.1.233/161"); // 定义本机的地址 Address localAdd = GenericAddress.parse("udp:192.168.1.130/161"); // 设定远程主机的地址 // myTarget.setAddress(deviceAdd); // 设定本地主机的地址 myTarget.setAddress(localAdd); // 设置snmp共同体 myTarget.setCommunity(new OctetString("public")); // 设置超时重试次数 myTarget.setRetries(2); // 设置超时的时间 myTarget.setTimeout(5 * 60); // 设置使用的snmp版本 myTarget.setVersion(SnmpConstants.version2c); // 设定采取的协议 // 设定传输协议为UDP TransportMapping transport = new DefaultUdpTransportMapping(); // 调用TransportMapping中的listen()方法,启动监听进程,接收消息,由于该监听进程是守护进程,最后应调用close()方法来释放该进程 transport.listen(); // 创建SNMP对象,用于发送请求PDU Snmp protocol = new Snmp(transport); // 创建请求pdu,获取mib PDU request = new PDU(); // 调用的add方法绑定要查询的OID // linux常见的oid https://www.cnblogs.com/yesong8553305/p/3709535.html request.add(new VariableBinding(new OID( ".1.3.6.1.2.1.1.1"))); request.add(new VariableBinding(new OID(".1.3.6.1.2.1.1.3"))); request.add(new VariableBinding(new OID(".1.3.6.1.2.1.1.2"))); request.add(new VariableBinding(new OID(".1.3.6.1.4.1.2021.4.5.0"))); // 调用setType()方法来确定该pdu的类型 request.setType(PDU.GETNEXT); // 调用 send(PDU pdu,Target target)发送pdu,返回一个ResponseEvent对象 ResponseEvent responseEvent = protocol.send(request, myTarget); // 通过ResponseEvent对象来获得SNMP请求的应答pdu,方法:public PDU getResponse() PDU response = responseEvent.getResponse(); // 输出 if (response != null) { System.out.println("request.size()=" + request.size()); System.out.println("response.size()=" + response.size()); // 通过应答pdu获得mib信息(之前绑定的OID的值),方法:VaribleBinding get(int index) for (int i = 0; i < response.size(); i++) { VariableBinding vb1 = response.get(i); System.out.println(vb1); } // 调用close()方法释放该进程 transport.close(); } } catch (IOException e) { e.printStackTrace(); } } }

在这里插入图片描述

附: 锐捷交换机 获取各个端口的流量 流入 流出的数据



import java.io.IOException;
import java.util.Vector;

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;


public class testSNMP {

    public static void main(String[] args) throws Exception {

        try {
            // 设定CommunityTarget
            CommunityTarget myTarget = new CommunityTarget();
            // 定义机器的地址
            Address localAdd = GenericAddress.parse("udp:192.168.1.254/161");
            // 设定机器的地址
            myTarget.setAddress(localAdd);
            // 设置snmp共同体
            myTarget.setCommunity(new OctetString("ruijie"));
            // 设置超时重试次数
            myTarget.setRetries(2);
            // 设置超时的时间
            myTarget.setTimeout(5 * 60);
            // 设置使用的snmp版本
            myTarget.setVersion(SnmpConstants.version2c);

            // 设定采取的协议 // 设定传输协议为UDP
            TransportMapping transport = new DefaultUdpTransportMapping();
            // 调用TransportMapping中的listen()方法,启动监听进程,接收消息,由于该监听进程是守护进程,最后应调用close()方法来释放该进程
            transport.listen();
            // 创建SNMP对象,用于发送请求PDU
            Snmp protocol = new Snmp(transport);
            // 创建请求pdu,获取mib
            PDU request = new PDU();
            // 调用的add方法绑定要查询的OID
            for (int i = 0; i < 28; i++) {
                //28个接口 输入字节数
                request.add(new VariableBinding(new OID(".1.3.6.1.2.1.31.1.1.1.6." + i)));
            }
            for (int i = 0; i < 28; i++) {
                //28个接口 输出字节数
                request.add(new VariableBinding(new OID(".1.3.6.1.2.1.31.1.1.1.10." + i)));
            }
            // 调用setType()方法来确定该pdu的类型
            request.setType(PDU.GETNEXT);
            // 调用 send(PDU pdu,Target target)发送pdu,返回一个ResponseEvent对象
            ResponseEvent responseEvent = protocol.send(request, myTarget);
            // 通过ResponseEvent对象来获得SNMP请求的应答pdu,方法:public PDU getResponse()
            PDU response = responseEvent.getResponse();
            Vector<? extends VariableBinding> vector = response.getVariableBindings();
            // 输出
            System.err.println(vector.toString());
            // 通过应答pdu获得mib信息(之前绑定的OID的值),方法:VaribleBinding get(int index)
            for (int i = 0; i < response.size(); i++) {
                VariableBinding vb1 = response.get(i);
                System.out.println(vb1);
            }
            // 调用close()方法释放该进程
            transport.close();
        } catch (IOException e) {
            e.printStackTrace();
        }
    }
}

在这里插入图片描述