.net core 3.1 服务承载【依赖注入】

• .net core 3.1 服务承载【依赖注入】
  • 目录
  • 前言
  • 项目内容
    • 接口的代码
    • 实现性能的接口
    • 实现对指标的操作
    • 修改PerformanceMetricsCollector
    • 通过依赖注入的方式
    • 运行测试

目录

前言

项目内容

接口的代码

// 网络，内存，CPU性能接口
public interface IMemoryMetricsCollector
{
    long GetUsage();
}
public interface INetworkMetricsCollector
{
    long GetThroughput();
}
public interface IProcessorMetricsCollector
{
    int GetUsage();
}
// 处理接口
public interface IMetricsDeliverer
{
    Task DeliverAsync(PerformanceMetrics performanceMetrics);
}

实现性能的接口

public class FakeMetricsCollector :
    IProcessorMetricsCollector,
    INetworkMetricsCollector,
    IMemoryMetricsCollector
{
    public long GetThroughput() => PerformanceMetrics.Create().Network;
    public long GetUsage() => PerformanceMetrics.Create().Memory;
    int IProcessorMetricsCollector.GetUsage() => PerformanceMetrics.Create().Processor;
}

实现对指标的操作

public class FakeMetricsDeliverer : IMetricsDeliverer
{
    public Task DeliverAsync(PerformanceMetrics performanceMetrics)
    {
        Console.WriteLine($"[{DateTimeOffset.Now}]:{performanceMetrics}");
        return Task.CompletedTask;
    }
}

修改PerformanceMetricsCollector

public sealed class PerformanceMetricsCollector : IHostedService
{
    private readonly IProcessorMetricsCollector _processorMetricsCollector;
    private readonly INetworkMetricsCollector _networkMetricsCollector;
    private readonly IMetricsDeliverer _metricsDeliverer;
    private readonly IMemoryMetricsCollector _memoryMetricsCollector;
    private IDisposable _scheduler;
    public PerformanceMetricsCollector(
        IProcessorMetricsCollector processorMetricsCollector,
        INetworkMetricsCollector networkMetricsCollector,
        IMetricsDeliverer metricsDeliverer,
        IMemoryMetricsCollector memoryMetricsCollector
        )
    {
        _processorMetricsCollector = processorMetricsCollector;
        _networkMetricsCollector = networkMetricsCollector;
        _metricsDeliverer = metricsDeliverer;
        _memoryMetricsCollector = memoryMetricsCollector;
    }
    /// <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 async void Callback(object state)
    {
        // 通过不同
        var performanceMetrics = new PerformanceMetrics() {
            Memory = _memoryMetricsCollector.GetUsage(),
            Network = _networkMetricsCollector.GetThroughput(),
            Processor = _processorMetricsCollector.GetUsage()
        };
        await _metricsDeliverer.DeliverAsync(performanceMetrics);
    }
    /// <summary>
    /// 关闭服务
    /// </summary>
    /// <param name="cancellationToken"></param>
    /// <returns></returns>
    public Task StopAsync(CancellationToken cancellationToken)
    {
        _scheduler?.Dispose();
        return Task.CompletedTask;
    }
}

通过依赖注入的方式

var fakeMetricsCollector = new FakeMetricsCollector();
new HostBuilder()
    .ConfigureServices(svcs => svcs
        .AddSingleton<IProcessorMetricsCollector>(fakeMetricsCollector)
        .AddSingleton<INetworkMetricsCollector>(fakeMetricsCollector)
        .AddSingleton<IMemoryMetricsCollector>(fakeMetricsCollector)
        .AddSingleton<IMetricsDeliverer, FakeMetricsDeliverer>()
        .AddSingleton<IHostedService, PerformanceMetricsCollector>()
    )
    .Build()
    .Run();

运行测试