关键词搜索

源码搜索 ×
×

使用VMware VSphere WebService SDK进行开发 （二）——获取虚拟机cpu的使用情况

发布2015-11-11浏览13173次

详情内容

欢迎支持笔者新作：《深入理解Kafka:核心设计与实践原理》和《RabbitMQ实战指南》，同时欢迎关注笔者的微信公众号：朱小厮的博客。

欢迎跳转到本文的原文链接：https://honeypps.com/backend/vmware-vsphere-webservice-sdk-virtual-cpu/

 

本文通过代码举例虚拟机cpu的使用情况来演示如何遍历搜寻VirtualMachine的对象，以及根据这个对象进行性能指标的见识。希望可以取到举一反三的效果。

首先下面先罗列出如何更具虚拟机的名称获得VirtualMachine的ManagedObjectReference对象。

 

  1. 	private static TraversalSpec getVmTraversalSpec()
  2. 	{
  3. 		TraversalSpec vAppToVM = new TraversalSpec();
  4. 		vAppToVM.setName("vAppToVM");
  5. 		vAppToVM.setType("VirtualApp");
  6. 		vAppToVM.setPath("vm");
  7.  
  8. 		TraversalSpec vAppToVApp = new TraversalSpec();
  9. 		vAppToVApp.setName("vAppToVApp");
  10. 		vAppToVApp.setType("VirtualApp");
  11. 		vAppToVApp.setPath("resourcePool");
  12.  
  13. 		SelectionSpec vAppRecursion = new SelectionSpec();
  14. 		vAppRecursion.setName("vAppToVApp");
  15. 		SelectionSpec vmInVApp = new SelectionSpec();
  16. 		vmInVApp.setName("vAppToVM");
  17. 		List<SelectionSpec> vAppToVMSS = new ArrayList<SelectionSpec>();
  18. 		vAppToVMSS.add(vAppRecursion);
  19. 		vAppToVMSS.add(vmInVApp);
  20. 		vAppToVApp.getSelectSet().addAll(vAppToVMSS);
  21.  
  22. 		SelectionSpec sSpec = new SelectionSpec();
  23. 		sSpec.setName("VisitFolders");
  24.  
  25. 		TraversalSpec dataCenterToVMFolder = new TraversalSpec();
  26. 		dataCenterToVMFolder.setName("DataCenterToVMFolder");
  27. 		dataCenterToVMFolder.setType("Datacenter");
  28. 		dataCenterToVMFolder.setPath("vmFolder");
  29. 		dataCenterToVMFolder.setSkip(false);
  30. 		dataCenterToVMFolder.getSelectSet().add(sSpec);
  31.  
  32. 		TraversalSpec traversalSpec = new TraversalSpec();
  33. 		traversalSpec.setName("VisitFolders");
  34. 		traversalSpec.setType("Folder");
  35. 		traversalSpec.setPath("childEntity");
  36. 		traversalSpec.setSkip(false);
  37. 		List<SelectionSpec> sSpecArr = new ArrayList<SelectionSpec>();
  38. 		sSpecArr.add(sSpec);
  39. 		sSpecArr.add(dataCenterToVMFolder);
  40. 		sSpecArr.add(vAppToVM);
  41. 		sSpecArr.add(vAppToVApp);
  42. 		traversalSpec.getSelectSet().addAll(sSpecArr);
  43. 		return traversalSpec;
  44. 	}
  1. 	private static ManagedObjectReference getVmByVmName(String vmName)
  2. 	{
  3. 		ManagedObjectReference retVal = null;
  4. 		ManagedObjectReference rootFolder = serviceContent.getRootFolder();
  5. 		try
  6. 		{
  7. 			TraversalSpec tSpec = getVmTraversalSpec();
  8. 			PropertySpec propertySpec = new PropertySpec();
  9. 			propertySpec.setAll(Boolean.FALSE);
  10. 			propertySpec.getPathSet().add("name");
  11. 			propertySpec.setType("VirtualMachine");
  12.  
  13. 			ObjectSpec objectSpec = new ObjectSpec();
  14. 			objectSpec.setObj(rootFolder);
  15. 			objectSpec.setSkip(Boolean.TRUE);
  16. 			objectSpec.getSelectSet().add(tSpec);
  17.  
  18. 			PropertyFilterSpec propertyFilterSpec = new PropertyFilterSpec();
  19. 			propertyFilterSpec.getPropSet().add(propertySpec);
  20. 			propertyFilterSpec.getObjectSet().add(objectSpec);
  21.  
  22. 			List<PropertyFilterSpec> listpfs = new ArrayList<PropertyFilterSpec>(1);
  23. 			listpfs.add(propertyFilterSpec);
  24. 			List<ObjectContent> listobjcont = retrievePropertiesAllObjects(listpfs);
  25.  
  26. 			if (listobjcont != null)
  27. 			{
  28. 				for (ObjectContent oc : listobjcont)
  29. 				{
  30. 					ManagedObjectReference mr = oc.getObj();
  31. 					String vmnm = null;
  32. 					List<DynamicProperty> dps = oc.getPropSet();
  33. 					if (dps != null)
  34. 					{
  35. 						for (DynamicProperty dp : dps)
  36. 						{
  37. 							vmnm = (String) dp.getVal();
  38. 						}
  39. 					}
  40. 					if (vmnm != null && vmnm.equals(vmName))
  41. 					{
  42. 						retVal = mr;
  43. 						break;
  44. 					}
  45. 				}
  46. 			}
  47. 		}
  48. 		catch (SOAPFaultException sfe)
  49. 		{
  50. 			printSoapFaultException(sfe);
  51. 		}
  52. 		catch (Exception e)
  53. 		{
  54. 			e.printStackTrace();
  55. 		}
  56. 		return retVal;
  57. 	}

然后根据上面的VirtualMachine的ManagedObjectReference对象获取虚拟机的实时性能信息：

 

 

  1. 	private static List<List<Long>> getVmData(String vmName, String nameInfo, String groupInfo) throws RuntimeFaultFaultMsg, DatatypeConfigurationException
  2. 	{
  3. 		List<List<Long>> list = new ArrayList<List<Long>>();
  4. 		ManagedObjectReference vmmor = getVmByVmName(vmName);
  5. 		if (vmmor != null)
  6. 		{
  7. 			List<PerfCounterInfo> cInfo = getPerfCounters();
  8.  
  9. 			int i = 0;
  10. 			Map<Integer, PerfCounterInfo> counters = new HashMap<Integer, PerfCounterInfo>();
  11. 			for (Iterator<PerfCounterInfo> it = cInfo.iterator(); it.hasNext();)
  12. 			{
  13. 				PerfCounterInfo pcInfo = (PerfCounterInfo) it.next();
  14. 				counters.put(new Integer(pcInfo.getKey()), pcInfo);
  15. 			}
  16.  
  17. 			List<PerfMetricId> listpermeid = vimPort.queryAvailablePerfMetric(perfManager, vmmor, null, null, new Integer(20));
  18. 			ArrayList<PerfMetricId> mMetrics = new ArrayList<PerfMetricId>();
  19. 			if (listpermeid != null)
  20. 			{
  21. 				for (int index = 0; index < listpermeid.size(); ++index)
  22. 				{
  23. 					if (counters.containsKey(new Integer(listpermeid.get(index).getCounterId())))
  24. 					{
  25. 						mMetrics.add(listpermeid.get(index));
  26. 					}
  27. 				}
  28. 			}
  29. 			PerfQuerySpec qSpec = new PerfQuerySpec();
  30. 			qSpec.setEntity(vmmor);
  31. 			qSpec.setMaxSample(new Integer(10));
  32. 			qSpec.getMetricId().addAll(mMetrics);
  33. 			qSpec.setIntervalId(new Integer(20));
  34.  
  35. 			List<PerfQuerySpec> qSpecs = new ArrayList<PerfQuerySpec>();
  36. 			qSpecs.add(qSpec);
  37.  
  38. 			List<PerfEntityMetricBase> listpemb = vimPort.queryPerf(perfManager, qSpecs);
  39. 			List<PerfEntityMetricBase> pValues = listpemb;
  40. 			for (i = 0; i < pValues.size(); i++)
  41. 			{
  42. 				List<PerfMetricSeries> listpems = ((PerfEntityMetric) pValues.get(i)).getValue();
  43. 				List<PerfSampleInfo> listinfo = ((PerfEntityMetric) pValues.get(i)).getSampleInfo();
  44. 				for (int vi = 0; vi < listpems.size(); ++vi)
  45. 				{
  46. 					String printInf = "";
  47. 					PerfCounterInfo pci = (PerfCounterInfo) counters.get(new Integer(listpems.get(vi).getId().getCounterId()));
  48.  
  49. 					if (pci != null)
  50. 					{
  51. 						if (pci.getNameInfo().getKey().equalsIgnoreCase(nameInfo) && pci.getGroupInfo().getKey().equalsIgnoreCase(groupInfo))
  52. 						{
  53. 							printInf += vi + ":" + pci.getNameInfo().getSummary() + ":" + pci.getNameInfo().getKey() + ":" + pci.getNameInfo().getLabel() + ":"
  54. 									+ pci.getGroupInfo().getKey() + ":" + pci.getGroupInfo().getLabel() + ":" + pci.getGroupInfo().getSummary() + " ";
  55.  
  56. 							for (PerfMetricId pmi : mMetrics)
  57. 							{
  58. 								int counterId = pmi.getCounterId();
  59. 								if (counterId == listpems.get(vi).getId().getCounterId())
  60. 								{
  61. 									printInf += "[" + pmi.getCounterId() + ":" + pmi.getInstance() + "]    ";
  62. 								}
  63. 							}
  64.  
  65. 							if (listpems.get(vi) instanceof PerfMetricIntSeries)
  66. 							{
  67. 								PerfMetricIntSeries val = (PerfMetricIntSeries) listpems.get(vi);
  68. 								List<Long> lislon = val.getValue();
  69. 								for (Long k : lislon)
  70. 								{
  71. 									printInf += k + " ";
  72. 								}
  73. 								list.add(lislon);
  74. 							}
  75. 							printInf += "   " + pci.getUnitInfo().getKey() + " " + pci.getUnitInfo().getLabel() + " " + pci.getUnitInfo().getSummary();
  76. 							System.out.println(printInf);
  77. 						}
  78. 					}
  79. 				}
  80. 			}
  81.  
  82. 		}
  83.  
  84. 		return list;
  85. 	}


真正获取cpu使用情况的方法只是调用上面的方法做一些简单的处理：

 

 

  1. 	public static double getVmCpuUsageByVmName(String VmName) throws RuntimeFaultFaultMsg, DatatypeConfigurationException
  2. 	{
  3. 		double ans = 0.0;
  4. 		List<List<Long>> list = getVmData(VmName, "usage", "cpu");
  5.  
  6. 		long maxInner = 0;
  7. 		int times = 0;
  8. 		for (List<Long> listOuter : list)
  9. 		{
  10. 			long tempInner = 0;
  11. 			for (long inner : listOuter)
  12. 			{
  13. 				tempInner += inner;
  14. 			}
  15. 			if (tempInner > maxInner)
  16. 			{
  17. 				maxInner = tempInner;
  18. 				times = listOuter.size();
  19. 			}
  20. 		}
  21. 		if (times != 0)
  22. 		{
  23. 			ans = (double) maxInner / times;
  24. 		}
  25.  
  26. 		ans = ans / 100;
  27. 		return ans;
  28. 	}


这里的虚拟机cpu使用情况是百分制的，而且vsphere sdk返回的百分比的结果都是要除以100的，譬如真实结果是5%，那么vsphere sdk返回的就是500，需要做一下处理。

 

接下来获取cpu的可用量：

 

  1. 	public static double getVmCpuEntitlementByVmName(String VmName) throws RuntimeFaultFaultMsg, DatatypeConfigurationException
  2. 	{
  3. 		double ans = 0;
  4. 		List<List<Long>> list = getVmData(VmName, "entitlement", "cpu");
  5. 		long maxInner = 0;
  6. 		int times = 0;
  7. 		for (List<Long> listOuter : list)
  8. 		{
  9. 			long tempInner = 0;
  10. 			for (long inner : listOuter)
  11. 			{
  12. 				tempInner += inner;
  13. 			}
  14. 			if (tempInner > maxInner)
  15. 			{
  16. 				maxInner = tempInner;
  17. 				times = listOuter.size();
  18. 			}
  19. 		}
  20. 		if (times != 0)
  21. 		{
  22. 			ans = (double) maxInner / times;
  23. 		}
  24.  
  25. 		return ans;
  26. 	}

细心的读者可能发现的差别，这里只需要修改nameinfo以及groupinfo即可以获取不同的结果。
有一些监控数据不是实时获取的，通过上面的方法是获取不到的，比如：获取虚拟机cpu的个数，类似这种比较固定的信息，或者说配置信息更，就要另辟蹊径了。

 

 

  1. 	public static int getVmCpuNumByVmName(String VmName) throws RuntimeFaultFaultMsg, InvalidPropertyFaultMsg
  2. 	{
  3. 		int ans = 0;
  4. 		String cpuNum = getVmPropertyByVmName("summary.config.numCpu", VmName);
  5. 		ans = Integer.valueOf(cpuNum);
  6.  
  7. 		return ans;
  8. 	}
  1. 	private static String getVmPropertyByVmName(String property, String VmName) throws RuntimeFaultFaultMsg, InvalidPropertyFaultMsg
  2. 	{
  3. 		String ans = null;
  4. 		RetrieveResult props = getRetrieveResultObjectWithProperty("VirtualMachine", property);
  5.  
  6. 		if (props != null)
  7. 		{
  8. 			Boolean flag = false;
  9. 			if (property.compareToIgnoreCase("name") < 0)
  10. 			{
  11. 				for (ObjectContent oc : props.getObjects())
  12. 				{
  13. 					if (flag == true)
  14. 					{
  15. 						break;
  16. 					}
  17. 					String path = null;
  18. 					List<DynamicProperty> dps = oc.getPropSet();
  19.  
  20. 					if (dps != null)
  21. 					{
  22. 						for (DynamicProperty dp : dps)
  23. 						{
  24. 							path = dp.getName();
  25. 							if (path.equalsIgnoreCase(property))
  26. 							{
  27. 								String val = String.valueOf(dp.getVal());
  28. 								ans = val;
  29. 							}
  30. 							if (path.equalsIgnoreCase("name"))
  31. 							{
  32. 								String value = (String) dp.getVal();
  33. 								if (value.equals(VmName))
  34. 								{
  35. 									flag = true;
  36. 									break;
  37. 								}
  38. 							}
  39. 						}
  40. 					}
  41. 				}
  42. 			}
  43. 			else
  44. 			{
  45. 				for (ObjectContent oc : props.getObjects())
  46. 				{
  47. 					if (flag == true)
  48. 					{
  49. 						break;
  50. 					}
  51. 					String path = null;
  52. 					List<DynamicProperty> dps = oc.getPropSet();
  53.  
  54. 					if (dps != null)
  55. 					{
  56. 						for (DynamicProperty dp : dps)
  57. 						{
  58. 							path = dp.getName();
  59. 							if (path.equalsIgnoreCase("name"))
  60. 							{
  61. 								String value = (String) dp.getVal();
  62. 								if (value.equals(VmName))
  63. 								{
  64. 									flag = true;
  65. 								}
  66. 							}
  67. 							if (path.equalsIgnoreCase(property))
  68. 							{
  69. 								String val = String.valueOf(dp.getVal());
  70. 								if (flag == true)
  71. 								{
  72. 									ans = val;
  73. 									break;
  74. 								}
  75. 							}
  76. 						}
  77. 					}
  78. 				}
  79. 			}
  80. 		}
  81.  
  82. 		return ans;
  83. 	}
  1. 	private static RetrieveResult getRetrieveResultObjectWithProperty(String MorName, String property) throws InvalidPropertyFaultMsg, RuntimeFaultFaultMsg
  2. 	{
  3. 		ManagedObjectReference viewMgrRef = serviceContent.getViewManager();
  4. 		ManagedObjectReference propColl = serviceContent.getPropertyCollector();
  5.  
  6. 		List<String> vmList = new ArrayList<String>();
  7. 		vmList.add(MorName);
  8.  
  9. 		ManagedObjectReference cViewRef = vimPort.createContainerView(viewMgrRef, serviceContent.getRootFolder(), vmList, true);
  10.  
  11. 		ObjectSpec oSpec = new ObjectSpec();
  12. 		oSpec.setObj(cViewRef);
  13. 		oSpec.setSkip(true);
  14.  
  15. 		TraversalSpec tSpec = new TraversalSpec();
  16. 		tSpec.setName("traversalEntities");
  17. 		tSpec.setPath("view");
  18. 		tSpec.setSkip(false);
  19. 		tSpec.setType("ContainerView");
  20.  
  21. 		oSpec.getSelectSet().add(tSpec);
  22.  
  23. 		PropertySpec pSpec = new PropertySpec();
  24. 		pSpec.setType(MorName);
  25. 		pSpec.getPathSet().add("name");
  26.  
  27. 		PropertySpec pSpecRPr = new PropertySpec();
  28. 		pSpecRPr.setType(MorName);
  29. 		pSpecRPr.getPathSet().add(property);
  30.  
  31. 		PropertyFilterSpec fSpec = new PropertyFilterSpec();
  32. 		fSpec.getObjectSet().add(oSpec);
  33. 		fSpec.getPropSet().add(pSpec);
  34. 		fSpec.getPropSet().add(pSpecRPr);
  35.  
  36. 		List<PropertyFilterSpec> fSpecList = new ArrayList<PropertyFilterSpec>();
  37. 		fSpecList.add(fSpec);
  38.  
  39. 		RetrieveOptions ro = new RetrieveOptions();
  40. 		RetrieveResult props = vimPort.retrievePropertiesEx(propColl, fSpecList, ro);
  41.  
  42. 		return props;
  43. 	}

这样就可以获取虚拟机的cpu个数的信息。

 

附加一个方法（获取vCenter下所有虚拟机的名称）

  1. 	public static List<String> getVmNames()
  2. 	{
  3. 		List<String> list = new ArrayList<String>();
  4. 		ManagedObjectReference rootFolder = serviceContent.getRootFolder();
  5. 		try
  6. 		{
  7. 			TraversalSpec tSpec = getVmTraversalSpec();
  8. 			PropertySpec propertySpec = new PropertySpec();
  9. 			propertySpec.setAll(Boolean.FALSE);
  10. 			propertySpec.getPathSet().add("name");
  11. 			propertySpec.setType("VirtualMachine");
  12.  
  13. 			ObjectSpec objectSpec = new ObjectSpec();
  14. 			objectSpec.setObj(rootFolder);
  15. 			objectSpec.setSkip(Boolean.TRUE);
  16. 			objectSpec.getSelectSet().add(tSpec);
  17.  
  18. 			PropertyFilterSpec propertyFilterSpec = new PropertyFilterSpec();
  19. 			propertyFilterSpec.getPropSet().add(propertySpec);
  20. 			propertyFilterSpec.getObjectSet().add(objectSpec);
  21.  
  22. 			List<PropertyFilterSpec> listpfs = new ArrayList<PropertyFilterSpec>(1);
  23. 			listpfs.add(propertyFilterSpec);
  24. 			List<ObjectContent> listobjcont = retrievePropertiesAllObjects(listpfs);
  25.  
  26. 			if (listobjcont != null)
  27. 			{
  28. 				for (ObjectContent oc : listobjcont)
  29. 				{
  30. 					String vmnm = null;
  31. 					List<DynamicProperty> dps = oc.getPropSet();
  32. 					if (dps != null)
  33. 					{
  34. 						for (DynamicProperty dp : dps)
  35. 						{
  36. 							vmnm = (String) dp.getVal();
  37. 							if (vmnm != null)
  38. 							{
  39. 								list.add(vmnm);
  40. 							}
  41. 						}
  42. 					}
  43. 				}
  44. 			}
  45. 		}
  46. 		catch (SOAPFaultException sfe)
  47. 		{
  48. 			printSoapFaultException(sfe);
  49. 		}
  50. 		catch (Exception e)
  51. 		{
  52. 			e.printStackTrace();
  53. 		}
  54. 		return list;
  55. 	}

关于主机（HostSystem）信息的获取将在下一篇文章中呈现。敬请期待。
 

Modified: 居然忘了写一个重要的函数了，这里赶紧补上：

 

  1. 	private static List<PerfCounterInfo> getPerfCounters()
  2. 	{
  3. 		List<PerfCounterInfo> pciArr = null;
  4.  
  5. 		try
  6. 		{
  7. 			PropertySpec propertySpec = new PropertySpec();
  8. 			propertySpec.setAll(Boolean.FALSE);
  9. 			propertySpec.getPathSet().add("perfCounter");
  10. 			propertySpec.setType("PerformanceManager");
  11. 			List<PropertySpec> propertySpecs = new ArrayList<PropertySpec>();
  12. 			propertySpecs.add(propertySpec);
  13.  
  14. 			ObjectSpec objectSpec = new ObjectSpec();
  15. 			objectSpec.setObj(perfManager);
  16. 			List<ObjectSpec> objectSpecs = new ArrayList<ObjectSpec>();
  17. 			objectSpecs.add(objectSpec);
  18.  
  19. 			PropertyFilterSpec propertyFilterSpec = new PropertyFilterSpec();
  20. 			propertyFilterSpec.getPropSet().add(propertySpec);
  21. 			propertyFilterSpec.getObjectSet().add(objectSpec);
  22.  
  23. 			List<PropertyFilterSpec> propertyFilterSpecs = new ArrayList<PropertyFilterSpec>();
  24. 			propertyFilterSpecs.add(propertyFilterSpec);
  25.  
  26. 			List<PropertyFilterSpec> listpfs = new ArrayList<PropertyFilterSpec>(10);
  27. 			listpfs.add(propertyFilterSpec);
  28. 			List<ObjectContent> listobjcont = retrievePropertiesAllObjects(listpfs);
  29.  
  30. 			if (listobjcont != null)
  31. 			{
  32. 				for (ObjectContent oc : listobjcont)
  33. 				{
  34. 					List<DynamicProperty> dps = oc.getPropSet();
  35. 					if (dps != null)
  36. 					{
  37. 						for (DynamicProperty dp : dps)
  38. 						{
  39. 							List<PerfCounterInfo> pcinfolist = ((ArrayOfPerfCounterInfo) dp.getVal()).getPerfCounterInfo();
  40. 							pciArr = pcinfolist;
  41. 						}
  42. 					}
  43. 				}
  44. 			}
  45. 		}
  46. 		catch (SOAPFaultException sfe)
  47. 		{
  48. 			printSoapFaultException(sfe);
  49. 		}
  50. 		catch (Exception e)
  51. 		{
  52. 			e.printStackTrace();
  53. 		}
  54. 		return pciArr;
  55. 	}

 

欢迎跳转到本文的原文链接：https://honeypps.com/backend/vmware-vsphere-webservice-sdk-virtual-cpu/

欢迎支持笔者新作：《深入理解Kafka:核心设计与实践原理》和《RabbitMQ实战指南》，同时欢迎关注笔者的微信公众号：朱小厮的博客。

 

 

 

 

 

 

相关技术文章

最新源码

下载排行榜
点击QQ咨询
开通会员
返回顶部
×
微信扫码支付 元
微信扫码支付
确定支付下载
请使用微信描二维码支付
×

提示信息

×

选择支付方式

  • 微信支付
  • 支付宝付款
确定支付下载