吾爱破解 - LCG - LSG |安卓破解|病毒分析|www.52pojie.cn

 找回密码
 注册[Register]

QQ登录

只需一步,快速开始

查看: 4613|回复: 1
收起左侧

[会员申请] 申请会员ID: slient

[复制链接]
吾爱游客  发表于 2018-10-26 16:34
1.申 请 I D:slient
2.个人邮箱:blackjava@163.com
3.技术文章: 90后程序猿一枚,精通java略会一点scala和python等,简答写一个snmp客户端工具类 并获取一下服务器的cpu使用率吧。
开发工具:Eclipse

目标:通过安装在linux 7.3下的snmp server获取当前服务器的cpu使用率

import java.io.IOException;
import java.util.HashMap;
import java.util.Map;
import java.util.Set;

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.Integer32;  
import org.snmp4j.smi.Null;  
import org.snmp4j.smi.OID;  
import org.snmp4j.smi.OctetString;
import org.snmp4j.smi.Variable;
import org.snmp4j.smi.VariableBinding;  
import org.snmp4j.transport.DefaultUdpTransportMapping;  

public class SnmpData {  

    public static final int DEFAULT_VERSION = SnmpConstants.version2c;  
    public static final String DEFAULT_PROTOCOL = "udp";  
    public static final long DEFAULT_TIMEOUT = 3 * 1000L;  
    public static final int DEFAULT_RETRY = 3;  

    /**
     * 创建对象communityTarget,用于返回target
     *
     * @param targetAddress
     * @param community
     * @param version
     * @param timeOut
     * @param retry
     * @return CommunityTarget
     */  
    public synchronized static CommunityTarget createDefault(String ip, String community,int snmpPort) {  
        Address address = GenericAddress.parse(DEFAULT_PROTOCOL + ":" + ip  
                + "/" + snmpPort);  
        CommunityTarget target = new CommunityTarget();  
        target.setCommunity(new OctetString(community));  
        target.setAddress(address);  
        target.setVersion(DEFAULT_VERSION);  
        target.setTimeout(DEFAULT_TIMEOUT); // milliseconds  
        target.setRetries(DEFAULT_RETRY);  
        return target;  
    }  
    /*根据OID,获取单条消息*/  
    public Variable snmpGet(String ip, String community, String oid,int snmpPort) {  

        Variable variable = null;
        CommunityTarget target = createDefault(ip, community,snmpPort);  
        Snmp snmp = null;  
        try {  
            PDU pdu = new PDU();  
            // pdu.add(new VariableBinding(new OID(new int[]  
            // {1,3,6,1,2,1,1,2})));  
            pdu.add(new VariableBinding(new OID(oid)));  

            DefaultUdpTransportMapping transport = new DefaultUdpTransportMapping();  
            snmp = new Snmp(transport);  
            snmp.listen();  
            pdu.setType(PDU.GET);  
            ResponseEvent respEvent = snmp.send(pdu, target);  
            PDU response = respEvent.getResponse();  
            if (response == null) {  
                System.out.println("response is null, request time out");  
            } else {  

                for (int i = 0; i < response.size(); i++) {  
                    VariableBinding vb = response.get(i);  
                    variable = vb.getVariable();
                }  

            }  
        } catch (Exception e) {  
            e.printStackTrace();  
            System.out.println("SNMP Get Exception:" + e);  
        } finally {  
            if (snmp != null) {  
                try {  
                    snmp.close();  
                } catch (IOException ex1) {  
                    snmp = null;  
                }  
            }  

        }  
        
        return variable;
    }  
   
    /*根据targetOID,获取树形数据*/  
    public Map<String,Variable> snmpWalk(String ip, String community, String targetOid,int snmpPort)  
    {  

        Map<String,Variable> map = new HashMap<String,Variable>();
        CommunityTarget target = createDefault(ip, community,snmpPort);  
        TransportMapping transport = null;  
        Snmp snmp = null;  
        try {  
            transport = new DefaultUdpTransportMapping();  
            snmp = new Snmp(transport);  
            transport.listen();  

            PDU pdu = new PDU();  
            OID targetOID = new OID(targetOid);  
            pdu.add(new VariableBinding(targetOID));  

            boolean finished = false;  
            while (!finished) {  
                VariableBinding vb = null;  
                ResponseEvent respEvent = snmp.getNext(pdu, target);  

                PDU response = respEvent.getResponse();  

                if (null == response) {  
                    finished = true;  
                    map = null;
                    break;  
                } else {  
                    vb = response.get(0);  
                }  
                // check finish  
                finished = checkWalkFinished(targetOID, pdu, vb);  
                if (!finished) {  
                    Variable variable = vb.getVariable();
                    OID oid = vb.getOid();
                    map.put(oid.toString(), variable);
                    // Set up the variable binding for the next entry.  
                    pdu.setRequestID(new Integer32(0));  
                    pdu.set(0, vb);  
                } else {  
                    snmp.close();  
                }  
            }  
        } catch (Exception e) {  
            e.printStackTrace();  
            System.out.println("SNMP Walk Exception:" + e);  
        } finally {  
            if (snmp != null) {  
                try {  
                    snmp.close();  
                } catch (IOException ex1) {  
                    snmp = null;  
                }  
            }  
        }
        return map;  
    }  

    private static boolean checkWalkFinished(OID targetOID, PDU pdu,  
            VariableBinding vb) {  
        boolean finished = false;  
        if (pdu.getErrorStatus() != 0) {  
            finished = true;  
        } else if (vb.getOid() == null) {  
            finished = true;  
        } else if (vb.getOid().size() < targetOID.size()) {  
            finished = true;  
        } else if (targetOID.leftMostCompare(targetOID.size(), vb.getOid()) != 0) {  
            finished = true;  
        } else if (Null.isExceptionSyntax(vb.getVariable().getSyntax())) {  
            finished = true;  
        } else if (vb.getOid().compareTo(targetOID) <= 0) {  
            finished = true;  
        }  
        return finished;  

    }  


   public static void main(String[] args) {
       String ip = "
127.0.0.1";
        SnmpData sd = new SnmpData();
        Variable snmpGet = sd.snmpGet(
ip , "public", "1.3.6.1.2.1.25.3.3.1.2", 161);
        System.out.println(snmpGet.toString());

       //判断snmp是否获取到信息  如果没有获取到则表示当前服务器  未启动snmp或者关机或者snmp信息填写错误
            if(hrProcessorLoad == null ){
                System.out.println(" ip:"+
ip +" cpu信息采集异常");
            
                continue ;
               
                //如果获取到信息并且当前是异常线程则 将当前设备移回正常设备处理线程
            }else{
               

              //计算cpu利用率
              Set<String> keySet = hrProcessorLoad.keySet();
              long cpu = 0L;
              for (String string : keySet) {
                cpu += hrProcessorLoad.get(string).toLong();
              }
              double cpuUsageRate = 1.0 * cpu / (keySet.size() * 100) * 100 ;
         
               

              System.out.println(" ip:"+ip +" 当前cpu使用率是:"+cpuUsageRate +"%");         
            }
            
            
    }
}  
微信图片_20181026112019.png

发帖前要善用论坛搜索功能,那里可能会有你要找的答案或者已经有人发布过相同内容了,请勿重复发帖。

Hmily 发表于 2018-10-29 11:26
抱歉,未能达到申请要求,申请不通过,可以关注论坛官方微信(吾爱破解论坛),等待开放注册通知。
您需要登录后才可以回帖 登录 | 注册[Register]

本版积分规则

快速回复 收藏帖子 返回列表 搜索

RSS订阅|小黑屋|处罚记录|联系我们|吾爱破解 - LCG - LSG ( 京ICP备16042023号 | 京公网安备 11010502030087号 )

GMT+8, 2024-3-29 16:45

Powered by Discuz!

Copyright © 2001-2020, Tencent Cloud.

快速回复 返回顶部 返回列表