Quartz Job Scheduler - 多租户设置

Question

由于我没有找到任何相关的东西来激发我的灵感，所以我想我会在这里想出这个。

我最近使用Quartz Job Scheduler 进行了很多工作，我已经在一个 RESTful Java Servlet 中实现了它，它应该提供一个基于 Sencha ExtJS 的 UI 来创建工作。我们将 Authenticator 类与 DatabaseManager 结合使用，后者负责对用户和所有其他特定于数据库的内容进行身份验证（使用 Hibernate）。

由于我们想在我们开发的 Java 企业应用程序中使用它，我们需要为每个客户运行这个东西。我们还要求将 JobStoreTX 用于 MySQL 数据库上的持久数据（显然用于集群），因此 volatile RAMJobStore 实现是一个禁忌。我知道官方文档，并且 Quartz 本身似乎不支持多租户实现（请参阅Quartz Clustering）。

我们的设置看起来有点像这样（简化）：
- 1+ 生产 Tomcat（服务于应用程序逻辑）
- 1+ 生产 Apache（服务 ExtJS 前端和静态内容）
- n 个数据库（每个客户一个）

添加一些更棘手的东西：
我们有客户特定的遗留模块（每个客户都有自己的应用程序托管），而更多最新的模块则通过客户相关的访问集中托管。

在我看来，在每个客户数据库上创建与 Quartz 相关的表是不够的，因为我们希望坚持简单、直接的设置（这意味着例如每个客户的表前缀相同等）只是不会使整个场中的 Quartz 部署复杂化。

我已经考虑过将它与 MariaDB MaxScale 结合使用，并使用 filters 根据 RegEx 或类似的东西将 Quartz 路由到每个客户数据库，Quartz 只与 MaxScale 对话代理，但这对于我试图实现的目标来说似乎有点太多的开销，我什至不确定这是否会起作用。

有什么东西可以让我使用 Quartz 进行多租户？您能否建议一种使 Quartz 能够处理此问题的方法，因为我们需要为每个客户运行作业，但是在“一个”Tomcat（实际上是集群和负载平衡的）上运行？或者是否有其他开箱即用支持多租户的产品/框架/库？

非常感谢任何线索、想法或帮助！

Answer 1

您可以使用名为 JobDataMap 的东西，它只是地图，您可以将其用作每个作业的数据容器。您需要做的是：

• 创建新作业时，添加一些租户标识符
• 创建globalJobListener，您可以在其中将该映射中的租户标识符注入到您的tenantContext

这是我的代码：

// quartz configuration with custom job listener
@Configuration
public class MultiTenantQuartzAutoConfiguration {

    @Bean
    public SchedulerFactoryBean schedulerFactory() {
        SchedulerFactoryBean schedulerFactoryBean = new SchedulerFactoryBean();
        schedulerFactoryBean.setJobFactory(jobFactory());
        schedulerFactoryBean.setGlobalJobListeners(new MultiTenantQuartzJobListener());

        return schedulerFactoryBean;
    }

    @Bean
    public SpringBeanJobFactory jobFactory() {
        return new SpringBeanJobFactory();
    }
}

// custom job listener
public class MultiTenantQuartzJobListener implements JobListener {

    private static final String NAME = "tenantContext";

    @Override
    public String getName() {
        return NAME;
    }

    @Override
    public void jobToBeExecuted(JobExecutionContext context) {
        TenantContext.setTenantId(context.getJobDetail().getJobDataMap().getString(TenantContext.TENANT_HEADER));
    }

    @Override
    public void jobExecutionVetoed(JobExecutionContext context) {
        TenantContext.clear();
    }

    @Override
    public void jobWasExecuted(JobExecutionContext context, JobExecutionException jobException) {
        TenantContext.clear();
    }
}

// and here is how to create job with filled JobDataMap
Class c = Class.forName(jobInfo.getClassName());

JobDetail job = newJob(c)
        .withIdentity(jobInfo.getJobName(), jobInfo.getJobGroup())
        .withDescription(jobInfo.getDesc())
        .usingJobData(TenantContext.TENANT_HEADER, TenantContext.getTenantId())
        .build();

CronTrigger trigger = newTrigger()
        .withIdentity(jobInfo.getJobName(), jobInfo.getJobGroup())
        .withSchedule(cronSchedule(jobInfo.getCronExpression()))
        .build();

var ft = scheduler.scheduleJob(job, trigger);

Answer 2

我终于让它写入多个数据库。

我所做的是根据各自的客户参数为每个客户即时生成 Quartz 属性文件，并使程序逻辑读取这个新生成的文件。所以最后，每个客户都有自己的 Quartz 作业存储到自己的数据库中。