一、管理端核心类

  1. @Component
  2. public class XxlJobAdminConfig implements InitializingBean, DisposableBean {
  3. private static XxlJobAdminConfig adminConfig = null;
  4. public static XxlJobAdminConfig getAdminConfig() {
  5. return adminConfig;
  6. }
  7. // ---------------------- XxlJobScheduler ----------------------
  8. private XxlJobScheduler xxlJobScheduler;
  9. @Override
  10. public void afterPropertiesSet() throws Exception {
  11. adminConfig = this;
  12. xxlJobScheduler = new XxlJobScheduler();
  13. xxlJobScheduler.init();
  14. }
  15. @Override
  16. public void destroy() throws Exception {
  17. xxlJobScheduler.destroy();
  18. }
  19. }
  1. public class XxlJobScheduler {
  2. private static final Logger logger = LoggerFactory.getLogger(XxlJobScheduler.class);
  3. public void init() throws Exception {
  4. // init i18n
  5. initI18n();
  6. // 饿汉式,获取JobRegistryMonitorHelper对象,并启动注册线程
  7. JobRegistryMonitorHelper.getInstance().start();
  8. // admin monitor run
  9. JobFailMonitorHelper.getInstance().start();
  10. // admin trigger pool start
  11. JobTriggerPoolHelper.toStart();
  12. // admin log report start
  13. JobLogReportHelper.getInstance().start();
  14. // start-schedule
  15. JobScheduleHelper.getInstance().start();
  16. logger.info(">>>>>>>>> init xxl-job admin success.");
  17. }
  18. public void destroy() throws Exception {
  19. // stop-schedule
  20. JobScheduleHelper.getInstance().toStop();
  21. // admin log report stop
  22. JobLogReportHelper.getInstance().toStop();
  23. // admin trigger pool stop
  24. JobTriggerPoolHelper.toStop();
  25. // admin monitor stop
  26. JobFailMonitorHelper.getInstance().toStop();
  27. // admin registry stop
  28. JobRegistryMonitorHelper.getInstance().toStop();
  29. }
  30. }