`

java用com.adventnet包读mib

    博客分类:
  • SNMP
阅读更多
public static boolean readMibWalk(String ip, String community, SnmpOID[] oids, Vector[] resultList, Vector indexList) {
        SnmpAPI snmpapi = null;
        SnmpSession session = null;
        try {
            snmpapi = new SnmpAPI();
            snmpapi.start();
            session = new SnmpSession(snmpapi);
            session.open();

            SnmpPDU pdu = new SnmpPDU();
            pdu.setRemoteHost(ip); //OLT上的ip
            pdu.setRemotePort(161);
            pdu.setCommunity(community);
            pdu.setTimeout(5000);
            pdu.setRetries(2);
            pdu.setVersion(SnmpAPI.SNMP_VERSION_2C);
            pdu.setCommand(SnmpAPI.GETNEXT_REQ_MSG);
            for (int i = 0; i < oids.length; i++) { //第几个列(也就是第几个参数) ,i是列号
                pdu.addNull(oids[i]);
                resultList[i] = new Vector();
                while (true) {   //循环 ,读取每一行
                    SnmpPDU v = session.syncSend(pdu);  //本次读回来得到的内容,下面是解析了
                    if (v == null) {
                        return false;
                    }
                    if (isInSubTree(oids[i].toIntArray(), v.getObjectID(0))) { //通过列的oid,去判断读的是不是还是这个列
                        String t = v.getVariableBinding(0).toString(); //索引+ 值
                        int index = t.indexOf(":");
                        resultList[i].add(t.substring(index + 2)); //存值
                        pdu.removeVariableBinding(0);  //移除上一个行号
                        pdu.addNull(v.getObjectID(0)); //绑定当前行号,可以去读下一行
                        if (i == 0) {   //读第一列的时候,记录索引号
                            String d = getIndexs(oids[i].toIntArray(), v.getObjectID(0)); //得到索引值
                            indexList.add(d);
                        }
                    } else {
                        break;
                    }
                }
                pdu.removeVariableBinding(0);
            }
        } catch (Exception ex) {
            ex.printStackTrace();
            return false;
        } finally {
            if (null != session) {
                snmpapi.close();
                session.close();
                session = null;
            }
        }
        return true;
    }

 

public static boolean readMibBulk(String ip, String community, SnmpOID[] oids, Vector[] resultList, Vector indexList) {
        SnmpAPI snmpapi = null;
        SnmpSession session = null;
        int maxRepInt = 25;  //设置每次读的行数
        try {
            snmpapi = new SnmpAPI();
            snmpapi.start();
            session = new SnmpSession(snmpapi);
            session.open();

            SnmpPDU pdu = new SnmpPDU();
            pdu.setRemoteHost(ip);
            pdu.setRemotePort(161);
            pdu.setCommunity(community);
            pdu.setTimeout(5000);
            pdu.setRetries(2);
            pdu.setVersion(SnmpAPI.SNMP_VERSION_2C);
            pdu.setCommand(SnmpAPI.GETBULK_REQ_MSG);
            pdu.setMaxRepetitions(maxRepInt);
            pdu.setNonRepeaters(0);

            for (int i = 0; i < oids.length; i++) {
                pdu.addNull(oids[i]);
                resultList[i] = new Vector();
                while (true) {
                    SnmpPDU v = session.syncSend(pdu);
                    if (v == null) {
                        return false;
                    }
                    int j = 0;
                    SnmpOID loid = null;
                    for (j = 0; j < maxRepInt; j++) {  //再加了一个循环,循环这25行内是否有异常数据
                        if (isInSubTree(oids[i].toIntArray(), v.getObjectID(j))) {
                            String t = v.getVariableBinding(j).toString();
                            int index = t.indexOf(":");
                            resultList[i].add(t.substring(index + 2));
                            pdu.removeVariableBinding(j);
                            loid = v.getObjectID(j); //记录当前行号
                            String d = getIndexs(oids[i].toIntArray(), v.getObjectID(j));
                            indexList.add(d); //一直记录索引号,其实可以加上 if (i == 0)语句的
                        } else {
                            break; //如果读回来的25行中,第几行不是了,那么跳出循环
                        }
                    }
                    //是否是读完25行,没有跳出
                    if (j == maxRepInt) { //是,那么去读下一个25行,从loid行开始
                        pdu.addNull(loid);
                    } else {
                        break; //不是,有异常数据,接着跳出while循环
                    }
                }
                pdu.removeVariableBinding(0); // 读取下一列
            }
        } catch (Exception ex) {
            ex.printStackTrace();
            return false;
        } finally {
            if (null != session) {
                snmpapi.close();
                session.close();
                session = null;
            }
        }
        return true;

    }

 

public static boolean isInSubTree(int oids[], SnmpOID snmpoid) { //oid设定的oid值,snmpoid为当前读取的oid值
        if (snmpoid == null) {
            return false;
        }
        int ai1[] = (int[]) snmpoid.toValue();
        if (ai1 == null) {
            return false;
        }
        int i = oids.length;
        if (ai1.length < i) {
            return false;
        }
        for (int j = i - 1; j >= 0; j--) {
            if (ai1[j] != oids[j]) {
                return false;
            }
        }
        return true;
    }

    public static String getIndexs(int[] oids, SnmpOID snmpoid) {
        String ret = "";
        if (snmpoid == null) {
            return "";
        }
        int ai1[] = (int[]) snmpoid.toValue();
        if (ai1 == null) {
            return "";
        }
        int i = oids.length;
        if (ai1.length < i) {
            return "";
        }
        for (int j = i - 1; j >= 0; j--) {
            if (ai1[j] != oids[j]) {
                return "";
            }
        }
        for (int k = i; k < ai1.length; k++) {
            ret = ret + ai1[k];
            ret = ret + ".";
        }
        return ret;
    }

 

分享到:
评论

相关推荐

    AdventNet_Agent_Toolkit_Java_Edition_6_0_0_keymaker

    AdventNet_Agent_Toolkit_Java_Edition_6_0_0_keygen

    AdventNet_Agent_Toolkit_Java_Edition_6_0_0

    综上所述,AdventNet Agent Toolkit Java Edition 6.0.0是一个全面的SNMP开发平台,它简化了MIB的解析、代理的开发和测试,是网络管理软件开发者不可或缺的工具。通过这款工具,开发者能够更高效地实现网络设备的...

    基于SNMP/MIB的网络数据获取系统设计与实现

    本文将深入探讨如何使用Java语言和AdventNet SNMP API来设计和实现一个基于SNMP/MIB的网络数据获取系统。 首先,SNMP是一种应用层协议,运行在TCP/IP协议栈上,主要用于网络设备的管理和监控。它提供了标准的通信...

    ireasoning Mib Browser

    ireasoning MIB Browser是一款专业的MIB浏览软件,虽然在某些方面可能略逊于AdventNet的MIB浏览器,但它依然具有相当的实用价值,尤其对于网络管理员来说,它提供了方便的MIB文件管理和设备配置功能。 首先,我们要...

    AdventNet SNMP Agent for Linux

    AdventNet SNMP Agent for Linux能简化网络中Linux机器的监控和管理,支持名为AdventNet-LINUX-MIB的预定义MIB,以及诸如MIB RFC-1213-MIB和HOST-RESOURCES-MIB的标准MIB。此外,它使用SNMP和HTTP控制台以便于管理。...

    AdventNetSNMPAPI

    总的来说,AdventNet SNMP API 是一个强大且易于使用的工具,它使Java开发者能够快速构建具有SNMP功能的应用,从而更好地管理和监控网络环境。通过学习和实践提供的示例代码,开发者可以迅速掌握SNMP编程,并将其...

    基于SNMP/MIB的网络数据获取系统设计与实现

    AdventNet SNMP API为基于SNMP的网络管理应用提供了一个全面的开发工具包。AdventNet的SNMP栈包含一系列强大的Java SNMP库,用来为监控和跟踪网络元素创建实时的应用程序,这些应用程序是可靠的、可伸展的且独立于OS...

    SNMP开发包

    首先,AdventNet SNMP API 是一个功能强大的SNMP库,尽管它没有公开源代码,但提供了丰富的API接口,使得开发者能够轻松地在Java应用中集成SNMP功能。AdventNet SNMP API的"4_Std"版本可能指的是标准版,它包含了...

Global site tag (gtag.js) - Google Analytics