vijava 实时监控HostSystem主机各种指标，以及区分目标对象（直接可用）

本是古典何须时尚 2022-12-29 09:55 67阅读 0赞

自己百度时总能看到这个文章：  Vmware Vsphere WebService之vijava 开发（二）一性能信息的采集（实时监控）

[https://www.cnblogs.com/xiaodige/p/6774413.html  ][https_www.cnblogs.com_xiaodige_p_6774413.html_]

我根据他的代码 完善并有新需求  我用的是vc 6.7

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L1d1aGFvdGlhbjE5OTY_size_16_color_FFFFFF_t_70][]

点击图标选项 自定义监控类型

listNm.add("net");  这个意思就是  选择 -网络   例如 cpu   就是"cpu"   这个可以打断点查出来

Map<String, PerformanceManage> perfData = performanceCounter2.getPerfData("packetsTx", listNm, dataCenter, 20,serviceInstance,calBegin,calEnd);  这个意思就是内部名称 找到-传输的数据包数

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L1d1aGFvdGlhbjE5OTY_size_16_color_FFFFFF_t_70 1][]xian

先把  PerformanceManage 类给你们  就是一个实体

package com.tongdaotech.modules.vcenter.entity;
    
    
    import java.util.Date;
    import java.util.List;
    
    public class PerformanceManage {
        public Date startTime;
        public Date endTime;
        public List<Long> performanceValues;
        public List<String> times;
    
        public List<String> getTimes() {
            return times;
        }
    
        public void setTimes(List<String> times) {
            this.times = times;
        }
    
        public Date getStartTime() {
            return startTime;
        }
    
        public void setStartTime(Date startTime) {
            this.startTime = startTime;
        }
    
        public Date getEndTime() {
            return endTime;
        }
    
        public void setEndTime(Date endTime) {
            this.endTime = endTime;
        }
    
        public List<Long> getPerformanceValues() {
            return performanceValues;
        }
    
        public void setPerformanceValues(List<Long> performanceValues) {
            this.performanceValues = performanceValues;
        }
    }

以下代码直接可用   改一下 ip和密码即可

package com.tongdaotech.modules.vcenter.controller;
    
    import com.tongdaotech.common.utils.Constant;
    import com.tongdaotech.common.utils.Result;
    import com.tongdaotech.modules.vcenter.entity.PerformanceManage;
    import com.vmware.vim25.*;
    import com.vmware.vim25.mo.*;
    import org.springframework.web.bind.annotation.GetMapping;
    import org.springframework.web.bind.annotation.RequestMapping;
    import org.springframework.web.bind.annotation.RestController;
    
    import java.net.URL;
    import java.text.SimpleDateFormat;
    import java.util.*;
    
    
    /**
     * @description 监控统计vcenter所有对象性能数据
     * @date 2020年12月22日11:46:35
     * @version 1.1
     * @author Wu
     */
    
    public class PerformanceCounter1 {
        /** main测试方法 */
        public static void main(String[] args) throws Exception {
            PerformanceCounter1 performanceCounter2 = new PerformanceCounter1();
            ServiceInstance serviceInstance = new ServiceInstance(new URL("https://12x.13x.12x.14x:29888/sdk"), "administrator@vsphere.local", "123...,", true);
            HostSystem dataCenter = (HostSystem) new InventoryNavigator(serviceInstance.getRootFolder())
                    .searchManagedEntity("HostSystem", "192.168.2.234");
            List<String> listNm = new ArrayList<String>();
    //        listNm.add("datastore");
            listNm.add("net");
    
            Date date = new Date();
    //        Date sTime = new Date(date.getTime() - 24 * 60 * 60 * 1000);   24小时
    //        Date sTime = new Date(date.getTime() - 1*60* 60 * 1000);     1小时
            Date sTime = new Date(date.getTime() - 1*11* 60 * 1000);     //  11分钟  //20秒间隔  一分钟=3个数据
    
            Calendar calBegin = Calendar.getInstance();
            calBegin.setTime(sTime);
    
            Calendar calEnd = Calendar.getInstance();
            calEnd.setTime(date);
    
    
            Map<String, PerformanceManage> perfData = performanceCounter2.getPerfData11("packetsTx", listNm, dataCenter, 20,serviceInstance,calBegin,calEnd);
    //        PerformanceManage performanceManage = perfData.get("datastore");
            PerformanceManage performanceManage = perfData.get("net");
            List<Long> performanceValues = performanceManage.getPerformanceValues();
            System.out.println(performanceValues);
    
        }
    
        public Map<String, PerformanceManage> getPerfData11(String nameInfo, List<String> groupInfo, ManagedEntity mo,
                                                          Integer interval, ServiceInstance instance,Calendar calBegin ,Calendar calEnd) {
            Map<String, PerformanceManage> PerformanceMap = null;
    
    
            try {
                PerformanceMap = new HashMap<String, PerformanceManage>();
                if (mo != null) {
                    PerformanceManager performanceManager = instance.getPerformanceManager();
    //                PerformanceManager performanceManager = cs.si.getPerformanceManager();
                    PerfCounterInfo[] cInfo = performanceManager.getPerfCounter();
    
                    Map<Integer, PerfCounterInfo> counters = new HashMap<Integer, PerfCounterInfo>();
    
                    for (PerfCounterInfo pcInfo : cInfo) {
                        counters.put(new Integer(pcInfo.getKey()), pcInfo);
                    }
    
                    PerfMetricId[] listpermeid = performanceManager.queryAvailablePerfMetric(mo, null, null, interval);
    
                    ArrayList<PerfMetricId> mMetrics = new ArrayList<PerfMetricId>();
                    if (listpermeid != null) {
                        for (int index = 0; index < listpermeid.length; ++index) {
                            if (counters.containsKey(new Integer(listpermeid[index].getCounterId()))) {
                                mMetrics.add(listpermeid[index]);
                            }
                        }
                    }
    
                    PerfQuerySpec qSpec = new PerfQuerySpec();
                    qSpec.setEntity(mo.getMOR());
                    qSpec.setMetricId(listpermeid);
                    qSpec.setStartTime(calBegin);
                    qSpec.setEndTime(calEnd);
                    qSpec.setIntervalId(interval);
                    qSpec.setFormat("normal");
    
                    PerfQuerySpec[] arryQuery = { qSpec };
    
                    PerfEntityMetricBase[] pValues = performanceManager.queryPerf(arryQuery);
    
    
                    if (pValues == null || pValues.length <= 0) {
                        return null;
                    }
                    PerfSampleInfo[] listperfsinfo = ((PerfEntityMetric) pValues[0]).getSampleInfo();
    
    
    
                    for (int i = 0; i < pValues.length; i++) {
                        PerfMetricSeries[] listpems = ((PerfEntityMetric) pValues[i]).getValue();
    
    
                        for (int vi = 0; vi < listpems.length; ++vi) {
                            PerfCounterInfo pci = (PerfCounterInfo) counters
                                    .get(new Integer(listpems[vi].getId().getCounterId()));
    
    
    
                            if (pci != null) {
                                for (String Info : groupInfo) {
                                    PerformanceManage performanceManage = new PerformanceManage();
                                    performanceManage.setStartTime(listperfsinfo[0].getTimestamp().getTime());
                                    performanceManage
                                            .setEndTime((listperfsinfo[listperfsinfo.length - 1]).getTimestamp().getTime());
                                    if (pci.getNameInfo().getKey().equalsIgnoreCase(nameInfo)
                                            && pci.getGroupInfo().getKey().equalsIgnoreCase(Info)) {
                                        if (listpems[vi] instanceof PerfMetricIntSeries) {
                                            PerfMetricIntSeries val = (PerfMetricIntSeries) listpems[vi];
                                            if(val.getId().instance.equals("")){
                                            long[] lislon = val.getValue();
    
                                            List<Long> asList = new ArrayList<Long>();
                                            for (Long k : lislon) {
                                                asList.add(k);
                                            }
                                            performanceManage.setPerformanceValues(asList);
                                            PerformanceMap.put(Info, performanceManage);
                                        }
                                       }
                                    }
                                }
                            }
                        }
                    }
    
                }
            } catch (Exception e) {
                e.printStackTrace();
            }
    
            return PerformanceMap;
        }
    
    
    }

当我想要请求时发现      目标对象为多个  他的代码就默认取第一个   也就是说  有可能  为vmnic0   vmnic1   或者其他   所以加了

if(val.getId().instance.equals("")) 这个判断    确保拿到的是 正确的目标对象 也就是"198.98.31.xxx"的数据

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L1d1aGFvdGlhbjE5OTY_size_16_color_FFFFFF_t_70 2][]

[https_www.cnblogs.com_xiaodige_p_6774413.html_]: https://www.cnblogs.com/xiaodige/p/6774413.html
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L1d1aGFvdGlhbjE5OTY_size_16_color_FFFFFF_t_70]: /images/20221120/2204467e91c84b8499edf6229ecbf9d2.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L1d1aGFvdGlhbjE5OTY_size_16_color_FFFFFF_t_70 1]: /images/20221120/81d6fe2c60314eec9c2ee5c45307135c.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L1d1aGFvdGlhbjE5OTY_size_16_color_FFFFFF_t_70 2]: /images/20221120/ce1f3cbb21cf498fa7197a8e3382fb8f.png