关键词搜索

源码搜索 ×
×

使用VMware VSphere WebService SDK进行开发 （三）——获取主机（HostSystem）的基本信息

发布2015-11-11浏览9488次

详情内容

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

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

 

通过前面两篇文章的了解，详细应该很快掌握的code路数，这里首先罗列如何获取主机（接下去也会成为HostSystem）的对象。

 

  1. 	private static TraversalSpec getHostSystemTraversalSpec()
  2. 	{
  3. 		SelectionSpec ss = new SelectionSpec();
  4. 		ss.setName("VisitFolders");
  5.  
  6. 		TraversalSpec computeResourceToHostSystem = new TraversalSpec();
  7. 		computeResourceToHostSystem.setName("computeResourceToHostSystem");
  8. 		computeResourceToHostSystem.setType("ComputeResource");
  9. 		computeResourceToHostSystem.setPath("host");
  10. 		computeResourceToHostSystem.setSkip(false);
  11. 		computeResourceToHostSystem.getSelectSet().add(ss);
  12.  
  13. 		TraversalSpec hostFolderToComputeResource = new TraversalSpec();
  14. 		hostFolderToComputeResource.setName("hostFolderToComputeResource");
  15. 		hostFolderToComputeResource.setType("Folder");
  16. 		hostFolderToComputeResource.setPath("childEntity");
  17. 		hostFolderToComputeResource.setSkip(false);
  18. 		hostFolderToComputeResource.getSelectSet().add(ss);
  19.  
  20. 		TraversalSpec dataCenterToHostFolder = new TraversalSpec();
  21. 		dataCenterToHostFolder.setName("DataCenterToHostFolder");
  22. 		dataCenterToHostFolder.setType("Datacenter");
  23. 		dataCenterToHostFolder.setPath("hostFolder");
  24. 		dataCenterToHostFolder.setSkip(false);
  25. 		dataCenterToHostFolder.getSelectSet().add(ss);
  26.  
  27. 		TraversalSpec traversalSpec = new TraversalSpec();
  28. 		traversalSpec.setName("VisitFolders");
  29. 		traversalSpec.setType("Folder");
  30. 		traversalSpec.setPath("childEntity");
  31. 		traversalSpec.setSkip(false);
  32.  
  33. 		List<SelectionSpec> sSpecArr = new ArrayList<SelectionSpec>();
  34. 		sSpecArr.add(ss);
  35. 		sSpecArr.add(dataCenterToHostFolder);
  36. 		sSpecArr.add(hostFolderToComputeResource);
  37. 		sSpecArr.add(computeResourceToHostSystem);
  38. 		traversalSpec.getSelectSet().addAll(sSpecArr);
  39. 		return traversalSpec;
  40. 	}
  1. 	private static ManagedObjectReference getHostByHostName(String hostName)
  2. 	{
  3. 		ManagedObjectReference retVal = null;
  4. 		ManagedObjectReference rootFolder = serviceContent.getRootFolder();
  5. 		try
  6. 		{
  7. 			TraversalSpec tSpec = getHostSystemTraversalSpec();
  8. 			PropertySpec propertySpec = new PropertySpec();
  9. 			propertySpec.setAll(Boolean.FALSE);
  10. 			propertySpec.getPathSet().add("name");
  11. 			propertySpec.setType("HostSystem");
  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 hostnm = null;
  32. 					List<DynamicProperty> listDynamicProps = oc.getPropSet();
  33. 					DynamicProperty[] dps = listDynamicProps.toArray(new DynamicProperty[listDynamicProps.size()]);
  34. 					if (dps != null)
  35. 					{
  36. 						for (DynamicProperty dp : dps)
  37. 						{
  38. 							hostnm = (String) dp.getVal();
  39. 						}
  40. 					}
  41. 					if (hostnm != null && hostnm.equals(hostName))
  42. 					{
  43. 						retVal = mr;
  44. 						break;
  45. 					}
  46. 				}
  47. 			}
  48. 			else
  49. 			{
  50. 				System.out.println("The Object Content is Null");
  51. 			}
  52. 		}
  53. 		catch (SOAPFaultException sfe)
  54. 		{
  55. 			printSoapFaultException(sfe);
  56. 		}
  57. 		catch (Exception e)
  58. 		{
  59. 			e.printStackTrace();
  60. 		}
  61. 		return retVal;
  62. 	}

接下去展示获取HostSystem的性能信息的方法，和VirtualMachine的类似。

 

 

  1. 	private static List<List<Long>> getHostData(String hostName, String nameInfo, String groupInfo) throws RuntimeFaultFaultMsg
  2. 	{
  3. 		List<List<Long>> list = new ArrayList<List<Long>>();
  4. 		ManagedObjectReference vmmor = getHostByHostName(hostName);
  5. 		if (vmmor != null)
  6. 		{
  7. 			List<PerfCounterInfo> cInfo = getPerfCounters();
  8. 			List<PerfCounterInfo> vmCpuCounters = new ArrayList<PerfCounterInfo>();
  9. 			for (int i = 0; i < cInfo.size(); ++i)
  10. 			{
  11. 				vmCpuCounters.add(cInfo.get(i));
  12. 			}
  13.  
  14. 			int i = 0;
  15. 			Map<Integer, PerfCounterInfo> counters = new HashMap<Integer, PerfCounterInfo>();
  16. 			for (Iterator<PerfCounterInfo> it = vmCpuCounters.iterator(); it.hasNext();)
  17. 			{
  18. 				PerfCounterInfo pcInfo = (PerfCounterInfo) it.next();
  19. 				counters.put(new Integer(pcInfo.getKey()), pcInfo);
  20. 			}
  21.  
  22. 			List<PerfMetricId> listpermeid = vimPort.queryAvailablePerfMetric(perfManager, vmmor, null, null, new Integer(20));
  23.  
  24. 			ArrayList<PerfMetricId> mMetrics = new ArrayList<PerfMetricId>();
  25. 			if (listpermeid != null)
  26. 			{
  27. 				for (int index = 0; index < listpermeid.size(); ++index)
  28. 				{
  29. 					if (counters.containsKey(new Integer(listpermeid.get(index).getCounterId())))
  30. 					{
  31. 						mMetrics.add(listpermeid.get(index));
  32. 					}
  33. 				}
  34. 			}
  35.  
  36. 			PerfQuerySpec qSpec = new PerfQuerySpec();
  37. 			qSpec.setEntity(vmmor);
  38. 			qSpec.setMaxSample(new Integer(10));
  39. 			qSpec.getMetricId().addAll(mMetrics);
  40. 			qSpec.setIntervalId(new Integer(20));
  41.  
  42. 			List<PerfQuerySpec> qSpecs = new ArrayList<PerfQuerySpec>();
  43. 			qSpecs.add(qSpec);
  44.  
  45. 			List<PerfEntityMetricBase> listpemb = vimPort.queryPerf(perfManager, qSpecs);
  46. 			List<PerfEntityMetricBase> pValues = listpemb;
  47.  
  48. 			// System.out.println("pValues.size() = "+pValues.size());
  49. 			for (i = 0; i < pValues.size(); i++)
  50. 			{
  51. 				List<PerfMetricSeries> listpems = ((PerfEntityMetric) pValues.get(i)).getValue();
  52. 				// System.out.println("listpems.size() = "+listpems.size());
  53. 				for (int vi = 0; vi < listpems.size(); ++vi)
  54. 				{
  55. 					String printInf = "";
  56. 					PerfCounterInfo pci = (PerfCounterInfo) counters.get(new Integer(listpems.get(vi).getId().getCounterId()));
  57.  
  58. 					if (pci != null)
  59. 					{
  60. 						if (pci.getNameInfo().getKey().equalsIgnoreCase(nameInfo) && pci.getGroupInfo().getKey().equalsIgnoreCase(groupInfo))
  61. 						{
  62. 							printInf += vi + ":" + pci.getNameInfo().getSummary() + ":" + pci.getNameInfo().getKey() + ":" + pci.getNameInfo().getLabel() + ":"
  63. 									+ pci.getGroupInfo().getKey() + ":" + pci.getGroupInfo().getLabel() + ":" + pci.getGroupInfo().getSummary() + " ";
  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 getHostCpuUsageByHostName(String hostName) throws RuntimeFaultFaultMsg
  2. 	{
  3. 		double ans = 0.0;
  4. 		List<List<Long>> list = getHostData(hostName, "usage", "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. 		ans = ans / 100;
  25. 		return ans;
  26. 	}

与VirtualMachine相同，Hostsystem也有些信息要通过另一种方式遍历。

 

譬如获取主机cpu的个数：

 

  1. <span style="white-space:pre">	</span>private static String getHostPropertyByHostName(String property, String hostName) throws InvalidPropertyFaultMsg, RuntimeFaultFaultMsg
  2. 	{
  3. 		String ans = null;
  4. 		RetrieveResult props = getRetrieveResultObjectWithProperty("HostSystem", 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(hostName))
  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(hostName))
  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. 	public static double getHostCpuUsageByHostName(String hostName) throws RuntimeFaultFaultMsg
  2. 	{
  3. 		double ans = 0.0;
  4. 		List<List<Long>> list = getHostData(hostName, "usage", "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. 		ans = ans / 100;
  25. 		return ans;
  26. 	}

这里不做过多的说明，相信读者如果真的想要迫切了解这些内容，肯定会自己研究，本人罗列的代码都是亲身试用到项目中的，保证能够运行。希望对各位有帮助。

 

这里同样采用获取主机名称的方法来结束：

 

  1. 	public static List<String> getHostNames()
  2. 	{
  3. 		List<String> list = new ArrayList<String>();
  4. 		ManagedObjectReference rootFolder = serviceContent.getRootFolder();
  5. 		try
  6. 		{
  7. 			TraversalSpec tSpec = getHostSystemTraversalSpec();
  8. 			PropertySpec propertySpec = new PropertySpec();
  9. 			propertySpec.setAll(Boolean.FALSE);
  10. 			propertySpec.getPathSet().add("name");
  11. 			propertySpec.setType("HostSystem");
  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 hostnm = null;
  31. 					List<DynamicProperty> listDynamicProps = oc.getPropSet();
  32. 					DynamicProperty[] dps = listDynamicProps.toArray(new DynamicProperty[listDynamicProps.size()]);
  33. 					if (dps != null)
  34. 					{
  35. 						for (DynamicProperty dp : dps)
  36. 						{
  37. 							hostnm = (String) dp.getVal();
  38. 							if (hostnm != null)
  39. 							{
  40. 								list.add(hostnm);
  41. 							}
  42. 						}
  43. 					}
  44. 				}
  45. 			}
  46. 			else
  47. 			{
  48. 				System.out.println("getHostNames: Object Content is null ");
  49. 			}
  50. 		}
  51. 		catch (SOAPFaultException sfe)
  52. 		{
  53. 			printSoapFaultException(sfe);
  54. 		}
  55. 		catch (Exception e)
  56. 		{
  57. 			e.printStackTrace();
  58. 		}
  59.  
  60. 		return list;
  61. 	}

 

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

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

相关技术文章

最新源码

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

提示信息

×

选择支付方式

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