.net core 3.1 服务承载【BackgroundService】

• .net core 3.1 服务承载【BackgroundService】
  • 目录
  • 内容
  • BackgroundService的优点
  • BackgroundService的缺点

目录

内容

public class PerformanceMetricsBackgroundService : BackgroundService
{
    private readonly IProcessorMetricsCollector _processorMetricsCollector;
    private readonly INetworkMetricsCollector _networkMetricsCollector;
    private readonly IMetricsDeliverer _metricsDeliverer;
    private readonly IMemoryMetricsCollector _memoryMetricsCollector;
    private readonly IOptions<MetricsCollectionOptions> _optionsAccessor;
    private readonly ILogger<PerformanceMetricsBackgroundService> _logger;
    public PerformanceMetricsBackgroundService(
        IProcessorMetricsCollector processorMetricsCollector,
        INetworkMetricsCollector networkMetricsCollector,
        IMetricsDeliverer metricsDeliverer,
        IMemoryMetricsCollector memoryMetricsCollector,
        IOptions<MetricsCollectionOptions> optionsAccessor,
        ILogger<PerformanceMetricsBackgroundService> logger
        )
    {
        _processorMetricsCollector = processorMetricsCollector;
        _networkMetricsCollector = networkMetricsCollector;
        _metricsDeliverer = metricsDeliverer;
        _memoryMetricsCollector = memoryMetricsCollector;
        _optionsAccessor = optionsAccessor;
        _logger = logger;
    }
    protected override async Task ExecuteAsync(CancellationToken stoppingToken)
    {
        while (!stoppingToken.IsCancellationRequested)
        {
            try
            {
                // 执行的方法
                await Callback();
            }
            catch (Exception ex)
            {
                _logger.LogError(ex,$"Job {nameof(PerformanceMetricsBackgroundService)} threw an exception!");
            }
            // 间隔的时间
            await Task.Delay(_optionsAccessor.Value.CaptureInterval);
        }
    }
    private async Task Callback()
    {
        // 通过不同指标获取实例
        var performanceMetrics = new PerformanceMetrics()
        {
            Memory = _memoryMetricsCollector.GetUsage(),
            Network = _networkMetricsCollector.GetThroughput(),
            Processor = _processorMetricsCollector.GetUsage()
        };
        await _metricsDeliverer.DeliverAsync(performanceMetrics);
    }
}

.AddSingleton<IHostedService, PerformanceMetricsBackgroundService>()

BackgroundService的优点

BackgroundService的缺点