.net core 3.1 服务承载【配置选项】

• .net core 3.1 服务承载【配置选项】
  • 目录
  • 配置选项
    • 承载配置
    • 获取传输协议与目的地址指标
    • 设置采集指标频率
    • 创建配置文件
    • 注册配置文件

目录

配置选项

承载配置

public class Endpoint
{
    public string Host { get; set; }
    public int Port { get; set; }
    public override string ToString() => $"{Host}:{Port}";
}
public class MetricsCollectionOptions
{
    public TimeSpan CaptureInterval { get; set; }
    public TransportType Transport { get; set; }
    public Endpoint DeliverTo { get; set; }
}
public enum TransportType
{
    Tcp,
    Http,
    Udp
}

获取传输协议与目的地址指标

public class FakeMetricsDeliverer : IMetricsDeliverer
{
    private readonly TransportType _transport;
    private readonly Endpoint _deliverTo;
    public FakeMetricsDeliverer(IOptions<MetricsCollectionOptions> optionsAccessor)
    {
        var options = optionsAccessor.Value;
        _transport = options.Transport;
        _deliverTo = options.DeliverTo;
    }
    public Task DeliverAsync(PerformanceMetrics performanceMetrics)
    {
        Console.WriteLine($"[{DateTimeOffset.Now}]Deliver performance counter {performanceMetrics} to {_deliverTo} via {_transport}");
        return Task.CompletedTask;
    }
}

设置采集指标频率

public sealed class PerformanceMetricsCollector : IHostedService
{
    private readonly IProcessorMetricsCollector _processorMetricsCollector;
    private readonly INetworkMetricsCollector _networkMetricsCollector;
    private readonly IMetricsDeliverer _metricsDeliverer;
    private readonly IMemoryMetricsCollector _memoryMetricsCollector;
    private readonly IOptions<MetricsCollectionOptions> _optionsAccessor;
    private IDisposable _scheduler;
    public PerformanceMetricsCollector(
        IProcessorMetricsCollector processorMetricsCollector,
        INetworkMetricsCollector networkMetricsCollector,
        IMetricsDeliverer metricsDeliverer,
        IMemoryMetricsCollector memoryMetricsCollector,
        IOptions<MetricsCollectionOptions> optionsAccessor
        )
    {
        _processorMetricsCollector = processorMetricsCollector;
        _networkMetricsCollector = networkMetricsCollector;
        _metricsDeliverer = metricsDeliverer;
        _memoryMetricsCollector = memoryMetricsCollector;
        _optionsAccessor = optionsAccessor;
    }
    /// <summary>
    /// 启动服务
    /// </summary>
    /// <param name="cancellationToken"></param>
    /// <returns></returns>
    public Task StartAsync(CancellationToken cancellationToken)
    {
        // 需要调用的方法  需要传入的对象  多久后启动  间隔时长执行一次
        _scheduler = new Timer(Callback,null,TimeSpan.FromSeconds(5),_optionsAccessor.Value.CaptureInterval);
        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;
    }
}

创建配置文件

{
  "MetricsCollection": {
    "CaptureInterval": "00:00:10",
    "Transport": "Udp",
    "DeliverTo": {
      "Host": "127.0.0.1",
      "Port": "22"
    }
  }
}

注册配置文件

var fakeMetricsCollector = new FakeMetricsCollector();
new HostBuilder()
    .ConfigureAppConfiguration(builder=>builder.AddJsonFile("appsetting.json"))
    .ConfigureServices((context,svcs) => svcs
        .AddSingleton<IProcessorMetricsCollector>(fakeMetricsCollector)
        .AddSingleton<INetworkMetricsCollector>(fakeMetricsCollector)
        .AddSingleton<IMemoryMetricsCollector>(fakeMetricsCollector)
        .AddSingleton<IMetricsDeliverer, FakeMetricsDeliverer>()
        .AddSingleton<IHostedService, PerformanceMetricsCollector>()
        // 添加配置
        .AddOptions()
        .Configure<MetricsCollectionOptions>(context.Configuration.GetSection("MetricsCollection"))
    )
    .Build()
    .Run();