.net core 3.1 服务承载【承载长时间运行服务】

• .net core 3.1 服务承载【承载长时间运行服务】
  • 目录
  • 前言
  • 创建控制台项目
    • 添加相关依赖包
  • 添加长时间运行服务相关内容
    • 创建指标实例
    • 承载服务的实现
    • 构建承载系统
  • 运行测试

目录

前言

创建控制台项目

添加相关依赖包

<ItemGroup>
  <PackageReference Include="Microsoft.Extensions.Hosting" Version="3.1.11" />
  <PackageReference Include="Microsoft.Extensions.Hosting.Abstractions" Version="3.1.11" />
</ItemGroup>

添加长时间运行服务相关内容

创建指标实例

public class PerformanceMetrics
{
    private static readonly Random _random = new Random();
    /// <summary>
    /// CPU指标
    /// </summary>
    public int Processor { get; set; }
    /// <summary>
    /// 内存指标
    /// </summary>
    public long Memory { get; set; }
    /// <summary>
    /// 网络指标
    /// </summary>
    public long Network { get; set; }
    public override string ToString() => $"CPU:{Processor * 100}%; Memory: {Memory * (1024 * 1024)}M/s";
    /// <summary>
    /// 创建 PerformanceMetrics 的实例
    /// </summary>
    /// <returns></returns>
    public static PerformanceMetrics Create() => new PerformanceMetrics
    {
        // 随机生成指标
        Processor = _random.Next(1, 8),
        Memory = _random.Next(10, 100) * 1024 * 1024,
        Network = _random.Next(10, 100) * 1024 * 1024
    };
}

承载服务的实现

public sealed class PerformanceMetricsCollector : IHostedService
{
    private IDisposable _scheduler;
    /// <summary>
    /// 启动服务
    /// </summary>
    /// <param name="cancellationToken"></param>
    /// <returns></returns>
    public Task StartAsync(CancellationToken cancellationToken)
    {
        // 需要调用的方法  需要传入的对象  多久后启动  间隔时长执行一次
        _scheduler = new Timer(Callback,null,TimeSpan.FromSeconds(5),TimeSpan.FromSeconds(5));
        return Task.CompletedTask;
    }
    private void Callback(object state)
    {
        Console.WriteLine($"[{DateTimeOffset.Now}]{PerformanceMetrics.Create()}");
    }
    /// <summary>
    /// 关闭服务
    /// </summary>
    /// <param name="cancellationToken"></param>
    /// <returns></returns>
    public Task StopAsync(CancellationToken cancellationToken)
    {
        _scheduler?.Dispose();
        return Task.CompletedTask;
    }
}

构建承载系统

new HostBuilder()
    .ConfigureServices(svcs => svcs
        //.AddSingleton<IHostedService,PerformanceMetricsCollector>() 与下面一样的
        .AddHostedService<PerformanceMetricsCollector>())
    .Build()
    .Run();

运行测试