如何持久化绑定Camel动态路由与Quartz调度并重启后恢复

Quartz仅将调度触发的元数据（如触发器、任务）持久化到数据库，但Camel的路由定义（从Quartz端点到目标地址的处理逻辑）并未与数据库关联。重启应用后，若移除硬编码的路由添加代码，Camel上下文没有重建对应的路由，导致Quartz触发器触发时找不到匹配的Camel端点，因此无日志输出并出现警告。

核心思路是：将Camel路由的配置参数持久化到数据库，应用启动时从数据库加载配置并自动重建路由，让Quartz触发器能匹配到对应的Camel端点。

1. 持久化路由配置 #

创建数据库实体类和Repository，用于存储路由的核心参数：

@Entity
@Table(name = "camel_route_config")
public class CamelRouteConfig {
    @Id
    @GeneratedValue(strategy = GenerationType.IDENTITY)
    private Long id;
    private int repeatInterval; // 调度间隔（毫秒）
    private String message; // 发送的消息内容
    private String destination; // 目标地址（如log、ActiveMQ）
    private String triggerName; // Quartz触发器名称（唯一标识）

    // 省略getter、setter、全参/无参构造方法
}

public interface CamelRouteConfigRepository extends JpaRepository<CamelRouteConfig, Long> {
    // 根据触发器名称查询配置，避免重复
    CamelRouteConfig findByTriggerName(String triggerName);
}

2. 启动时自动加载并重建路由 #

修改CamelStarter类，在应用启动时从数据库读取所有路由配置，循环创建并添加到Camel上下文：

@Service
public class CamelStarter implements InitializingBean, DisposableBean {
    
    private final QuartzComponent customQuartz;
    private final CamelRouteConfigRepository routeConfigRepository;
    private DefaultCamelContext camelCustomContext;

    public CamelStarter(QuartzComponent customQuartz, CamelRouteConfigRepository routeConfigRepository) {
        this.customQuartz = customQuartz;
        this.routeConfigRepository = routeConfigRepository;
    }
    
    @Override
    public void afterPropertiesSet() throws Exception {
        camelCustomContext = new DefaultCamelContext();
        camelCustomContext.addComponent("customQuartz", customQuartz);
        camelCustomContext.setName("camelCustomContext");
        
        // 从数据库加载所有路由配置，批量创建路由
        List<CamelRouteConfig> routeConfigs = routeConfigRepository.findAll();
        for (CamelRouteConfig config : routeConfigs) {
            camelCustomContext.addRoutes(new CustomRouter(
                    config.getRepeatInterval(),
                    config.getMessage(),
                    config.getDestination(),
                    config.getTriggerName()
            ));
        }
        
        camelCustomContext.start();
    }

    @Override
    public void destroy() throws Exception {
        camelCustomContext.stop();
    }
}

3. 调整Quartz配置避免覆盖现有任务 #

修改CamelCustomConfiguration中的SchedulerFactoryBean配置，关闭任务覆盖，确保数据库中已有的Quartz任务不会被清空：

@Bean
public SchedulerFactoryBean customSchedulerFactory(
        DataSource dataSource, QuartzProperties quartzProperties) {
    Properties properties = new Properties();
    properties.putAll(quartzProperties.getProperties());

    SchedulerFactoryBean factory = new SchedulerFactoryBean();
    // 改为false，保留数据库中已存在的Job和Trigger
    factory.setOverwriteExistingJobs(false);
    factory.setWaitForJobsToCompleteOnShutdown(true);
    factory.setDataSource(dataSource);
    factory.setQuartzProperties(properties);
    factory.setJobFactory(new SpringBeanJobFactory());
    return factory;
}

4. 初始化默认路由（可选） #

如果需要首次启动时自动添加默认路由，可以创建初始化类：

@Component
public class RouteConfigInitializer {
    private final CamelRouteConfigRepository routeConfigRepository;

    public RouteConfigInitializer(CamelRouteConfigRepository routeConfigRepository) {
        this.routeConfigRepository = routeConfigRepository;
    }

    @PostConstruct
    public void initDefaultRoute() {
        // 检查是否已存在该路由，避免重复插入
        if (routeConfigRepository.findByTriggerName("customRouterTrigger1") == null) {
            CamelRouteConfig config = new CamelRouteConfig();
            config.setRepeatInterval(1000);
            config.setMessage("CustomRouter1");
            config.setDestination("log:customLog1");
            config.setTriggerName("customRouterTrigger1");
            routeConfigRepository.save(config);
        }
    }
}

1. 首次启动应用：初始化类会将默认路由配置保存到数据库，Camel创建路由并启动Quartz调度，日志正常输出。
2. 移除硬编码的camelCustomContext.addRoutes(...)代码，重启应用：
   • 应用从数据库加载路由配置，自动重建Camel路由
   • Quartz从数据库读取触发器信息，触发时能匹配到对应的Camel端点，日志正常输出

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