后台任务

比较耗时的需求可以这样解决

后台工作（Background job）

1.创建一个后台job

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

可以注入并使用 IBackgroundJobManager将作业添加到队列中

public class MyService
{
    private readonly IBackgroundJobManager _backgroundJobManager;

    public MyService(IBackgroundJobManager backgroundJobManager)
    {
        _backgroundJobManager = backgroundJobManager;
    }

    public void Test()
    {
        _backgroundJobManager.Enqueue<TestJob, int>(42);
    }
}

通过MyService调用在其他Task接口中调用Test() 有时候会出现当前作业执行失败的情况不清楚为什么

    public class MyServiceAppService : ApplicationService, IMyServiceAppService
    {
        private readonly IBackgroundJobManager _backgroundJobManager;

        public MyServiceAppService(IBackgroundJobManager backgroundJobManager)
        {
            this._backgroundJobManager = backgroundJobManager;
        }
        public void SendJob()
        {
            MyService myService = new MyService(_backgroundJobManager);
            myService.Test();
        }
        public async Task SendJobAsync()
        {
            MyService myService = new MyService(_backgroundJobManager);
            myService.Test();
            await Task.FromResult(0);
        }
    }

*********************

后台工作者（Background workers）

它们是在后台运行的应用程序中的简单独立线程。通常，它们会定期运行以执行某些任务

1.创建后台定时运行任务

    public class MakeInactiveUsersPassiveWorker : PeriodicBackgroundWorkerBase, ISingletonDependency
    {
        private readonly IRepository<Customer, Guid> _customerRepository;

        public MakeInactiveUsersPassiveWorker(AbpTimer timer,
            IRepository<Customer, Guid> customerRepository
            )
            : 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 inactiveUsers = _customerRepository.GetAll().IgnoreQueryFilters().Where(t => t.IsSystem != true).ToList();

            foreach (var inactiveUser in inactiveUsers)
            {
                Logger.Info(inactiveUser.Name + " :这个用户不是系统创建的");
            }
            Logger.Info( " :这个用户不是系统创建的");

                CurrentUnitOfWork.SaveChanges();
            //}
        }
    }

2.在模块的预初始化中注册

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

3.注意：这个后台工作者中注入了_customerRepository这个仓储所以在模块的预初始化中解析MakeInactiveUsersPassiveWorker需要在注入仓储之后，后台工作者在application和code的module中注入是无效的因为这两个模块的时候还没有注入仓储可以考虑把这两行代码放在Web.Core的初始化方法中或者其他地方

**************************

通过Hangfire替换ABP默认后台作业管理器

1.安装

Abp.HangFire.AspNetCore      Hangfire.SqlServer

2.更改Startup类以将Hangfire添加到依赖项注入，然后在ConfigureServices方法中配置存储和连接字符串：

services.AddHangfire(config =>
{
    config.UseSqlServerStorage(_appConfiguration.GetConnectionString("Default"));
});

3.然后，我们在Configure方法中添加UseHangfireServer调用：

app.UseHangfireServer();

启动仪表盘

app.UseHangfireDashboard("/hangfire", new DashboardOptions
{
    //Authorization = new[] { new AbpHangfireAuthorizationFilter("MyHangFireDashboardPermissionName") }
});

4.配置我们的Web模块来替换ABP的默认后台作业管理器的Hangfire：

[DependsOn(typeof (AbpHangfireAspNetCoreModule))]
public class MyProjectWebModule : AbpModule
{
    public override void PreInitialize()
    {
        Configuration.BackgroundJobs.UseHangfire();             
    }

    //...
}

5.如果报错

检查上面两个安装的包的版本安装这两个包版本对不上没有自动抛异常需要自己手动检查

所有的后台任务会在/Hangfire展示

后台任务在ABP模块进行初始化的时候会初始化一个后台JOB对象放到workerManager 中 workerManager这个对象里面就是存放后台job对象和所有的后台工作者对象

                var workerManager = IocManager.Resolve<IBackgroundWorkerManager>();
                workerManager.Start();
                workerManager.Add(IocManager.Resolve<IBackgroundJobManager>());
            }

后台任务和后台工作者最后都会包成一个PeriodicBackgroundWorkerBase对象定时的执行周期任务都是通过.net下的Timer对象来实现 ABP包了一层AbpTimer 解决第一次任务未执行完毕第二次任务就启动的问题

ABP在执行当前后台任务的时候会把执行周期设置为无限大等执行完毕在把执行周期置为用户设定的时间（确保执行第二次后台任务，第一次已经执行完毕）

在BackgroundJobManager中的DoWork()方法中就是根据条件获取后台job任务执行包装好的业务代码

后台任务最后会转成一个PeriodicBackgroundWorkerBase对象默认周期5秒钟

后台工作者需要自己在module中注册到workerManager 中每一个后台工作者都是一个单独的线程