如何复用含Quartz.NET的ASP.NET Core Web项目适配多业务应用？

针对你的场景，完全可以通过两种主流方式实现需求，下面是具体的落地方案：

方案一：将Web核心功能封装为可复用类库（通过AddMyWebApplication/UseMyWebApplication调用） #

这种方式适合希望A、B项目直接集成Web核心能力，且接受编译时依赖的场景，实现简单、维护成本低。

改造步骤 #

1. 拆分Web项目为类库
   将Web项目中的Quartz调度器配置、作业管理服务、日志查看控制器、数据库迁移逻辑、GUI页面等核心代码抽离成一个独立的类库项目（如MyQuartzWebHost），原Web项目保留为空壳，仅调用类库的扩展方法。

2. 编写扩展方法
   在类库中封装服务注册和中间件配置的扩展方法：

   public static class MyWebApplicationExtensions
   {
       public static IServiceCollection AddMyWebApplication(this IServiceCollection services, Action<MyWebOptions>? options = null)
       {
           // 注册Quartz核心服务
           services.AddQuartz(q =>
           {
               q.UseMicrosoftDependencyInjectionJobFactory();
               // 通用Quartz配置（如持久化、线程池）
           });
           services.AddQuartzServer(opt => opt.WaitForJobsToComplete = true);
   
           // 注册作业管理、日志、数据库上下文等核心服务
           services.AddScoped<IJobManager, JobManager>();
           services.AddDbContext<JobLogDbContext>(opt => 
               opt.UseSqlServer(options?.ConnectionString));
   
           // 注册GUI控制器与视图
           services.AddControllersWithViews();
   
           // 处理自定义配置（如客户专属参数）
           options?.Invoke(new MyWebOptions());
           return services;
       }
   
       public static IApplicationBuilder UseMyWebApplication(this IApplicationBuilder app)
       {
           // 配置中间件
           app.UseStaticFiles();
           app.UseRouting();
           app.UseAuthorization();
   
           // 映射GUI路由
           app.MapControllerRoute(
               name: "quartz-manager",
               pattern: "quartz/{controller=JobEditor}/{action=Index}/{id?}");
   
           // 自动执行数据库迁移
           using var scope = app.ApplicationServices.CreateScope();
           var dbContext = scope.ServiceProvider.GetRequiredService<JobLogDbContext>();
           dbContext.Database.Migrate();
   
           return app;
       }
   }
   

3. A、B项目集成
   在A、B项目的Program.cs中直接调用扩展方法，同时注册自身的服务和作业：

   // 客户A项目Program.cs
   var builder = WebApplication.CreateBuilder(args);
   
   // 集成Web核心功能
   builder.Services.AddMyWebApplication(opt => 
       opt.ConnectionString = builder.Configuration.GetConnectionString("CustomerA"));
   
   // 注册A项目专属服务与作业
   builder.Services.AddScoped<ICustomerAService, CustomerAService>();
   builder.Services.AddQuartz(q =>
   {
       q.AddJob<CustomerADataSyncJob>(opt => opt.WithIdentity("CustomerA-SyncJob"));
       q.AddTrigger(opt => opt
           .ForJob("CustomerA-SyncJob")
           .WithCronSchedule("0 0/10 * * * ?"));
   });
   
   var app = builder.Build();
   app.UseMyWebApplication();
   app.Run();
   

方案二：插件化架构实现A、B动态接入 #

这种方式适合希望A、B项目与Web项目完全解耦，无需预先引用，支持动态加载/卸载的场景，灵活性更强但架构复杂度稍高。

改造步骤 #

1. 定义插件接口
   创建共享类库，定义插件必须实现的接口，用于统一服务和作业的注册逻辑：

   public interface IQuartzPlugin
   {
       // 注册插件专属服务
       void RegisterServices(IServiceCollection services);
       // 注册插件专属Quartz作业
       Task RegisterJobs(IQuartzScheduler scheduler, CancellationToken cancellationToken);
   }
   

2. A、B项目改造为插件
   将A、B项目改为类库项目，实现IQuartzPlugin接口：

   // 客户A插件实现
   public class CustomerAPlugin : IQuartzPlugin
   {
       public void RegisterServices(IServiceCollection services)
       {
           services.AddScoped<ICustomerAService, CustomerAService>();
       }
   
       public async Task RegisterJobs(IQuartzScheduler scheduler, CancellationToken cancellationToken)
       {
           var job = JobBuilder.Create<CustomerADataSyncJob>()
               .WithIdentity("CustomerA-SyncJob")
               .Build();
           var trigger = TriggerBuilder.Create()
               .ForJob(job)
               .WithCronSchedule("0 0/10 * * * ?")
               .Build();
           await scheduler.ScheduleJob(job, trigger, cancellationToken);
       }
   }
   

3. Web项目实现插件加载
   在Web项目启动时，扫描指定目录（如Plugins）下的插件DLL，动态加载并执行注册逻辑：

   // Web项目Program.cs
   var builder = WebApplication.CreateBuilder(args);
   
   // 注册Web核心服务
   builder.Services.AddQuartz(q => q.UseMicrosoftDependencyInjectionJobFactory());
   builder.Services.AddQuartzServer();
   builder.Services.AddControllersWithViews();
   
   // 加载插件
   var pluginDir = Path.Combine(AppContext.BaseDirectory, "Plugins");
   if (Directory.Exists(pluginDir))
   {
       foreach (var dllPath in Directory.GetFiles(pluginDir, "*.dll"))
       {
           var loadContext = new AssemblyLoadContext(null, isCollectible: true);
           var assembly = loadContext.LoadFromAssemblyPath(dllPath);
           
           foreach (var type in assembly.GetTypes())
           {
               if (typeof(IQuartzPlugin).IsAssignableFrom(type) && !type.IsInterface && !type.IsAbstract)
               {
                   if (Activator.CreateInstance(type) is IQuartzPlugin plugin)
                   {
                       plugin.RegisterServices(builder.Services);
                       builder.Services.AddSingleton(plugin);
                   }
               }
           }
       }
   }
   
   var app = builder.Build();
   
   // 初始化插件作业
   using var scope = app.Services.CreateScope();
   var scheduler = scope.ServiceProvider.GetRequiredService<IQuartzScheduler>();
   var plugins = scope.ServiceProvider.GetServices<IQuartzPlugin>();
   foreach (var plugin in plugins)
   {
       await plugin.RegisterJobs(scheduler, CancellationToken.None);
   }
   
   app.UseMyWebApplication(); // 复用方案一中的中间件配置方法
   app.Run();
   

方案对比 #

内容的提问来源于stack exchange，提问作者AxSc