.net core 3.1 服务承载【Workservice】

• .net core 3.1 服务承载【Workservice】
  • 目录
  • WorkerService优点
  • Demo
    • 创建WorkService项目
    • 修改内容
    • 测试运行
  • 部署到Windows服务运行
    • 添加相关依赖包
    • 添加WindowsService方法
    • 发布项目
    • 创建WorkerService服务
  • 部署作为Linux守护程序运行

目录

WorkerService优点

Demo

创建WorkService项目

修改内容

public static IHostBuilder CreateHostBuilder(string[] args) =>
    Host.CreateDefaultBuilder(args)
        // 获取命令行的参数
        .ConfigureHostConfiguration(builder => builder.AddCommandLine(args))
        .ConfigureAppConfiguration((context, builder) => builder
            .AddJsonFile("appsettings.json", false)
            // 添加不同环境的json
            .AddJsonFile($"appsettings.{context.HostingEnvironment.EnvironmentName}.json", true)
        )
        .ConfigureServices((hostContext, services) =>
        {
            var fakeMetricsCollector = new FakeMetricsCollector();
            services
            .AddSingleton<IProcessorMetricsCollector>(fakeMetricsCollector)
            .AddSingleton<INetworkMetricsCollector>(fakeMetricsCollector)
            .AddSingleton<IMemoryMetricsCollector>(fakeMetricsCollector)
            .AddSingleton<IMetricsDeliverer, FakeMetricsDeliverer>()
            .AddSingleton<IHostedService, Worker>()
            // 添加配置
            .AddOptions()
            .Configure<MetricsCollectionOptions>(hostContext.Configuration.GetSection("MetricsCollection"));
        });

public class Worker : BackgroundService
{
    private readonly ILogger<Worker> _logger;
    private readonly IProcessorMetricsCollector _processorMetricsCollector;
    private readonly INetworkMetricsCollector _networkMetricsCollector;
    private readonly IMetricsDeliverer _metricsDeliverer;
    private readonly IMemoryMetricsCollector _memoryMetricsCollector;
    private readonly IOptions<MetricsCollectionOptions> _optionsAccessor;
    public Worker(
        IProcessorMetricsCollector processorMetricsCollector,
        INetworkMetricsCollector networkMetricsCollector,
        IMetricsDeliverer metricsDeliverer,
        IMemoryMetricsCollector memoryMetricsCollector,
        IOptions<MetricsCollectionOptions> optionsAccessor, 
        ILogger<Worker> logger)
    {
        _logger = logger;
        _processorMetricsCollector = processorMetricsCollector;
        _networkMetricsCollector = networkMetricsCollector;
        _metricsDeliverer = metricsDeliverer;
        _memoryMetricsCollector = memoryMetricsCollector;
        _optionsAccessor = optionsAccessor;
    }
    protected override async Task ExecuteAsync(CancellationToken stoppingToken)
    {
        while (!stoppingToken.IsCancellationRequested)
        {
            try
            {
                // 执行的方法
                await Callback();
            }
            catch (Exception ex)
            {
                _logger.LogError(ex, $"Job {nameof(Worker)} 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);
    }
}

测试运行

部署到Windows服务运行

添加相关依赖包

添加WindowsService方法

.UseWindowsService()

发布项目

dotnet publish  -c Release -o C:\WorkerPub

创建WorkerService服务

sc.exe create MyTestService binPath=C:\WorkerPub\WorkerService.exe

sc.exe query MyTestService

sc.exe start MyTestService

sc.exe stop MyTestService
sc.exe delete MyTestService

部署作为Linux守护程序运行

部署linux守护程序也是很方便的执行一下两个步骤即可：

• 添加Microsoft.Extensions.Hosting.Systemd NuGet包到项目中，并告诉你的新Worker，其生命周期由systemd管理！
• 将UseSystemd()添加到HostBuilder中

.UseSystemd ()