我让它工作了——尽管它并不是很直接。
首先,我必须对我之前的陈述进行一些更正——只是为了保持在同一水平上。
在云服务中有多个虚拟机,每个虚拟机托管一个 WebRole 实例或一个 WorkerRole 实例。因此,在单个 VM 上,只有一个 w3wp 运行,或者根本没有 w3wp,只有一个 waworkerhost 进程。
在我的特殊情况下,可以在单个 VM 上运行两个 w3wp。所以我需要区分这两者 - 因此要求我进行某种流程实例关联。
我想记录的是:单个 VM 的总 CPU 负载,在 VM 上运行的实例进程的 CPU 负载(w3wp,waworkerhost)。
每个 VM 的总 CPU 负载的 PerformanceCounter 很简单且相等: \Processor(_Total)\% Processortime for the webrole VM 我不能只使用 \process(w3wp)\% processortime 计数器,因为我不能确定它是否正确w3wp(见上文)
现在这是我所做的:由于您必须为 WebRole.cs 或 WorkerRole.cs 中的每个角色实例 OnStart() 启动性能计数器监视器,我认为这是我可以以某种方式收集所需信息的唯一地方。
在 WorkerRole.cs 我做了:
int pc = Environment.ProcessorCount;
string instance = RoleEnvironment.CurrentRoleInstance.Id;
SomeOtherManagementClass.StartDiagnosticMonitorService(pc, instance, Process.GetCurrentProcess());
在 WebRole.cs 中 CurrentProcess 也返回 WaWorkerHost,所以我不得不将上面的代码行移动到 WebRole 的 global.asax 中。这里有正确的过程可用。
在 SomeOtherManagementClass 我放了 StartDiagnosticsMonitorService ,它现在接收调用 StartDiagnosticsMonitorService 的 CurrentProcess。(从 workerrole.cs 它将接收 WaWorkerHost 进程并从 WebRoles 接收 w3wp 进程 - 包括 PID)
public static void StartDiagnosticMonitorService(int coreCount, string currentRole, Process process)
{
string processName = GetProcessInstanceName(process.Id);
SetCPUCoreData(coreCount, currentRole, processName, process.Id);
...
instanceProcessLoadCounterName = String.Format(@"\Process({0})\% Processor Time", processName);
}
现在在每个 VM 上调用 GetProcessInstanceName(process.Id) 并将 processName 获取到提供的 process.Id - 这允许您区分单个 VM 上的多个 w3wps,因为返回的 instanceNames 是 w3wp、w3wp#1、w3wp# 2等与GetCurrentProcess提供的processName相反,它总是w3wp。为此,我修改了我在 stackoverflow 上找到的代码示例 - 你可以在下面找到它:
private static string GetProcessInstanceName(int pid)
{
PerformanceCounterCategory cat = new PerformanceCounterCategory("Process");
string[] instances = cat.GetInstanceNames();
foreach (string instance in instances)
{
try
{
using (PerformanceCounter cnt = new PerformanceCounter("Process",
"ID Process", instance, true))
{
int val = (int)cnt.RawValue;
if (val == pid)
{
return instance;
}
}
}
catch (InvalidOperationException)
{
//this point is reached when a process terminates while iterating the processlist- this it cannot be found
}
}
return "";
}
最后但同样重要的是:SetCPUCoreData(coreCount, currentRole, processName, process.Id) 将进程的所有相关数据保存到 azure 存储中,以便在应用程序的任何地方都可以使用它:
private static void SetCPUCoreData(int count, string roleinstance, string processName, int processID)
{
string[] instances = roleinstance.Split('.');
CloudStorageAccount storageAccount = CloudStorageAccount.Parse(GetSettingValue("LoadMonitor.Connection.String"));
CloudTableClient cloudTableClient = storageAccount.CreateCloudTableClient();
const string tableName = "PerformanceMonitorCoreCount";
cloudTableClient.CreateTableIfNotExist(tableName);
TableServiceContext serviceContext = cloudTableClient.GetDataServiceContext();
PerformanceCounterCPUCoreEntity ent = new PerformanceCounterCPUCoreEntity(count, instances[instances.Count() - 1],processName, processID);
serviceContext.AttachTo(tableName, ent);
serviceContext.UpdateObject(ent);
serviceContext.SaveChangesWithRetries(SaveChangesOptions.ReplaceOnUpdate);
}
PerformanceCounterCPUCoreEntity 是 StorageTable 的模板 - 如果您对此部分有任何疑问,或者只是询问,请查看 azure Storage API。