首页 > 代码库 > ABP官方文档翻译 7.1 后台Jobs和Workers

ABP官方文档翻译 7.1 后台Jobs和Workers

2024-10-16 23:06:02   218人阅读

后台Jobs和Workers

  • 介绍
  • 后台Jobs
    • 关于Job持久化
    • 创建后台Job
    • 在队列中添加一个新Job
    • 默认的后台Job管理器
      • 后台Job存储
    • 配置
      • 禁用Job执行
    • 异常处理
    • Hangfire集成
  • 后台Workers
    • 创建后台Workers
    • 注册后台Workers
    • 后台Worker生命周期
    • 高级计划安排
  • 让你的应用一直运行

介绍

　　ABP提供了后台jobs和workers，他们用于在应用的后台线程中执行一些任务。

后台Jobs

　　后台Jobs用来排队一些需要在后台队列或持久化的方式执行一些任务。以下几种情况可以使用后台jobs：

  • 执行一些长时运行的任务而不需要用户等待。例如，用户按了一个‘report‘按钮开始一个长时运行的报表job。可以将这个job添加到队列，当执行完成的时候通过邮件发送给用户报表结果。
  • 创建一个重试且持久化的任务来保证一段代码的成功运行。例如：可以在后台job中发送邮件来克服临时错误并保证它最终被发送。这样，当发送邮件时，用户不必等待。

关于Job持久化

　　参见后台Job存储了解更多关于job持久化的信息。

创建后台Job

　　我们可以通过从BackgroundJob<TArgs>类或直接实现IBackgroundJob<TArgs>接口来创建一个后台job类。

　　这是最简单的后台job：

public class TestJob : BackgroundJob<int>, ITransientDependency{    public override void Execute(int number)    {        Logger.Debug(number.ToString());    }}

　　后台job定义了Excute方法，它有一个输入参数。参数类型为泛型类参数。

　　后台job必须注册到依赖注入系统。实现ITransientDependency是最简单的方式。

　　让我们定义一个比较实际的后台队列任务，发送邮件：

public class SimpleSendEmailJob : BackgroundJob<SimpleSendEmailJobArgs>, ITransientDependency{    private readonly IRepository<User, long> _userRepository;    private readonly IEmailSender _emailSender;    public SimpleSendEmailJob(IRepository<User, long> userRepository, IEmailSender emailSender)    {        _userRepository = userRepository;        _emailSender = emailSender;    }    public override void Execute(SimpleSendEmailJobArgs args)    {        var senderUser = _userRepository.Get(args.SenderUserId);        var targetUser = _userRepository.Get(args.TargetUserId);        _emailSender.Send(senderUser.EmailAddress, targetUser.EmailAddress, args.Subject, args.Body);    }}

　　我们注入了user仓储(获得用户电子邮件)和电子邮件sender(发送邮件的服务)简单的发送邮件。SimpleSendEmailJobArgs为job的参数，定义如下：

[Serializable]public class SimpleSendEmailJobArgs{    public long SenderUserId { get; set; }    public long TargetUserId { get; set; }    public string Subject { get; set; }    public string Body { get; set; }}

　　job参数应该是可以序列化的，因为它被序列化并存储在数据库中。ABP默认后台job管理器使用JSON序列化（它不需要[Serilizable]特性），但是最好定义[Serializable]特性，因为我们可能在将来切换到其他job管理器，它可能使用.NET的内置二进制序列化。

　　保持参数简单(如DTOs)，不要包含实体或其他非序列化的对象。如在SimpleSendEmailJob示例中所示，我们可以存储实体的Id并从实体的仓储中获得实体。

在队列中添加一个新Job

　　定义后台job之后，我们可以注入并使用IBackgroundJobManager来添加job到队列。参见TestJob定义示例：

public class MyService{    private readonly IBackgroundJobManager _backgroundJobManager;    public MyService(IBackgroundJobManager backgroundJobManager)    {        _backgroundJobManager = backgroundJobManager;    }    public void Test()    {        _backgroundJobManager.Enqueue<TestJob, int>(42);    }}

　　当入队时，我们使用42作为参数。IBackgroundJobManager将实例化并执行TestJob，参数为42。

　　让我们添加一个上面定义的新的SimpleSendEmailJob：

[AbpAuthorize]public class MyEmailAppService : ApplicationService, IMyEmailAppService{    private readonly IBackgroundJobManager _backgroundJobManager;    public MyEmailAppService(IBackgroundJobManager backgroundJobManager)    {        _backgroundJobManager = backgroundJobManager;    }    public async Task SendEmail(SendEmailInput input)    {            await _backgroundJobManager.EnqueueAsync<SimpleSendEmailJob, SimpleSendEmailJobArgs>(            new SimpleSendEmailJobArgs            {                Subject = input.Subject,                Body = input.Body,                SenderUserId = AbpSession.GetUserId(),                TargetUserId = input.TargetUserId            });    }}

　　Enque(或EnqueueAsync)方法还有其他参数如priority和delay。

默认的后台Job管理器

　　IBackgroundJobManager默认由BackgroundJobManager实现。它可以被其他后台job提供者（参见hangfire集成）取代。BackgroundJobManager的一些参考信息：

  • 它是一个单线程的FIFO的简单job队列。它使用IBackgroundJobStore来持久化jobs（参见下部分）。
  • 在job成功运行(不抛出任何异常但是会记录)或超时前会一直重试。默认的重试时间为2天。
  • 当成功执行后，它从仓储（数据库）中删除job。如果它超时了，就设置为abandoned并保留在数据库中。
  • 每次重试前它会递增时间。第一次尝试等待1分钟，第二次等待2分钟，第三次等待4分钟...
  • 它以固定间隔轮训jobs仓储。按优先级（升序）、重试次数（升序）排列查询jobs。

后台Job存储

　　默认的BackgroundJobManager需要一个数据仓储来保存和获取jobs。如果你没实现IBackgroundJobStore那么它使用InMemoryBackgroundJobStore，它不在持久化的数据库中存储jobs。你可以简单的实现它来在数据库中存储jobs或者可以使用已经实现了它的module-zero。

　　如果你使用了第三方的job管理器（如Hangfire）,就不需要实现IBackgroundJobStore了。

配置

　　你可以在模块的PreInitialize方法中使用Configuration.BackgroundJobs来配置后台job系统。

禁用Job执行

　　你可以禁用应用程序的后台job执行：

public class MyProjectWebModule : AbpModule{    public override void PreInitialize()    {        Configuration.BackgroundJobs.IsJobExecutionEnabled = false;    }    //...}

　　几乎不需要这样做。但是，假如你的应用运行了多个实例并使用同样的数据库（在web farm中）。在这种情况下，每个应用将使用同样的数据库查询job并执行。这会导致同样job的多次执行及其他的问题。为了阻止这种情况，有两种选择：

  • 你可以只为应用程序的一个实例启用job执行。
  • 你可以为应用程序的所有实例禁用job执行，然后创建一个单独的执行后台jobs的应用程序（例如：windows service）。

异常处理

　　因为默认的后台管理器会自动重试失败的jobs，它处理（并记录）所有的异常。如果当异常发生时你想要得到通知，可以创建一个事件处理者来处理AbpHandledExceptionData。后台管理器触发这个事件，它有一个BackgroundJobException异常对象参数，这个参数包装了真正的异常（获取InnerException获取真正的异常）。

Hangfire集成

　　后台管理器设计为可以被其他后台job管理器代替。参见hangfire集成文档，使用Hangfire替换它。

后台Workers

　　后台Workers与后台Jobs不同。他们为在后台运行的简单独立的线程。通常，他们定期执行一些任务。例如：

  • 后台worker可以定期的删除老的日志。
  • 后台worker可以定期的判定不活动的用户并发送邮件来通知用户。

创建后台Workers

　　创建一个后台worker，我们需要实现IBackgroundWorker接口。作为另一个选择，我们可以基于我们的需求继承BackgroundWorkerBase或PeriodicBackgroundWorkerBase。

　　假如我们想使用户失活，如果他30天内没有登录应用的话。参见下面的代码：

public class MakeInactiveUsersPassiveWorker : PeriodicBackgroundWorkerBase, ISingletonDependency{    private readonly IRepository<User, long> _userRepository;    public MakeInactiveUsersPassiveWorker(AbpTimer timer, IRepository<User, long> userRepository)        : base(timer)    {        _userRepository = userRepository;        Timer.Period = 5000; //5 seconds (good for tests, but normally will be more)    }    [UnitOfWork]    protected override void DoWork()    {        using (CurrentUnitOfWork.DisableFilter(AbpDataFilters.MayHaveTenant))        {            var oneMonthAgo = Clock.Now.Subtract(TimeSpan.FromDays(30));            var inactiveUsers = _userRepository.GetAllList(u =>                u.IsActive &&                ((u.LastLoginTime < oneMonthAgo && u.LastLoginTime != null) || (u.CreationTime < oneMonthAgo && u.LastLoginTime == null))                );            foreach (var inactiveUser in inactiveUsers)            {                inactiveUser.IsActive = false;                Logger.Info(inactiveUser + " made passive since he/she did not login in last 30 days.");            }            CurrentUnitOfWork.SaveChanges();        }    }}

　　这是一段直接在ABP moudle-zero中使用的真实代码。

  • 如果你从PeriodicBackgroundWokerBase(如在本例中)继承，需要实现DoWork方法来执行你的定期执行代码。
  • 如果你从BackgroundWorkerBase继承或直接实现IBackgroundWorker接口，你需要重写/实现Start,Stop和WaitToStop方法。Start和Stop方法需要为非阻塞的，WaitToStop方法需要等待worker完成它当前关键的job。

注册后台Workers

　　创建后台worker后，我们需要把它添加到IBackgroundWorkerManger。最常见的地方为模块的PostInitialize方法：

public class MyProjectWebModule : AbpModule{    //...    public override void PostInitialize()    {        var workManager = IocManager.Resolve<IBackgroundWorkerManager>();        workManager.Add(IocManager.Resolve<MakeInactiveUsersPassiveWorker>());    }}

　　我们通常在PostInitialize方法中添加worker，但并不限制。你可以在任何地方注入IBackgroundWorkerManager并添加worker。当应用程序关闭时，IBackgroundWorkerManager将停止并释放所有注册的worker。

后台Worker生命周期

　　后台workder一般实现为单例模式。但是并没有限制。如果你需要同个worker类的多个实例，你可以使它为瞬时的并添加多个实例到IBackgroundWorkerManager。在这种情况下，你的worker将为参数化的（也就是说你有一个单独的LogCleaner类但是两个LogCleaner worker实例他们监视并清理不同的日志文件夹）。

高级计划安排

　　ABP后台worker系统比较简单。除了上面展示的定期执行worker，它没有计划安排系统。如果你需要更多计划安排的特征，我们建议你使用Quartz或其他类库。

让你的应用一直运行

　　后台jobs和workers只有当你应用程序运行时才会工作。如果长时间web应用没有请求执行，ABP应用默认会关闭。所以，如果你在web应用中（这是默认行为）寄宿后台job的执行，你需要保证你的web应用配置为一直执行。否则，后台job只有应用在使用时才能工作。

　　有一些技术可以实现。最简单的方式是使用外部应用定期请求你的web应用。这样，你可以检查文本应用是否已启动并运行。Hangfire文档解释了一些其他的方式。

 

返回主目录

ABP官方文档翻译 7.1 后台Jobs和Workers


联系
我们