yx lin
3 months ago
committed by
GitHub
GitHub
17 changed files with 730 additions and 3 deletions
@ -0,0 +1,3 @@ |
|||||
|
<Weavers xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:noNamespaceSchemaLocation="FodyWeavers.xsd"> |
||||
|
<ConfigureAwait ContinueOnCapturedContext="false" /> |
||||
|
</Weavers> |
||||
@ -0,0 +1,30 @@ |
|||||
|
<?xml version="1.0" encoding="utf-8"?> |
||||
|
<xs:schema xmlns:xs="http://www.w3.org/2001/XMLSchema"> |
||||
|
<!-- This file was generated by Fody. Manual changes to this file will be lost when your project is rebuilt. --> |
||||
|
<xs:element name="Weavers"> |
||||
|
<xs:complexType> |
||||
|
<xs:all> |
||||
|
<xs:element name="ConfigureAwait" minOccurs="0" maxOccurs="1"> |
||||
|
<xs:complexType> |
||||
|
<xs:attribute name="ContinueOnCapturedContext" type="xs:boolean" /> |
||||
|
</xs:complexType> |
||||
|
</xs:element> |
||||
|
</xs:all> |
||||
|
<xs:attribute name="VerifyAssembly" type="xs:boolean"> |
||||
|
<xs:annotation> |
||||
|
<xs:documentation>'true' to run assembly verification (PEVerify) on the target assembly after all weavers have been executed.</xs:documentation> |
||||
|
</xs:annotation> |
||||
|
</xs:attribute> |
||||
|
<xs:attribute name="VerifyIgnoreCodes" type="xs:string"> |
||||
|
<xs:annotation> |
||||
|
<xs:documentation>A comma-separated list of error codes that can be safely ignored in assembly verification.</xs:documentation> |
||||
|
</xs:annotation> |
||||
|
</xs:attribute> |
||||
|
<xs:attribute name="GenerateXsd" type="xs:boolean"> |
||||
|
<xs:annotation> |
||||
|
<xs:documentation>'false' to turn off automatic generation of the XML Schema file.</xs:documentation> |
||||
|
</xs:annotation> |
||||
|
</xs:attribute> |
||||
|
</xs:complexType> |
||||
|
</xs:element> |
||||
|
</xs:schema> |
||||
@ -0,0 +1,22 @@ |
|||||
|
<Project Sdk="Microsoft.NET.Sdk"> |
||||
|
|
||||
|
<Import Project="..\..\..\..\configureawait.props" /> |
||||
|
<Import Project="..\..\..\..\common.props" /> |
||||
|
|
||||
|
<PropertyGroup> |
||||
|
<TargetFramework>net9.0</TargetFramework> |
||||
|
<AssemblyName>LINGYUN.Abp.SystemInfo.HttpApi</AssemblyName> |
||||
|
<PackageId>LINGYUN.Abp.SystemInfo.HttpApi</PackageId> |
||||
|
<GenerateAssemblyConfigurationAttribute>false</GenerateAssemblyConfigurationAttribute> |
||||
|
<GenerateAssemblyCompanyAttribute>false</GenerateAssemblyCompanyAttribute> |
||||
|
<GenerateAssemblyProductAttribute>false</GenerateAssemblyProductAttribute> |
||||
|
<RootNamespace /> |
||||
|
</PropertyGroup> |
||||
|
|
||||
|
<ItemGroup> |
||||
|
<PackageReference Include="Volo.Abp.AspNetCore.Mvc" /> |
||||
|
<PackageReference Include="DotNetCore.CAP" /> |
||||
|
<PackageReference Include="StackExchange.Redis" /> |
||||
|
</ItemGroup> |
||||
|
|
||||
|
</Project> |
||||
@ -0,0 +1,17 @@ |
|||||
|
using Microsoft.Extensions.DependencyInjection; |
||||
|
using Volo.Abp.AspNetCore.Mvc; |
||||
|
using Volo.Abp.Modularity; |
||||
|
|
||||
|
namespace LINGYUN.Abp.SystemInfo; |
||||
|
|
||||
|
[DependsOn(typeof(AbpAspNetCoreMvcModule))] |
||||
|
public class AbpSystemInfoHttpApiModule : AbpModule |
||||
|
{ |
||||
|
public override void PreConfigureServices(ServiceConfigurationContext context) |
||||
|
{ |
||||
|
PreConfigure<IMvcBuilder>(mvcBuilder => |
||||
|
{ |
||||
|
mvcBuilder.AddApplicationPartIfNotExists(typeof(AbpSystemInfoHttpApiModule).Assembly); |
||||
|
}); |
||||
|
} |
||||
|
} |
||||
@ -0,0 +1,27 @@ |
|||||
|
using System.Collections.Generic; |
||||
|
|
||||
|
namespace LINGYUN.Abp.SystemInfo.Models; |
||||
|
/// <summary>
|
||||
|
/// 组件
|
||||
|
/// </summary>
|
||||
|
public class ComponentInfoModel |
||||
|
{ |
||||
|
/// <summary>
|
||||
|
/// 组件名称
|
||||
|
/// </summary>
|
||||
|
public string Name { get; set; } |
||||
|
/// <summary>
|
||||
|
/// 组件名称集合
|
||||
|
/// </summary>
|
||||
|
public ComponentKeyModel[] Keys { get; set; } |
||||
|
/// <summary>
|
||||
|
/// 组件状态集合
|
||||
|
/// </summary>
|
||||
|
public Dictionary<string, object> Details { get; set; } |
||||
|
public ComponentInfoModel(string name, ComponentKeyModel[] keys, Dictionary<string, object> details) |
||||
|
{ |
||||
|
Name = name; |
||||
|
Keys = keys; |
||||
|
Details = details; |
||||
|
} |
||||
|
} |
||||
@ -0,0 +1,20 @@ |
|||||
|
namespace LINGYUN.Abp.SystemInfo.Models; |
||||
|
/// <summary>
|
||||
|
/// 组件名称
|
||||
|
/// </summary>
|
||||
|
public class ComponentKeyModel |
||||
|
{ |
||||
|
/// <summary>
|
||||
|
/// 组件名称
|
||||
|
/// </summary>
|
||||
|
public string Name { get; set; } |
||||
|
/// <summary>
|
||||
|
/// 组件显示名称
|
||||
|
/// </summary>
|
||||
|
public string DisplayName { get; set; } |
||||
|
public ComponentKeyModel(string name, string displayName) |
||||
|
{ |
||||
|
Name = name; |
||||
|
DisplayName = displayName; |
||||
|
} |
||||
|
} |
||||
@ -0,0 +1,9 @@ |
|||||
|
namespace LINGYUN.Abp.SystemInfo.Models; |
||||
|
|
||||
|
public class SystemInfoModel |
||||
|
{ |
||||
|
/// <summary>
|
||||
|
/// 组件状态集合
|
||||
|
/// </summary>
|
||||
|
public ComponentInfoModel[] Components { get; set; } |
||||
|
} |
||||
@ -0,0 +1,20 @@ |
|||||
|
using Volo.Abp.Authorization.Permissions; |
||||
|
using Volo.Abp.Localization; |
||||
|
|
||||
|
namespace LINGYUN.Abp.SystemInfo.Permissions; |
||||
|
|
||||
|
public class SystemInfoPermissionDefinitionProvider : PermissionDefinitionProvider |
||||
|
{ |
||||
|
public override void Define(IPermissionDefinitionContext context) |
||||
|
{ |
||||
|
var systemInfoGroup = context.AddGroup( |
||||
|
SystemInfoPermissions.GroupName, |
||||
|
new FixedLocalizableString("系统详情")); |
||||
|
|
||||
|
systemInfoGroup.AddPermission( |
||||
|
SystemInfoPermissions.Default, |
||||
|
new FixedLocalizableString("获取系统详情"), |
||||
|
Volo.Abp.MultiTenancy.MultiTenancySides.Host) |
||||
|
.WithProviders(ClientPermissionValueProvider.ProviderName); // 使用客户端授权
|
||||
|
} |
||||
|
} |
||||
@ -0,0 +1,8 @@ |
|||||
|
namespace LINGYUN.Abp.SystemInfo.Permissions; |
||||
|
|
||||
|
public static class SystemInfoPermissions |
||||
|
{ |
||||
|
public const string GroupName = "SystemInfo"; |
||||
|
|
||||
|
public const string Default = GroupName + ".Get"; |
||||
|
} |
||||
@ -0,0 +1,361 @@ |
|||||
|
using DotNetCore.CAP; |
||||
|
using LINGYUN.Abp.SystemInfo.Models; |
||||
|
using LINGYUN.Abp.SystemInfo.Permissions; |
||||
|
using LINGYUN.Abp.SystemInfo.Utils; |
||||
|
using Microsoft.AspNetCore.Authorization; |
||||
|
using Microsoft.AspNetCore.Mvc; |
||||
|
using Microsoft.Extensions.DependencyInjection; |
||||
|
using Microsoft.Extensions.Hosting; |
||||
|
using Microsoft.Extensions.Logging; |
||||
|
using StackExchange.Redis; |
||||
|
using System; |
||||
|
using System.Collections.Generic; |
||||
|
using System.Diagnostics; |
||||
|
using System.IO; |
||||
|
using System.Linq; |
||||
|
using System.Reflection; |
||||
|
using System.Runtime.InteropServices; |
||||
|
using System.Threading.Tasks; |
||||
|
using Volo.Abp.AspNetCore.Mvc; |
||||
|
|
||||
|
namespace LINGYUN.Abp.SystemInfo; |
||||
|
|
||||
|
[Controller] |
||||
|
[Route("api/system-info")] |
||||
|
[Authorize(SystemInfoPermissions.Default)] |
||||
|
public class SystemInfoController : AbpControllerBase |
||||
|
{ |
||||
|
[HttpGet] |
||||
|
public async virtual Task<SystemInfoModel> GetSystemInfoAsync() |
||||
|
{ |
||||
|
return new SystemInfoModel |
||||
|
{ |
||||
|
Components = new ComponentInfoModel[] |
||||
|
{ |
||||
|
GetSystemInfo(), |
||||
|
GetPerformanceInfo(), |
||||
|
GetRedisInfo(), |
||||
|
GetCapInfo(), |
||||
|
}, |
||||
|
}; |
||||
|
} |
||||
|
|
||||
|
private ComponentInfoModel GetSystemInfo() |
||||
|
{ |
||||
|
var env = HttpContext.RequestServices.GetService<IHostEnvironment>(); |
||||
|
using var process = Process.GetCurrentProcess(); |
||||
|
|
||||
|
var systemKeys = new List<ComponentKeyModel> |
||||
|
{ |
||||
|
new ComponentKeyModel("sys_machine_name", "机器名称"), |
||||
|
new ComponentKeyModel("sys_environment", "运行环境"), |
||||
|
new ComponentKeyModel("sys_framework_version", ".NET版本"), |
||||
|
new ComponentKeyModel("sys_os_version", "操作系统版本"), |
||||
|
new ComponentKeyModel("sys_app_db_provider", "数据库"), |
||||
|
new ComponentKeyModel("sys_app_version", "应用版本"), |
||||
|
new ComponentKeyModel("sys_app_build_time", "编译时间"), |
||||
|
new ComponentKeyModel("sys_app_start_time", "启动时间"), |
||||
|
}; |
||||
|
|
||||
|
var systemDetails = new Dictionary<string, object> |
||||
|
{ |
||||
|
{ "sys_machine_name", Environment.MachineName }, |
||||
|
{ "sys_environment", env?.EnvironmentName ?? Environment.GetEnvironmentVariable("ASPNETCORE_ENVIRONMENT") }, |
||||
|
{ "sys_framework_version", RuntimeInformation.FrameworkDescription }, |
||||
|
{ "sys_os_version", RuntimeInformation.OSDescription }, |
||||
|
{ "sys_app_db_provider", Environment.GetEnvironmentVariable("APPLICATION_DATABASE_PROVIDER") }, |
||||
|
{ "sys_app_start_time", process.StartTime.ToString("yyyy-MM-dd HH:mm:ss") }, |
||||
|
}; |
||||
|
|
||||
|
try |
||||
|
{ |
||||
|
var assembly = Assembly.GetEntryAssembly() ?? Assembly.GetExecutingAssembly(); |
||||
|
var fileVersionInfo = FileVersionInfo.GetVersionInfo(assembly.Location); |
||||
|
var assemblyName = assembly.GetName(); |
||||
|
var buildTime = GetBuildTime(assembly); |
||||
|
|
||||
|
systemDetails.Add("sys_app_version", fileVersionInfo.FileVersion ?? assemblyName.Version?.ToString() ?? "N/A"); |
||||
|
systemDetails.Add("sys_app_build_time", buildTime.HasValue ? buildTime.Value.ToString("yyyy-MM-dd HH:mm:ss") : "N/A"); |
||||
|
} |
||||
|
catch |
||||
|
{ |
||||
|
systemDetails.Add("sys_app_version", "N/A"); |
||||
|
systemDetails.Add("sys_app_build_time", "N/A"); |
||||
|
} |
||||
|
|
||||
|
return new ComponentInfoModel("系统", systemKeys.ToArray(), systemDetails); |
||||
|
} |
||||
|
|
||||
|
private ComponentInfoModel GetPerformanceInfo() |
||||
|
{ |
||||
|
using var process = Process.GetCurrentProcess(); |
||||
|
|
||||
|
var memoryMetrics = new MemoryMonitor().GetMemoryMetrics(); |
||||
|
var threadMetrics = new ThreadMonitor().GetThreadMetrics(); |
||||
|
var gcMetrics = new GCMonitor().GetGCMetrics(); |
||||
|
|
||||
|
return new ComponentInfoModel( |
||||
|
"性能", |
||||
|
new ComponentKeyModel[] |
||||
|
{ |
||||
|
new ComponentKeyModel("perf_total_memory", "总内存(MB)"), |
||||
|
new ComponentKeyModel("perf_working_set", "工作集内存(MB)"), |
||||
|
new ComponentKeyModel("perf_private_memory", "私有内存(MB)"), |
||||
|
new ComponentKeyModel("perf_gc_heap_size", "GC堆大小(MB)"), |
||||
|
new ComponentKeyModel("perf_gc0", "Gen0回收次数"), |
||||
|
new ComponentKeyModel("perf_gc1", "Gen1回收次数"), |
||||
|
new ComponentKeyModel("perf_gc2", "Gen2回收次数"), |
||||
|
new ComponentKeyModel("perf_active_total_memory", "总可用内存"), |
||||
|
new ComponentKeyModel("perf_memory_load", "内存负载"), |
||||
|
new ComponentKeyModel("perf_fragmented_bytes", "内存碎片大小"), |
||||
|
new ComponentKeyModel("perf_available_worker_threads", "可用工作线程数"), |
||||
|
new ComponentKeyModel("perf_available_completion_port_threads", "可用I/O线程数"), |
||||
|
new ComponentKeyModel("perf_max_worker_threads", "最大工作线程数"), |
||||
|
new ComponentKeyModel("perf_max_completion_port_threads", "最大I/O线程数"), |
||||
|
new ComponentKeyModel("perf_active_threads", "进程总线程数"), |
||||
|
new ComponentKeyModel("perf_thread_pool_thread_count", "线程池活动线程数"), |
||||
|
}, |
||||
|
new Dictionary<string, object> |
||||
|
{ |
||||
|
{ "perf_total_memory", memoryMetrics.TotalMemory }, |
||||
|
{ "perf_working_set", memoryMetrics.WorkingSet }, |
||||
|
{ "perf_private_memory", memoryMetrics.PrivateMemory }, |
||||
|
{ "perf_gc_heap_size", memoryMetrics.GCHeapSize }, |
||||
|
{ "perf_gc0", gcMetrics.Gen0Collections }, |
||||
|
{ "perf_gc1", gcMetrics.Gen1Collections }, |
||||
|
{ "perf_gc2", gcMetrics.Gen2Collections }, |
||||
|
{ "perf_active_total_memory", gcMetrics.TotalMemory }, |
||||
|
{ "perf_memory_load", gcMetrics.MemoryLoad }, |
||||
|
{ "perf_fragmented_bytes", gcMetrics.FragmentedBytes }, |
||||
|
{ "perf_available_worker_threads", threadMetrics.AvailableWorkerThreads }, |
||||
|
{ "perf_available_completion_port_threads", threadMetrics.AvailableCompletionPortThreads }, |
||||
|
{ "perf_max_worker_threads", threadMetrics.MaxWorkerThreads }, |
||||
|
{ "perf_max_completion_port_threads", threadMetrics.MaxCompletionPortThreads }, |
||||
|
{ "perf_active_threads", threadMetrics.ActiveThreads }, |
||||
|
{ "perf_thread_pool_thread_count", threadMetrics.ThreadPoolThreadCount }, |
||||
|
}); |
||||
|
} |
||||
|
|
||||
|
private ComponentInfoModel GetCapInfo() |
||||
|
{ |
||||
|
var cap = HttpContext.RequestServices.GetService<CapMarkerService>(); |
||||
|
var storage = HttpContext.RequestServices.GetService<CapStorageMarkerService>(); |
||||
|
var broker = HttpContext.RequestServices.GetService<CapMessageQueueMakerService>(); |
||||
|
|
||||
|
var capKeys = new List<ComponentKeyModel> |
||||
|
{ |
||||
|
new ComponentKeyModel("cap_status", "状态"), |
||||
|
new ComponentKeyModel("cap_version", "版本"), |
||||
|
new ComponentKeyModel("cap_storage", "持久化"), |
||||
|
new ComponentKeyModel("cap_transport", "传输"), |
||||
|
}; |
||||
|
var capDetails = new Dictionary<string, object> |
||||
|
{ |
||||
|
{ "cap_status", cap != null ? "正常" : "未启用" }, |
||||
|
{ "cap_version", cap != null ? cap.Version.Substring(0, 5) : "N/A" }, |
||||
|
{ "cap_storage", storage != null ? storage.Name : "N/A" }, |
||||
|
{ "cap_transport", broker != null ? broker.Name : "N/A" } |
||||
|
}; |
||||
|
|
||||
|
return new ComponentInfoModel("CAP组件", capKeys.ToArray(), capDetails); |
||||
|
} |
||||
|
|
||||
|
private ComponentInfoModel GetRedisInfo() |
||||
|
{ |
||||
|
var redis = HttpContext.RequestServices.GetService<IConnectionMultiplexer>(); |
||||
|
if (redis == null) |
||||
|
{ |
||||
|
return new ComponentInfoModel( |
||||
|
"Redis组件", |
||||
|
new ComponentKeyModel[] |
||||
|
{ |
||||
|
new ComponentKeyModel("redis_status", "状态") |
||||
|
}, |
||||
|
new Dictionary<string, object> |
||||
|
{ |
||||
|
{ "redis_status", "未注册" }, |
||||
|
}); |
||||
|
} |
||||
|
var redisInfo = new Dictionary<string, string>(); |
||||
|
|
||||
|
try |
||||
|
{ |
||||
|
var server = redis.GetServer(redis.GetEndPoints().First()); |
||||
|
var serverInfo = server.Info(); |
||||
|
foreach (var section in serverInfo) |
||||
|
{ |
||||
|
foreach (var item in section) |
||||
|
{ |
||||
|
redisInfo[item.Key] = item.Value; |
||||
|
} |
||||
|
} |
||||
|
} |
||||
|
catch(Exception ex) |
||||
|
{ |
||||
|
Logger.LogWarning("There is an exception in connecting to the redis server: {message}", ex.Message); |
||||
|
|
||||
|
return new ComponentInfoModel( |
||||
|
"Redis组件", |
||||
|
new ComponentKeyModel[] |
||||
|
{ |
||||
|
new ComponentKeyModel("redis_status", "状态") |
||||
|
}, |
||||
|
new Dictionary<string, object> |
||||
|
{ |
||||
|
{ "redis_status", "连接异常" }, |
||||
|
}); |
||||
|
} |
||||
|
|
||||
|
var uptimeSeconds = redisInfo.ContainsKey("uptime_in_seconds") ? long.Parse(redisInfo["uptime_in_seconds"]) : 0; |
||||
|
var days = Math.Floor((double)uptimeSeconds / 86400); |
||||
|
var hours = Math.Floor((double)uptimeSeconds % 86400 / 3600); |
||||
|
var minutes = Math.Floor((double)uptimeSeconds % 3600 / 60); |
||||
|
|
||||
|
var usedMemory = redisInfo.ContainsKey("used_memory") ? long.Parse(redisInfo["used_memory"]) : 0; |
||||
|
var maxMemory = redisInfo.ContainsKey("maxmemory") ? long.Parse(redisInfo["maxmemory"]) : 0; |
||||
|
var totalKeys = CalculateTotalKeys(redisInfo); |
||||
|
var expiresKeys = CalculateExpires(redisInfo); |
||||
|
var avgTtl = CalculateAvgTtl(redisInfo); |
||||
|
|
||||
|
var redisKeys = new List<ComponentKeyModel>() |
||||
|
{ |
||||
|
new ComponentKeyModel("redis_version", "版本"), |
||||
|
new ComponentKeyModel("redis_mode", "运行模式"), |
||||
|
new ComponentKeyModel("redis_os", "操作系统"), |
||||
|
new ComponentKeyModel("redis_uptime", "运行时间"), |
||||
|
new ComponentKeyModel("redis_used_cpu_sys", "系统CPU使用时间"), |
||||
|
new ComponentKeyModel("redis_used_cpu_user", "用户CPU使用时间"), |
||||
|
new ComponentKeyModel("redis_used_memory_mb", "使用内存(MB)"), |
||||
|
new ComponentKeyModel("redis_used_memory_rss_mb", "物理内存(MB)"), |
||||
|
new ComponentKeyModel("redis_used_memory_peak_mb", "内存使用峰值(MB)"), |
||||
|
new ComponentKeyModel("redis_maxmemory_mb", "最大内存限制(MB)"), |
||||
|
new ComponentKeyModel("redis_memory_usage_percent", "内存使用率(%)"), |
||||
|
new ComponentKeyModel("redis_mem_fragmentation_ratio", "内存碎片率"), |
||||
|
new ComponentKeyModel("redis_connected_clients", "已连接客户端数"), |
||||
|
new ComponentKeyModel("redis_blocked_clients", "阻塞客户端数"), |
||||
|
new ComponentKeyModel("redis_client_longest_output_list", "客户端最长输出列表"), |
||||
|
new ComponentKeyModel("redis_client_biggest_input_buf", "客户端最大输入缓冲区"), |
||||
|
new ComponentKeyModel("redis_maxclients", "最大客户端数"), |
||||
|
new ComponentKeyModel("redis_total_keys", "总键数量"), |
||||
|
new ComponentKeyModel("redis_expires_keys", "设置过期键数量"), |
||||
|
new ComponentKeyModel("redis_expired_keys", "已过期键数量"), |
||||
|
new ComponentKeyModel("redis_evicted_keys", "被驱逐键数量"), |
||||
|
new ComponentKeyModel("redis_avg_ttl_seconds", "平均TTL(秒)"), |
||||
|
}; |
||||
|
var redisDetails = new Dictionary<string, object>() |
||||
|
{ |
||||
|
{ "redis_version", redisInfo.GetValueOrDefault("redis_version", "unknown") }, |
||||
|
{ "redis_mode", redisInfo.GetValueOrDefault("redis_mode", "unknown") }, |
||||
|
{ "redis_os", redisInfo.GetValueOrDefault("os", "unknown") }, |
||||
|
{ "redis_uptime", $"{days}天{hours}时{minutes}分" }, |
||||
|
{ "redis_used_cpu_sys", redisInfo.GetValueOrDefault("used_cpu_sys", "0") }, |
||||
|
{ "redis_used_cpu_user", redisInfo.GetValueOrDefault("used_cpu_user", "0") }, |
||||
|
{ "redis_used_memory_mb", Math.Round((double)usedMemory / 1024 / 1024, 2) }, |
||||
|
{ "redis_used_memory_rss_mb", redisInfo.ContainsKey("used_memory_rss") ? |
||||
|
Math.Round(double.Parse(redisInfo["used_memory_rss"]) / 1024 / 1024, 2) : 0 }, |
||||
|
{ "redis_used_memory_peak_mb", redisInfo.ContainsKey("used_memory_peak") ? |
||||
|
Math.Round(double.Parse(redisInfo["used_memory_peak"]) / 1024 / 1024, 2) : 0 }, |
||||
|
{ "redis_maxmemory_mb", maxMemory > 0 ? Math.Round((double)maxMemory / 1024 / 1024, 2) : 0 }, |
||||
|
{ "redis_memory_usage_percent", maxMemory > 0 ? Math.Round((double)usedMemory / maxMemory * 100, 2) : 0 }, |
||||
|
{ "redis_mem_fragmentation_ratio", redisInfo.GetValueOrDefault("mem_fragmentation_ratio", "0") }, |
||||
|
{ "redis_connected_clients", redisInfo.GetValueOrDefault("connected_clients", "0") }, |
||||
|
{ "redis_blocked_clients", redisInfo.GetValueOrDefault("blocked_clients", "0") }, |
||||
|
{ "redis_client_longest_output_list", redisInfo.GetValueOrDefault("client_longest_output_list", "0") }, |
||||
|
{ "redis_client_biggest_input_buf", redisInfo.GetValueOrDefault("client_biggest_input_buf", "0") }, |
||||
|
{ "redis_maxclients", redisInfo.GetValueOrDefault("maxclients", "unlimited") }, |
||||
|
{ "redis_total_keys", totalKeys }, |
||||
|
{ "redis_expires_keys", expiresKeys }, |
||||
|
{ "redis_expired_keys", redisInfo.GetValueOrDefault("expired_keys", "0") }, |
||||
|
{ "redis_evicted_keys", redisInfo.GetValueOrDefault("evicted_keys", "0") }, |
||||
|
{ "redis_avg_ttl_seconds", avgTtl }, |
||||
|
}; |
||||
|
|
||||
|
return new ComponentInfoModel("Redis组件", redisKeys.ToArray(), redisDetails); |
||||
|
} |
||||
|
|
||||
|
private long CalculateTotalKeys(Dictionary<string, string> redisInfo) |
||||
|
{ |
||||
|
long total = 0; |
||||
|
|
||||
|
foreach (var item in redisInfo) |
||||
|
{ |
||||
|
if (item.Key.StartsWith("db")) |
||||
|
{ |
||||
|
var keysPart = item.Value.Split(',').FirstOrDefault(x => x.StartsWith("keys=")); |
||||
|
if (keysPart != null && long.TryParse(keysPart.Split('=')[1], out var count)) |
||||
|
{ |
||||
|
total += count; |
||||
|
} |
||||
|
} |
||||
|
} |
||||
|
|
||||
|
return total; |
||||
|
} |
||||
|
|
||||
|
private long CalculateExpires(Dictionary<string, string> redisInfo) |
||||
|
{ |
||||
|
long expires = 0; |
||||
|
|
||||
|
foreach (var item in redisInfo) |
||||
|
{ |
||||
|
if (item.Key.StartsWith("db")) |
||||
|
{ |
||||
|
var expiresPart = item.Value.Split(',').FirstOrDefault(x => x.StartsWith("expires=")); |
||||
|
if (expiresPart != null && long.TryParse(expiresPart.Split('=')[1], out var count)) |
||||
|
{ |
||||
|
expires += count; |
||||
|
} |
||||
|
} |
||||
|
} |
||||
|
|
||||
|
return expires; |
||||
|
} |
||||
|
|
||||
|
private long CalculateAvgTtl(Dictionary<string, string> redisInfo) |
||||
|
{ |
||||
|
long totalTtl = 0; |
||||
|
long dbCount = 0; |
||||
|
|
||||
|
foreach (var item in redisInfo) |
||||
|
{ |
||||
|
if (item.Key.StartsWith("db")) |
||||
|
{ |
||||
|
var ttlPart = item.Value.Split(',').FirstOrDefault(x => x.StartsWith("avg_ttl=")); |
||||
|
if (ttlPart != null && long.TryParse(ttlPart.Split('=')[1], out var ttl) && ttl > 0) |
||||
|
{ |
||||
|
totalTtl += ttl; |
||||
|
dbCount++; |
||||
|
} |
||||
|
} |
||||
|
} |
||||
|
|
||||
|
return dbCount > 0 ? totalTtl / dbCount : -1; |
||||
|
} |
||||
|
|
||||
|
private DateTime? GetBuildTime(Assembly assembly) |
||||
|
{ |
||||
|
try |
||||
|
{ |
||||
|
var attribute = assembly.GetCustomAttribute<AssemblyMetadataAttribute>(); |
||||
|
if (attribute != null && attribute.Key == "BuildTimestamp") |
||||
|
{ |
||||
|
if (DateTime.TryParse(attribute.Value, out var buildTime)) |
||||
|
{ |
||||
|
return buildTime; |
||||
|
} |
||||
|
} |
||||
|
|
||||
|
var fileInfo = new FileInfo(assembly.Location); |
||||
|
if (fileInfo.Exists) |
||||
|
{ |
||||
|
return fileInfo.LastWriteTime; |
||||
|
} |
||||
|
|
||||
|
return null; |
||||
|
} |
||||
|
catch |
||||
|
{ |
||||
|
return null; |
||||
|
} |
||||
|
} |
||||
|
} |
||||
@ -0,0 +1,63 @@ |
|||||
|
using System; |
||||
|
|
||||
|
namespace LINGYUN.Abp.SystemInfo.Utils; |
||||
|
|
||||
|
public class GCMetrics |
||||
|
{ |
||||
|
/// <summary>
|
||||
|
/// Gen0回收次数
|
||||
|
/// </summary>
|
||||
|
public int Gen0Collections { get; set; } |
||||
|
/// <summary>
|
||||
|
/// Gen1回收次数
|
||||
|
/// </summary>
|
||||
|
public int Gen1Collections { get; set; } |
||||
|
/// <summary>
|
||||
|
/// Gen2回收次数
|
||||
|
/// </summary>
|
||||
|
public int Gen2Collections { get; set; } |
||||
|
/// <summary>
|
||||
|
/// 总可用内存
|
||||
|
/// </summary>
|
||||
|
public long TotalMemory { get; set; } |
||||
|
/// <summary>
|
||||
|
/// 内存负载
|
||||
|
/// </summary>
|
||||
|
public long MemoryLoad { get; set; } |
||||
|
/// <summary>
|
||||
|
/// 内存碎片大小
|
||||
|
/// </summary>
|
||||
|
public long FragmentedBytes { get; set; } |
||||
|
} |
||||
|
|
||||
|
public class GCMonitor |
||||
|
{ |
||||
|
private int _lastGen0; |
||||
|
private int _lastGen1; |
||||
|
private int _lastGen2; |
||||
|
|
||||
|
public GCMetrics GetGCMetrics() |
||||
|
{ |
||||
|
var currentGen0 = GC.CollectionCount(0); |
||||
|
var currentGen1 = GC.CollectionCount(1); |
||||
|
var currentGen2 = GC.CollectionCount(2); |
||||
|
|
||||
|
var metrics = new GCMetrics |
||||
|
{ |
||||
|
Gen0Collections = currentGen0 - _lastGen0, |
||||
|
Gen1Collections = currentGen1 - _lastGen1, |
||||
|
Gen2Collections = currentGen2 - _lastGen2 |
||||
|
}; |
||||
|
|
||||
|
var gcInfo = GC.GetGCMemoryInfo(); |
||||
|
metrics.TotalMemory = gcInfo.TotalAvailableMemoryBytes; |
||||
|
metrics.MemoryLoad = gcInfo.MemoryLoadBytes; |
||||
|
metrics.FragmentedBytes = gcInfo.FragmentedBytes; |
||||
|
|
||||
|
_lastGen0 = currentGen0; |
||||
|
_lastGen1 = currentGen1; |
||||
|
_lastGen2 = currentGen2; |
||||
|
|
||||
|
return metrics; |
||||
|
} |
||||
|
} |
||||
@ -0,0 +1,54 @@ |
|||||
|
using System; |
||||
|
using System.Diagnostics; |
||||
|
|
||||
|
namespace LINGYUN.Abp.SystemInfo.Utils; |
||||
|
|
||||
|
public class MemoryMetrics |
||||
|
{ |
||||
|
/// <summary>
|
||||
|
/// 总物理内存
|
||||
|
/// </summary>
|
||||
|
public long TotalMemory { get; set; } |
||||
|
/// <summary>
|
||||
|
/// 工作集内存
|
||||
|
/// </summary>
|
||||
|
public long WorkingSet { get; set; } |
||||
|
/// <summary>
|
||||
|
/// 私有内存
|
||||
|
/// </summary>
|
||||
|
public long PrivateMemory { get; set; } |
||||
|
/// <summary>
|
||||
|
/// 虚拟内存
|
||||
|
/// </summary>
|
||||
|
public long VirtualMemory { get; set; } |
||||
|
/// <summary>
|
||||
|
/// GC堆大小
|
||||
|
/// </summary>
|
||||
|
public long GCHeapSize { get; set; } |
||||
|
} |
||||
|
|
||||
|
public class MemoryMonitor |
||||
|
{ |
||||
|
// 转换为MB
|
||||
|
const long MB = 1024 * 1024; |
||||
|
|
||||
|
public MemoryMetrics GetMemoryMetrics() |
||||
|
{ |
||||
|
var process = Process.GetCurrentProcess(); |
||||
|
|
||||
|
return new MemoryMetrics |
||||
|
{ |
||||
|
TotalMemory = GC.GetTotalMemory(false) / MB, |
||||
|
WorkingSet = process.WorkingSet64 / MB, |
||||
|
PrivateMemory = process.PrivateMemorySize64 / MB, |
||||
|
VirtualMemory = process.VirtualMemorySize64 / MB, |
||||
|
GCHeapSize = GetGCHeapSize() / MB |
||||
|
}; |
||||
|
} |
||||
|
|
||||
|
private long GetGCHeapSize() |
||||
|
{ |
||||
|
var gcInfo = GC.GetGCMemoryInfo(); |
||||
|
return (long)gcInfo.HeapSizeBytes; |
||||
|
} |
||||
|
} |
||||
@ -0,0 +1,59 @@ |
|||||
|
using System.Diagnostics; |
||||
|
using System.Threading; |
||||
|
|
||||
|
namespace LINGYUN.Abp.SystemInfo.Utils; |
||||
|
|
||||
|
public class ThreadMetrics |
||||
|
{ |
||||
|
/// <summary>
|
||||
|
/// 可用工作线程数
|
||||
|
/// </summary>
|
||||
|
public int AvailableWorkerThreads { get; set; } |
||||
|
/// <summary>
|
||||
|
/// 可用I/O线程数
|
||||
|
/// </summary>
|
||||
|
public int AvailableCompletionPortThreads { get; set; } |
||||
|
/// <summary>
|
||||
|
/// 最大工作线程数
|
||||
|
/// </summary>
|
||||
|
public int MaxWorkerThreads { get; set; } |
||||
|
/// <summary>
|
||||
|
/// 最大I/O线程数
|
||||
|
/// </summary>
|
||||
|
public int MaxCompletionPortThreads { get; set; } |
||||
|
/// <summary>
|
||||
|
/// 进程总线程数
|
||||
|
/// </summary>
|
||||
|
public int ActiveThreads { get; set; } |
||||
|
/// <summary>
|
||||
|
/// 线程池活动线程数
|
||||
|
/// </summary>
|
||||
|
public int ThreadPoolThreadCount { get; set; } |
||||
|
} |
||||
|
|
||||
|
public class ThreadMonitor |
||||
|
{ |
||||
|
public ThreadMetrics GetThreadMetrics() |
||||
|
{ |
||||
|
ThreadPool.GetAvailableThreads( |
||||
|
out var availableWorkerThreads, |
||||
|
out var availableCompletionPortThreads); |
||||
|
ThreadPool.GetMaxThreads( |
||||
|
out var maxWorkerThreads, |
||||
|
out var maxCompletionPortThreads); |
||||
|
|
||||
|
// 获取进程线程数（近似活动线程数）
|
||||
|
var process = Process.GetCurrentProcess(); |
||||
|
var threads = process.Threads; |
||||
|
|
||||
|
return new ThreadMetrics |
||||
|
{ |
||||
|
AvailableWorkerThreads = availableWorkerThreads, |
||||
|
AvailableCompletionPortThreads = availableCompletionPortThreads, |
||||
|
MaxWorkerThreads = maxWorkerThreads, |
||||
|
MaxCompletionPortThreads = maxCompletionPortThreads, |
||||
|
ActiveThreads = threads.Count, |
||||
|
ThreadPoolThreadCount = ThreadPool.ThreadCount |
||||
|
}; |
||||
|
} |
||||
|
} |
||||
Loading…
Reference in new issue