2. 程式人生 > >.NET Core 中的通用主機和後臺服務

.NET Core 中的通用主機和後臺服務

阿新 • • 發佈：2018-12-07

目錄

簡介

我們在做專案的時候, 往往要處理一些後臺的任務. 一般是兩種, 一種是不停的執行，比如訊息佇列的消費者。另一種是定時任務。

在.NET Framework + Windows環境裡, 我們一般會使用 Windows 服務處理這些情形.

但在.Net Core + Linux環境裡, 有沒有類似的解決方案呢? 瞭解的方法有兩種:

  1. Web Host: 建立一個 ASP.Net Core 的 Web 專案(如MVC 或 WebAPI), 然後使用IHostedService或者BackgroundService處理後臺任務. 這種方案是Web專案和後臺任務混雜在一起執行.
  2. Generic Host: 通用主機是 .NET Core 2.1 中的新增功能, 它將HTTP管道從Web Host的API中分離出來, 從而提供更多的主機選擇方案, 比如後臺任務, 非 HTTP 工作負載等. 同時可以方便使用基礎功能如配置、依賴關係注入 [DI] 和日誌記錄等。

Web Host and Host

基本用法

  1. 建立一個控制檯程式並新增Hosting Nuget包。

    Install-Package Microsoft.Extensions.Hosting

Install-Package Microsoft.Extensions.Configuration.EnvironmentVariables
Install-Package Microsoft.Extensions.Configuration.CommandLine
Install-Package Microsoft.Extensions.Configuration.Json

Install-Package Microsoft.Extensions.Logging.Console
Install-Package Microsoft.Extensions.Logging.Debug

  2. 建立一個基於 Timer 的簡單 Hosted Service. 繼承自抽象類 BackgroundService.

    public class TimedHostedService : BackgroundService
{
    private readonly ILogger _logger;
    private Timer _timer;

    public TimedHostedService(ILogger<TimedHostedService> logger)
    {
        this._logger = logger;
    }

    protected override Task ExecuteAsync(CancellationToken stoppingToken)
    {
        _timer = new Timer(DoWork, null, TimeSpan.Zero, TimeSpan.FromSeconds(5));
        return Task.CompletedTask;
    }

    private void DoWork(object state)
    {
        _logger.LogInformation(string.Format("[{0:yyyy-MM-dd hh:mm:ss}] Timed Background Service is working.", DateTime.Now));
    }

    public override Task StopAsync(CancellationToken cancellationToken)
    {
        _logger.LogInformation("Timed Background Service is stopping.");
        _timer?.Change(Timeout.Infinite, 0);
        return Task.CompletedTask;
    }

    public override void Dispose()
    {
        _timer?.Dispose();
        base.Dispose();
    }
}

  3. Main 函式中新增 Host的相關程式碼.

    static async Task Main(string[] args)
{
    var builder = new HostBuilder()
        //Host config
        .ConfigureHostConfiguration(configHost =>
        {
            //配置根目錄
        　　//configHost.SetBasePath(Directory.GetCurrentDirectory()); 
        　　//讀取host的配置json，和appsetting類似
        　　//configHost.AddJsonFile("hostsettings.json", true, true); 
        　　//讀取環境變數，Asp.Net core預設的環境變數是以ASPNETCORE_作為字首的，這裡也採用此字首以保持一致
            configHost.AddEnvironmentVariables(prefix: "ASPNETCORE_");
            //啟動host的時候之可傳入引數
            if (args != null)
            {
                configHost.AddCommandLine(args);
            }
        })
        //App config
        .ConfigureAppConfiguration((hostContext, configApp) =>
        {
            //讀取應用的配置json
            configApp.AddJsonFile("appsettings.json", optional: true);
            //讀取應用特定環境下的配置json
            configApp.AddJsonFile($"appsettings.{hostContext.HostingEnvironment.EnvironmentName}.json", optional: true);
            //讀取環境變數
            configApp.AddEnvironmentVariables();
            //啟動host的時候可傳入引數
            if (args != null)
            {
                configApp.AddCommandLine(args);
            }
        })
        //配置服務及依賴注入註冊
        .ConfigureServices((hostContext, services) =>
        {
            //新增TimedHostedService
            services.AddHostedService<TimedHostedService>();
        })
        //日誌配置
        .ConfigureLogging((hostContext, configLogging) =>
        {
            //輸出控制檯日誌
            configLogging.AddConsole();
            //輸出Debug日誌
            if (hostContext.HostingEnvironment.EnvironmentName == EnvironmentName.Development)
            {
                configLogging.AddDebug();
            }
        });

    //使用控制檯生命週期, Ctrl + C退出
    await builder.RunConsoleAsync();
}

  4. 執行並測試.

進階使用

整合第三方日誌 Nlog

支援.Net Core的第三方日誌庫有很多, 下面以 Nlog 為例, 整合到 Generic host 裡.

  1. 新增 NLog.Extensions.Hosting Nuget包

    Install-Package NLog.Extensions.Hosting

  2. 新增配置檔案

    新建一個檔案nlog.config(建議全部小寫，linux系統中要注意)， 並右鍵點選其屬性，將其“複製到輸出目錄”設定為“始終複製”。檔案內容如下:

    <?xml version="1.0" encoding="utf-8" ?>
<nlog xmlns="http://www.nlog-project.org/schemas/NLog.xsd"
      xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
      autoReload="true"
      internalLogLevel="info"
      internalLogFile="logs\internal-nlog.txt">

  <!-- the targets to write to -->
  <targets>
    <!-- write logs to file -->
    <target xsi:type="File" name="fileTarget" fileName="logs\${shortdate}.log"
            layout="${date}|${level:uppercase=true}|${message} ${exception:format=tostring}|${logger}|${all-event-properties}" />
    <target xsi:type="Console" name="consoleTarget"
            layout="${date}|${level:uppercase=true}|${message} ${exception:format=tostring}|${logger}|${all-event-properties}" />
  </targets>

  <!-- rules to map from logger name to target -->
  <rules>
    <logger name="*" minlevel="Trace" writeTo="fileTarget,consoleTarget" />
  </rules>
</nlog>
      <ItemGroup>
    <None Update="nlog.config">
      <CopyToOutputDirectory>Always</CopyToOutputDirectory>
    </None>
  </ItemGroup>

  3. 修改 Main 方法:

    static async Task Main(string[] args)
{
    var logger = LogManager.GetCurrentClassLogger();
    try
    {
        var builder = new HostBuilder()
        //Host config
        .ConfigureHostConfiguration(configHost =>
        {
        })
        //App config
        .ConfigureAppConfiguration((hostContext, configApp) =>
        {
        })
        //Services
        .ConfigureServices((hostContext, services) =>
        {
        })
        //Log
        //.ConfigureLogging((hostContext, configLogging) =>
        //{
        //    configLogging.AddConsole();
        //    if (hostContext.HostingEnvironment.EnvironmentName == EnvironmentName.Development)
        //    {
        //        configLogging.AddDebug();
        //    }
        //})
        .UseNLog();

        await builder.RunConsoleAsync();
    }
    catch (Exception ex)
    {
        logger.Fatal(ex, "Stopped program because of exception");
        throw;
    }
    finally
    {
        // Ensure to flush and stop internal timers/threads before application-exit (Avoid segmentation fault on Linux)
        LogManager.Shutdown();
    }
}

  4. 執行並測試.

整合 EF Core

EF Core的整合相對比較簡單, 基本上和我們在 MVC / WebAPI 中用法一樣.

  1. 新增 Nuget 包

    // SQL Server
Install-Package Microsoft.EntityFrameworkCore.SqlServer

  2. 新增實體

    public class Product
{
    public int Id { get; set; }
    public string Name { get; set; }
    public int Count { get; set; }
}

public class ProductConfiguration : IEntityTypeConfiguration<Product>
{
    public void Configure(EntityTypeBuilder<Product> builder)
    {
        builder.Property(t => t.Name).IsRequired().HasMaxLength(100);

        builder.HasData(new Product { Id = 1, Name = "Test_Prouct_1", Count = 0 });
    }
}

  3. 新增資料庫上下文

    public class HostDemoContext : DbContext
{
    public HostDemoContext(DbContextOptions<HostDemoContext> options) : base(options)
    { }

    public DbSet<Product> Products { get; set; }

    protected override void OnModelCreating(ModelBuilder modelBuilder)
    {
        base.OnModelCreating(modelBuilder);
        modelBuilder.ApplyConfiguration(new ProductConfiguration());
    }
}

  4. 新增資料庫連線字串到 appsettings.json 並修改 Main 方法

    {
  "sqlserverconnection": "Server=.\\SQLEXPRESS;Database=GenericHostDemo;Trusted_Connection=True;"
}
    //Services
.ConfigureServices((hostContext, services) =>
{
    var connectionString = hostContext.Configuration["sqlserverconnection"];
    services.AddDbContext<HostDemoContext>(o => o.UseSqlServer(connectionString), ServiceLifetime.Singleton);

    services.AddHostedService<TimedHostedService>();
})

  5. 在 Hosted Service 中使用 Context

    private readonly HostDemoContext _context;

public TimedHostedService(HostDemoContext context)
{
    this._context = context;
}

private void DoWork(object state)
{
    int id = 1;
    var product = _context.Products.Find(id);
    product.Count++;
    _context.SaveChanges();

    _logger.LogInformation($"Processed {product.Name} at {DateTime.Now:yyyy-MM-dd hh:mm:ss}, current count is {product.Count}.");

    //_logger.LogInformation(string.Format("[{0:yyyy-MM-dd hh:mm:ss}] Timed Background Service is working.", DateTime.Now));
}

  6. 遷移Migration

    1. 通過 Nuget 新增引用 Install-Package Microsoft.EntityFrameworkCore.Tools

    2. 建立 DesignTimeDbContextFactory 類

      不同於Web專案, 執行Add-Migration遷移命令時候由於拿不到連線字串可能會報錯 Unable to create an object of type 'HostDemoContext'. Add an implementation of 'IDesignTimeDbContextFactory<HostDemoContext>' to the project, or see https://go.microsoft.com/fwlink/?linkid=851728 for additional patterns supported at design time.

      解決方法：建立一個與DbContext同一目錄下的DesignTimeDbContextFactory檔案，然後實現介面中的方法CreateDbContext，並配置ConnectionString:

      public class DesignTimeDbContextFactory : IDesignTimeDbContextFactory<HostDemoContext>
{
    public HostDemoContext CreateDbContext(string[] args)
    {
        var builder = new DbContextOptionsBuilder<HostDemoContext>();
        builder.UseSqlServer("Server=.\\SQLEXPRESS;Database=GenericHostDemo;Trusted_Connection=True;");
        return new HostDemoContext(builder.Options);
    }
}
    3. 生成遷移. 開啟Package Manager Console，執行命令 Add-Migration InitialCreate

    4. 更新遷移到資料庫. 執行命令 Update-Database。

  7. 執行並測試.

消費 MQ 訊息

接下來實現一個後臺任務用於監聽並消費 RabbitMQ 訊息.
這裡使用庫EasyNetQ, 它是一款基於RabbitMQ.Client封裝的API庫，正如其名，使用起來比較Easy，它把原RabbitMQ.Client中的很多操作都進行了再次封裝，讓開發人員減少了很多工作量。詳細請參考 https://github.com/EasyNetQ/EasyNetQ

  1. 新增 EasyNetQ 相關 Nuget 包

    install-package EasyNetQ
install-package EasyNetQ.DI.Microsoft

  2. 建立後臺服務 RabbitMQDemoHostedService

    public class RabbitMQDemoHostedService : BackgroundService
{
    private readonly ILogger _logger;
    private readonly IBus _bus;

    public RabbitMQDemoHostedService(ILogger<RabbitMQDemoHostedService> logger, IBus bus)
    {
        this._logger = logger;
        this._bus = bus;
    }

    protected override Task ExecuteAsync(CancellationToken stoppingToken)
    {
        _bus.Subscribe<DemoMessage>("demo_subscription_1", HandleDemoMessage);
        return Task.CompletedTask;
    }

    private void HandleDemoMessage(DemoMessage demoMessage)
    {
        _logger.LogInformation($"Got Message : {demoMessage.Id} {demoMessage.Text} {demoMessage.CreatedTime}");
    }
}

  3. Program 裡面配置相關服務

    //Services
.ConfigureServices((hostContext, services) =>
{
    //Rabbit MQ
    string rabbitMqConnection = hostContext.Configuration["rabbitmqconnection"];
    services.RegisterEasyNetQ(rabbitMqConnection);

    services.AddHostedService<RabbitMQDemoHostedService>();
})

  4. 啟動 MQ 傳送程式來模擬訊息的傳送並測試.

整合 Quartz

Quartz 是一個開源作業排程框架, quartznet的詳細資訊請參考 http://www.quartz-scheduler.net/ , 整合 Quartz 可以幫助提供比只使用定時器更強大的功能.

  1. 新增 Quartz 相關 Nuget 包

    Install-Package Quartz
Install-Package Quartz.Plugins

  2. 新建 Quartz 配置類 QuartzOption

    // More settings refer to：https://github.com/quartznet/quartznet/blob/master/src/Quartz/Impl/StdSchedulerFactory.cs
public class QuartzOption
{
    public QuartzOption(IConfiguration config)
    {
        if (config == null)
        {
            throw new ArgumentNullException(nameof(config));
        }

        var section = config.GetSection("quartz");
        section.Bind(this);
    }

    public Scheduler Scheduler { get; set; }

    public ThreadPool ThreadPool { get; set; }

    public Plugin Plugin { get; set; }

    public NameValueCollection ToProperties()
    {
        var properties = new NameValueCollection
        {
            ["quartz.scheduler.instanceName"] = Scheduler?.InstanceName,
            ["quartz.threadPool.type"] = ThreadPool?.Type,
            ["quartz.threadPool.threadPriority"] = ThreadPool?.ThreadPriority,
            ["quartz.threadPool.threadCount"] = ThreadPool?.ThreadCount.ToString(),
            ["quartz.plugin.jobInitializer.type"] = Plugin?.JobInitializer?.Type,
            ["quartz.plugin.jobInitializer.fileNames"] = Plugin?.JobInitializer?.FileNames
        };

        return properties;
    }
}

public class Scheduler
{
    public string InstanceName { get; set; }
}

public class ThreadPool
{
    public string Type { get; set; }

    public string ThreadPriority { get; set; }

    public int ThreadCount { get; set; }
}

public class Plugin
{
    public JobInitializer JobInitializer { get; set; }
}

public class JobInitializer
{
    public string Type { get; set; }
    public string FileNames { get; set; }
}

  3. 重寫 JobFactory

    public class JobFactory : IJobFactory
{
    private readonly IServiceProvider _serviceProvider;

    public JobFactory(IServiceProvider serviceProvider)
    {
        _serviceProvider = serviceProvider;
    }

    public IJob NewJob(TriggerFiredBundle bundle, IScheduler scheduler)
    {
        var job = _serviceProvider.GetService(bundle.JobDetail.JobType) as IJob;
        return job;
    }

    public void ReturnJob(IJob job)
    {
        var disposable = job as IDisposable;
        disposable?.Dispose();
    }
}

  4. 編寫 Quartz Hosted Service

    public class QuartzService : BackgroundService
{
    private readonly ILogger _logger;
    private readonly IScheduler _scheduler;

    public QuartzService(ILogger<QuartzService> logger, IScheduler scheduler)
    {
        _logger = logger;
        _scheduler = scheduler;
    }

    protected override async Task ExecuteAsync(CancellationToken stoppingToken)
    {
        _logger.LogInformation("Start quartz scheduler...");
        await _scheduler.Start(stoppingToken);
    }

    public override async Task StopAsync(CancellationToken cancellationToken)
    {
        _logger.LogInformation("Stop quartz scheduler...");
        await _scheduler.Shutdown(cancellationToken);
        await base.StopAsync(cancellationToken);
    }
}

  5. 編寫一個測試 Job

    public class TestJob : IJob
{
    private readonly ILogger _logger;

    public TestJob(ILogger<TestJob> logger)
    {
        _logger = logger;
    }

    public Task Execute(IJobExecutionContext context)
    {
        _logger.LogInformation(string.Format("[{0:yyyy-MM-dd hh:mm:ss}] TestJob is working.", DateTime.Now));
        return Task.CompletedTask;
    }
}

  6. 準備 appsettings.json 檔案

    "quartz": {
    "scheduler": {
      "instanceName": "GenericHostDemo.Quartz"
    },
    "threadPool": {
      "type": "Quartz.Simpl.SimpleThreadPool, Quartz",
      "threadPriority": "Normal",
      "threadCount": 10
    },
    "plugin": {
      "jobInitializer": {
        "type": "Quartz.Plugin.Xml.XMLSchedulingDataProcessorPlugin, Quartz.Plugins",
        "fileNames": "quartz_jobs.xml"
      }
    }
}

  7. 準備 Quartz 的排程檔案 quartz_jobs.xml, 並右鍵點選其屬性，將其“複製到輸出目錄”設定為“始終複製”。

    <?xml version="1.0" encoding="UTF-8"?>

<job-scheduling-data xmlns="http://quartznet.sourceforge.net/JobSchedulingData"
        xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
        version="2.0">

    <processing-directives>
        <overwrite-existing-data>true</overwrite-existing-data>
    </processing-directives>

    <schedule>
        <job>
          <name>TestJob</name>
          <group>TestGroup</group>
          <description>TestJob Description</description>
          <job-type>GenericHostDemo.Jobs.TestJob, GenericHostDemo</job-type>
          <durable>true</durable>
          <recover>false</recover>
        </job>
        <trigger>
          <simple>
            <name>TestJobTrigger</name>
            <group>TestGroup</group>
            <description>TestJobTrigger Description</description>
            <job-name>TestJob</job-name>
            <job-group>TestGroup</job-group>
            <repeat-count>-1</repeat-count>
            <repeat-interval>5000</repeat-interval>
          </simple>
        </trigger>

    </schedule>
</job-scheduling-data>

  8. Program 註冊 Quartz Hosted Service 和 TestJob

    //Quartz
services.AddSingleton<IJobFactory, JobFactory>();
services.AddSingleton(provider =>
{
    var option = new QuartzOption(hostContext.Configuration);
    var sf = new StdSchedulerFactory(option.ToProperties());
    var scheduler = sf.GetScheduler().Result;
    scheduler.JobFactory = provider.GetService<IJobFactory>();
    return scheduler;
});
services.AddHostedService<QuartzService>();

//Jobs
services.AddSingleton<TestJob>();

  9. 執行並檢視結果.

部署

通用主機的部署其實就是讓它在後臺執行。
在Linux下面讓程式在後臺執行方式有很多種，比如通過systemctl, Supervisor等。
也可以把它部署在Docker裡面.

BackgroundService 和 IHostedService

在 .NET Core 2.1 之前, 需要自己實現 IHostedService 介面來建立服務. 在 .NET Core 2.1 中, 考慮到大多數後臺任務在取消令牌管理和其他典型操作方面有相似的需求，微軟提供了一個非常方便的抽象基類BackgroundService. 原始碼如下:

// Copyright (c) .NET Foundation. Licensed under the Apache License, Version 2.0. 
/// <summary>
/// Base class for implementing a long running <see cref="IHostedService"/>.
/// </summary>
public abstract class BackgroundService : IHostedService, IDisposable
{
    private Task _executingTask;
    private readonly CancellationTokenSource _stoppingCts = 
                                                   new CancellationTokenSource();

    protected abstract Task ExecuteAsync(CancellationToken stoppingToken);

    public virtual Task StartAsync(CancellationToken cancellationToken)
    {
        // Store the task we're executing
        _executingTask = ExecuteAsync(_stoppingCts.Token);

        // If the task is completed then return it, 
        // this will bubble cancellation and failure to the caller
        if (_executingTask.IsCompleted)
        {
            return _executingTask;
        }

        // Otherwise it's running
        return Task.CompletedTask;
    }
    
    public virtual async Task StopAsync(CancellationToken cancellationToken)
    {
        // Stop called without start
        if (_executingTask == null)
        {
            return;
        }

        try
        {
            // Signal cancellation to the executing method
            _stoppingCts.Cancel();
        }
        finally
        {
            // Wait until the task completes or the stop token triggers
            await Task.WhenAny(_executingTask, Task.Delay(Timeout.Infinite,
                                                          cancellationToken));
        }

    }

    public virtual void Dispose()
    {
        _stoppingCts.Cancel();
    }
}

原始碼

GitHub

參考

相關推薦

.NET Core 中的通用主機和後臺服務

目錄 簡介 基本用法 進階使用 整合第三方日誌 Nlog 整合 EF Core 消費 MQ 訊息 整合 Quartz 部署 BackgroundService 和 IHostedService 原始碼 參考 簡介 我

NET Core 中的通用主機和後臺服務

NET Core 中的通用主機和後臺服務 https://www.cnblogs.com/royzshare/p/10083453.html .NET Core 中的通用主機和後臺服務 簡介 我們在做專案的時候, 往往要處理一些後臺的任務. 一般是兩種, 一種是不停的執行，比如訊息佇列的消費者。另一種是定

談談在.NET Core中使用Redis和Memcached的序列化問題

rman -m string create 讓其 ride builder cnblogs ron 前言 在使用分布式緩存的時候，都不可避免的要做這樣一步操作，將數據序列化後再存儲到緩存中去。 序列化這一操作，或許是顯式的，或許是隱式的，這個取決於使用的package是否有

NET Core中使用Redis和Memcached

前言 date toa 聯系 timespan 執行 mod init rtu 前言 在使用分布式緩存的時候，都不可避免的要做這樣一步操作，將數據序列化後再存儲到緩存中去。 序列化這一操作，或許是顯式的，或許是隱式的，這個取決於使用的package是否有幫我們做這樣一件事

ASP.NET Core 中的會話和應用狀態

原文地址：https://docs.microsoft.com/zh-cn/aspnet/core/fundamentals/app-state?view=aspnetcore-2.1 作者：Rick Anderson、Steve Smith、Diana LaRose 和 Luke Latham

.net core中使用Bumblebee架設微服務閘道器

Bumblebee是款基於.net core開發開源的http服務閘道器，經過最近版本的完善在功能足以滿足作為微服務閘道器的需要。在微服務閘道器功能中它提供了應用服務負載，故障遷移，安全控制，監控跟蹤和日誌處理等；不僅如此它強大的外掛擴充套件功能，可以針對實業務情況進行不同的相關外掛應用開發滿足實際情況的需要

淺入 .NET Core 中的記憶體和GC知識

[TOC] --- 參考資料： 【1】[https://docs.microsoft.com/zh-cn/dotnet/standard/managed-code](https://docs.microsoft.com/zh-cn/dotnet/standard/managed-code) 【2】:[

Asp.Net Core中服務的生命週期選項區別和用法

　　在做一個小的Demo中，在一個介面上兩次呼叫檢視元件，並且在檢視元件中都呼叫了資料庫查詢，結果發現，一直報錯，將兩個檢視元件的呼叫分離，單獨進行，卻又是正常的，尋找一番，發現是配置依賴注入服務時，對於服務的生命週期沒有配置得當導致，特此做一次實驗來認識三者之間(甚至是四者之間的用法及區別)。 一、服務

.Net Core中的通用主機（一）——系統配置

evel 內部 http pre ole 插入 sys 就是 validate ASP.NET Core 2.0 中的 WebHost（實現 IWebHost 的基類）是用於為進程提供 HTTP 服務器功能的基礎結構項目，例如，如果正在實現 MVC Web 應用或 Web

Net Core中數據庫事務隔離詳解——以Dapper和Mysql為例

事務 ring 增刪改 tostring 測試 stc efault 多個 log Net Core中數據庫事務隔離詳解——以Dapper和Mysql為例 事務隔離級別 準備工作 Read uncommitted 讀未提交 Read committed 讀取提交內

.net core 中後臺獲取前臺 數據（post）的方法

json字符串 序列化 convert pda pub poi ade 反序列化 stream [HttpPost] public async Task<JsonResult> EditPoint() { St

asp.net core中IHttpContextAccessor和HttpContextAccessor的妙用

class sys image 只需要 iap href build .com bubuko 分享一篇文章，關於asp.net core中httpcontext的拓展。 現在，試圖圍繞HttpContext.Current構建你的代碼真的不是一個好主意，但是我想如果你

NET Core中使用MediatR實現命令和中介者模式

tab 添加 www. 執行 重定向 什麽 接下來 ont 修飾 NET Core中使用MediatR實現命令和中介者模式 https://www.cnblogs.com/yilezhu/p/9866068.html 在本文中，我將解釋命令模式，以及如何利用基於命令模式的第

Core中使用Hangfire 在Asp.Net Core中使用DI的方式使用Hangfire構建後臺執行指令碼 解決 ASP.NET Core Hangfire 未授權（401 Unauthorized）

  　　之前使用Quartz.Net，後來發現hangfire對Core的繼承更加的好，而且自帶管理後臺，這就比前者好用太多了。 安裝註冊 安裝 PM> Install-Package Hangfire Startup.cs，在ConfigureServices方法中添加註冊：

EF的Include 在.NET Framework 和.net core 中進行多個表查詢的時候不同的寫法

下午正在開開心心擼程式碼的時候，老闆叫我過去說要問我問題，因為老闆最近莫名對.Net產生興趣，開始自己看書擼後臺，所以經常把我叫辦公室問我一些我也不懂的問題（畢竟我也是渣渣，老闆也算是推動我學習進步的源泉，每次問完我我都要去先自己學一遍，再去教老闆）。 問題如下  在專案中

[譯]ASP.NET Core中使用MediatR實現命令和中介者模式

在本文中，我將解釋命令模式，以及如何利用基於命令模式的第三方庫來實現它們，以及如何在ASP.NET Core中使用它來解決我們的問題並使程式碼簡潔。因此，我們將通過下面的主題來進行相關的講解。 什麼是命令模式? 命令模式的簡單例項以及中介者模式的簡單描述 MVC中的瘦控制器是什麼?我們是如如何實現使控制器

談談.NET Core中基於Generic Host來實現後臺任務

目錄 前言 很多時候，後臺任務對我們來說是一個利器，幫我們在後面處理了成千上萬的事情。 在.NET Framework時代，我們可能比較多的就是一個專案，會有一到多個對應的Windows服務，這些Windows服務就可以當作是我們所說的後臺任務了。 我喜歡將後臺任務分為兩大類，一類是不停的跑，好比MQ的消費

ASP.NET Core中的依賴注入（3）: 服務的註冊與提供

在採用了依賴注入的應用中，我們總是直接利用DI容器直接獲取所需的服務例項，換句話說，DI容器起到了一個服務提供者的角色，它能夠根據我們提供的服務描述資訊提供一個可用的服務物件。ASP.NET Core中的DI容器體現為一個實現了IServiceProvider介面的物件。 ServiceProvider與

ASP.NET Core中的依賴注入（4）: 建構函式的選擇與服務生命週期管理

ServiceProvider最終提供的服務例項都是根據對應的ServiceDescriptor建立的，對於一個具體的ServiceDescriptor物件來說，如果它的ImplementationInstance和ImplementationFactory屬性均為Null，那麼ServiceProvider

Net Core中資料庫事務隔離詳解——以Dapper和Mysql為例

原文: Net Core中資料庫事務隔離詳解——以Dapper和Mysql為例 Net Core中資料庫事務隔離詳解——以Dapper和Mysql為例 事務隔離級別 準備工作 Read uncommitted 讀未提交 Read