二十、进程服务（Daemon）

通过系统进程服务可以方便快捷的创建系统服务，如Windows服务，Linux守护进程等。

关于进程服务

进程服务使你能够创建在它们自己的 操作系统（如Windows/Linux） 会话中可长时间运行的可执行应用程序。

这些服务可以在计算机启动时自动启动，可以暂停和重新启动而且不显示任何用户界面。

这种服务非常适合在服务器上使用，或任何时候，为了不影响在同一台计算机上工作的其他用户，需要长时间运行功能时使用。还可以在不同于登录用户的特定用户帐户或默认计算机帐户的安全上下文中运行服务。

有几种类型

  • Windows 服务

  • Linux 守护进程

如何使用

在 Hoa Framework 中已经集成了非常方便强大的进程服务创建方式，只需要简简单单几行代码，即可创建进程服务。

第一步

在 Hoa.Worker.Projects 项目层中的 Workers 目录中新建 ProjectWorker.cs 类，并继承 BackgroundService父类。如基础模板：

using Microsoft.Extensions.Configuration;
using Microsoft.Extensions.Hosting;
using Microsoft.Extensions.Logging;
using System;
using System.Threading;
using System.Threading.Tasks;

namespace Hoa.Worker.Projects.Workers
{
    public class ProjectWorker : BackgroundService
    {
        // 可以使用依赖注入服务，
        // 如配置文件读取、数据库操作、上下文操作、仓储等等
        private readonly IConfiguration _configuration;
        private readonly ILogger<ProjectWorker> _logger;
        private readonly HoaDbContext _dbContext;
        private readonly IRepository<Test> _testRepository;

        public ProjectWorker(
            IConfiguration configuration
            , ILogger<ProjectWorker> logger
            , HoaDbContext dbContext
            , IRepository<Test> testRepository
            )
        {
            _configuration = configuration;
            _logger = logger;
            _dbContext = dbContext;
            _testRepository = testRepository;
        }

        // 服务启动时配置
        public override Task StartAsync(CancellationToken cancellationToken)
        {
            // 业务代码写在这里

            return base.StartAsync(cancellationToken);
        }

        // 服务正常运行执行功能，也就是我们的核心代码
        protected override async Task ExecuteAsync(CancellationToken stoppingToken)
        {
            while (!stoppingToken.IsCancellationRequested)
            {
                _logger.LogInformation("Worker running at: {time}", DateTimeOffset.Now);

                // 业务代码写在这里！！！！！！！！

                await Task.CompletedTask;
            }
        }

        // 服务停止时配置
        public override Task StopAsync(CancellationToken cancellationToken)
        {
            // 业务代码写在这里

            return base.StopAsync(cancellationToken);
        }
    }
}

第二步

在 Hoa.Worker.Projects 项目层的 WorkerStartup.cs 注册你的工作服务，如：

第三步

以管理员的方式打开 PowerShell，并切换到 Hoa.Worker.Projects 绝对路径下，并执行 create_system_services.ps1 脚本，如：

命令代码如下：

第四步

查看系统服务是否创建，通过 Windows + R 打开 运行，并输入 services.msc，打开系统服务界面：

大功告成！！！😁

脚本说明

Hoa Framework 针对系统进程服务创建了两个初始化脚本，可以非常方便的创建和管理进程服务：

  • create_system_services.ps1：创建并生成系统服务

  • delete_system_services.ps1：删除用户自定义的系统服务

create_system_services.ps1 参数说明

用于创建进程服务，如Window服务，Linux守护进程。

执行命令：

以管理员的方式打开 PowerShell，并切换到 Hoa.Worker.Projects 绝对路径下才能执行😥！

参数配置

  • -Name：设置服务运行名称，必填，字符串类型

  • -Description：设置服务描述，必填，字符串类型

  • -PackagePath：设置生成服务的包发布文件，用于生成环境创建Windows服务，字符串类型，选填！！！！只有生成环境才需要！

delete_system_services.ps1 参数说明

用于删除进程服务

执行命令

以管理员的方式打开 PowerShell，并切换到 Hoa.Worker.Projects 绝对路径下才能执行😥！

参数配置

  • -Name：设置服务运行名称，必填，字符串类型

多个工作进程

在过去我们构建Windows服务的时候，通常是一个服务只有一个功能，在Hoa Framework框架中，创建了新的 Worker Service的概念，也就是一个服务可以有多个服务进程。

在需要在 Workers 目录中创建新的 Worker类即可，并继承 BackgroundService，同时在 WorkerStartup.cs中注册，如发送短信的：SMSWorker

注册工作服务

调试代码

Hoa Framework 采用特殊的方式创建 进程服务，方便大家可以在开发过程中进行调试、打断点等等。只需要将 Hoa.Worker.Projects 设置为启动项即可，即可和常规代码一样调试。

部署到生产环境

执行 create_system_services.ps1完脚本后，将会在 Hoa.Worker.Projects 目录下生成 install 目录，只需要将 install目录和 create_system_services.ps1拷贝到 生产环境中中执行即可，如：

这时只需要指定 -PackagePath 目录即可。

查看生产环境日志

通过 Windows + R 打开 运行，并输入 eventvwr，打开事件查看器，并点击 Windows 日志 - 应用程序，然后在右边 操作中选择 筛选当前日志 即可

部署到Linux服务器

默认情况下，create_system_services 会生成 Windows 服务，如需生成 Linux 守护进程，只需要将 Hoa.Worker.Projects.Program.cs 中的 CreateHostBuilder 方法修改即可：

注意事项

在 Hoa.Worker.Projects中的 Worker里：

  1. 所有的方法都应该采用异步执行，也就是 async/await，IO/数据库操作严禁使用同步操作！！！！😕

  2. 执行的代码中将每一块都应该使用日志记录输入，方便生成环境查看，如 _logger.LogInformation("Worker running at: {time}", DateTimeOffset.Now);

  3. 尽量不要引入第三方包，进程服务应该是简单、单一的功能操作！

关于数据库增删改操作🤷‍♀️

由于 Windows Services 和 Linux 守护进程实现原理和 Hoa.Web.Core有点不太一样，导致数据库操作不能自动 SaveChanges，所以，如果有增删改操作，必须手动调用 SaveChanges/SaveChangesAsync，如：

上一页十九、筛选拦截器（未）下一页二十一、编写测试

最后更新于

这有帮助吗？