关键词搜索

源码搜索 ×
×

使用VMware VSphere WebService SDK进行开发 （四）——获取集群（Cluster, ComputeResource）的相关信息

发布2015-11-11浏览7532次

详情内容

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

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

 

获取集群的信息不再过多的赘述，详细读过前面两篇文章的读者已经很快上路子了~

疯狂罗列代码：

 

  1. 	private static TraversalSpec getComputeResourceTraversalSpec()
  2. 	{
  3. 		SelectionSpec ss = new SelectionSpec();
  4. 		ss.setName("VisitFolders");
  5.  
  6. 		TraversalSpec hostFolderToComputeResource = new TraversalSpec();
  7. 		hostFolderToComputeResource.setName("hostFolderToComputeResource");
  8. 		hostFolderToComputeResource.setType("Folder");
  9. 		hostFolderToComputeResource.setPath("childEntity");
  10. 		hostFolderToComputeResource.setSkip(false);
  11. 		hostFolderToComputeResource.getSelectSet().add(ss);
  12.  
  13. 		TraversalSpec dataCenterToHostFolder = new TraversalSpec();
  14. 		dataCenterToHostFolder.setName("DataCenterToHostFolder");
  15. 		dataCenterToHostFolder.setType("Datacenter");
  16. 		dataCenterToHostFolder.setPath("hostFolder");
  17. 		dataCenterToHostFolder.setSkip(false);
  18. 		dataCenterToHostFolder.getSelectSet().add(ss);
  19.  
  20. 		TraversalSpec traversalSpec = new TraversalSpec();
  21. 		traversalSpec.setName("VisitFolders");
  22. 		traversalSpec.setType("Folder");
  23. 		traversalSpec.setPath("childEntity");
  24. 		traversalSpec.setSkip(false);
  25.  
  26. 		List<SelectionSpec> sSpecArr = new ArrayList<SelectionSpec>();
  27. 		sSpecArr.add(ss);
  28. 		sSpecArr.add(dataCenterToHostFolder);
  29. 		sSpecArr.add(hostFolderToComputeResource);
  30. 		traversalSpec.getSelectSet().addAll(sSpecArr);
  31. 		return traversalSpec;
  32. 	}
  1. 	private static ManagedObjectReference getDatacenterByName(String datacenterName)
  2. 	{
  3. 		ManagedObjectReference retVal = null;
  4. 		ManagedObjectReference rootFolder = serviceContent.getRootFolder();
  5. 		try
  6. 		{
  7. 			TraversalSpec tSpec = getDatacenterTraversalSpec();
  8. 			PropertySpec propertySpec = new PropertySpec();
  9. 			propertySpec.setAll(Boolean.FALSE);
  10. 			propertySpec.getPathSet().add("name");
  11. 			propertySpec.setType("Datacenter");
  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> listfps = new ArrayList<PropertyFilterSpec>(1);
  23. 			listfps.add(propertyFilterSpec);
  24. 			List<ObjectContent> listobcont = retrievePropertiesAllObjects(listfps);
  25.  
  26. 			if (listobcont != null)
  27. 			{
  28. 				for (ObjectContent oc : listobcont)
  29. 				{
  30. 					ManagedObjectReference mr = oc.getObj();
  31. 					String dcnm = null;
  32. 					List<DynamicProperty> dps = oc.getPropSet();
  33. 					if (dps != null)
  34. 					{
  35. 						for (DynamicProperty dp : dps)
  36. 						{
  37. 							dcnm = (String) dp.getVal();
  38. 						}
  39. 					}
  40.  
  41. 					if (dcnm != null && dcnm.equals(datacenterName))
  42. 					{
  43. 						retVal = mr;
  44. 						break;
  45. 					}
  46. 				}
  47. 			}
  48. 		}
  49. 		catch (SOAPFaultException sfe)
  50. 		{
  51. 			printSoapFaultException(sfe);
  52. 		}
  53. 		catch (Exception e)
  54. 		{
  55. 			e.printStackTrace();
  56. 		}
  57. 		return retVal;
  58. 	}
  1. 	private static List<List<Long>> getClusterData(String clusterName, String nameInfo, String groupInfo) throws RuntimeFaultFaultMsg, DatatypeConfigurationException
  2. 	{
  3. 		List<List<Long>> list = new ArrayList<List<Long>>();
  4. 		ManagedObjectReference vmmor = getComputeResouceByCrName(clusterName);
  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. 			XMLGregorianCalendar beginTime = DateConvert.convertToXMLGregorianCalendar(new Date(new Date().getTime() - 1000 * 60 * 5));
  23. 			XMLGregorianCalendar endTime = DateConvert.convertToXMLGregorianCalendar(new Date());
  24. 			List<PerfMetricId> listpermeid = vimPort.queryAvailablePerfMetric(perfManager, vmmor, null, null, null);
  25.  
  26. 			ArrayList<PerfMetricId> mMetrics = new ArrayList<PerfMetricId>();
  27. 			if (listpermeid != null)
  28. 			{
  29. 				for (int index = 0; index < listpermeid.size(); ++index)
  30. 				{
  31. 					if (counters.containsKey(new Integer(listpermeid.get(index).getCounterId())))
  32. 					{
  33. 						mMetrics.add(listpermeid.get(index));
  34. 					}
  35. 				}
  36. 			}
  37.  
  38. 			PerfQuerySpec qSpec = new PerfQuerySpec();
  39. 			qSpec.setEntity(vmmor);
  40. 			qSpec.getMetricId().addAll(mMetrics);
  41. 			qSpec.setEndTime(endTime);
  42. 			qSpec.setStartTime(beginTime);
  43.  
  44. 			List<PerfQuerySpec> qSpecs = new ArrayList<PerfQuerySpec>();
  45. 			qSpecs.add(qSpec);
  46.  
  47. 			List<PerfEntityMetricBase> listpemb = vimPort.queryPerf(perfManager, qSpecs);
  48. 			List<PerfEntityMetricBase> pValues = listpemb;
  49.  
  50. 			for (i = 0; i < pValues.size(); i++)
  51. 			{
  52. 				List<PerfMetricSeries> listpems = ((PerfEntityMetric) pValues.get(i)).getValue();
  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. 	}
  1. 	private static String getClusterPropertyByClusterName(String property, String clusterName) throws InvalidPropertyFaultMsg, RuntimeFaultFaultMsg
  2. 	{
  3. 		String ans = null;
  4. 		RetrieveResult props = getRetrieveResultObjectWithProperty("ComputeResource", 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(clusterName))
  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(clusterName))
  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 getClusterCpuUsageByClusterName(String clusterName) throws RuntimeFaultFaultMsg, DatatypeConfigurationException
  2. 	{
  3. 		double ans = 0.0;
  4. 		List<List<Long>> list = getClusterData(clusterName, "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 long getClusterEffectiveMemoryByClusterName(String clusterName) throws InvalidPropertyFaultMsg, RuntimeFaultFaultMsg
  2. 	{
  3. 		long ans = 0;
  4. 		String ret = getClusterPropertyByClusterName("summary.effectiveMemory", clusterName);
  5. 		ans = Long.valueOf(ret);
  6. 		return ans;
  7. 	}

同样以罗列集群名称的代码结束：

 

  1. 	public static List<String> getClusterNames()
  2. 	{
  3. 		List<String> list = new ArrayList<String>();
  4. 		ManagedObjectReference rootFolder = serviceContent.getRootFolder();
  5. 		try
  6. 		{
  7. 			TraversalSpec tSpec = getComputeResourceTraversalSpec();
  8. 			PropertySpec propertySpec = new PropertySpec();
  9. 			propertySpec.setAll(Boolean.FALSE);
  10. 			propertySpec.getPathSet().add("name");
  11. 			propertySpec.setType("ClusterComputeResource");
  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> listfps = new ArrayList<PropertyFilterSpec>(1);
  23. 			listfps.add(propertyFilterSpec);
  24. 			List<ObjectContent> listobcont = retrievePropertiesAllObjects(listfps);
  25.  
  26. 			if (listobcont != null)
  27. 			{
  28. 				for (ObjectContent oc : listobcont)
  29. 				{
  30. 					String dcnm = null;
  31. 					List<DynamicProperty> dps = oc.getPropSet();
  32. 					if (dps != null)
  33. 					{
  34. 						for (DynamicProperty dp : dps)
  35. 						{
  36. 							dcnm = (String) dp.getVal();
  37. 							if (dcnm != null)
  38. 							{
  39. 								list.add(dcnm);
  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.  
  55. 		return list;
  56. 	}

 

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

 

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




 

相关技术文章

最新源码

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

提示信息

×

选择支付方式

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