Khái niệm về Quartz Scheduler

Quartz là một framework lập trình mã nguồn mở dành cho Java, được thiết kế để quản lý các tác vụ định kỳ (Task Scheduling). Nó hỗ trợ triển khai từ các ứng dụng đơn lẻ cho đến các hệ thống phân tán phức tạp. Quartz giúp giải quyết các bài toán về thực thi tác vụ theo thời gian cố định, theo chu kỳ hoặc dựa trên các biểu thức Cron linh hoạt.

So với các giải pháp truyền thống như Timer hay TimerTask của JDK, Quartz vượt trội nhờ:

• Khả năng xử lý đa luồng hiệu quả, tránh việc một tác vụ lỗi làm dừng toàn bộ hệ thống.
• Hỗ trợ cơ chế Persistence (lưu trữ tác vụ vào database) để đảm bảo không mất dữ liệu khi hệ thống khởi động lại.
• Khả năng chạy trong môi trường Cluster (phân tán), đảm bảo một tác vụ chỉ chạy trên một node tại một thời điểm.

Các thành phần cốt lõi trong kiến trúc Quartz

Quartz được xây dựng dựa trên sự phối hợp của bốn thành phần chính:

Mối quan hệ giữa các thành phần: Một JobDetail có thể gắn với nhiều Trigger, nhưng một Trigger chỉ thuộc về một JobDetail duy nhất.

// Ví dụ định nghĩa một Job đơn giản
public class EmailReportTask implements Job {
    @Override
    public void execute(JobExecutionContext context) throws JobExecutionException {
        System.out.println("Đang gửi báo cáo định kỳ: " + LocalDateTime.now());
    }
}

Các loại Trigger phổ biến

Quartz cung cấp hai loại Trigger chính để đáp ứng các nhu cầu khác nhau:

• SimpleTrigger: Sử dụng cho các tác vụ đơn giản như thực hiện một lần duy nhất tại một thời điểm hoặc lặp lại theo khoảng thời gian cố định (ví dụ: cứ 10 phút một lần).
• CronTrigger: Sử dụng biểu thức Cron (giây, phút, giờ, ngày, tháng...) để thiết lập các lịch trình phức tạp như "10 giờ sáng thứ Hai hàng tuần" hoặc "ngày cuối cùng của tháng".

Cơ chế lưu trữ JobStore

Quartz hỗ trợ hai phương thức lưu trữ trạng thái của các tác vụ:

1. RAMJobStore: Lưu trữ toàn bộ dữ liệu vào bộ nhớ RAM. Ưu điểm là tốc độ cực nhanh nhưng nhược điểm là dữ liệu sẽ mất sạch khi ứng dụng tắt hoặc crash.
2. JDBCJobStore: Lưu dữ liệu vào cơ sở dữ liệu quan hệ (MySQL, PostgreSQL, Oracle...). Phương thức này đảm bảo tính bền vững và là điều kiện cần để triển khai Quartz trong môi trường phân tán (Cluster).

Triển khai Quartz trong hệ thống phân tán (Clustering)

Trong một hệ thống gồm nhiều server cùng chạy Quartz, vấn đề lớn nhất là làm sao để một tác vụ không bị thực thi lặp lại trên nhiều máy. Quartz giải quyết vấn đề này thông qua cơ chế Database Locking.

• Tất cả các node trong Cluster cùng kết nối đến một database chung.
• Quartz sử dụng một bảng đặc biệt (thường là QRTZ_LOCKS) để thực hiện row-level locking. Node nào giành được lock trên database sẽ được quyền thực thi Job.
• Khi một node bị chết (down), các node khác sẽ phát hiện thông qua bảng trạng thái và tự động tiếp quản các tác vụ còn dang dở (Failover).

Tích hợp Quartz vào dự án Spring Boot

Spring Boot cung cấp starter hỗ trợ cấu hình Quartz một cách nhanh chóng. Dưới đây là cách cấu hình và quản lý tác vụ động.

1. Cấu hình Maven

<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-quartz</artifactId>
</dependency>

2. Cấu hình thuộc tính (application.yml)

spring:
  quartz:
    job-store-type: jdbc
    jdbc:
      initialize-schema: never
    properties:
      org:
        quartz:
          scheduler:
            instanceId: AUTO
          jobStore:
            isClustered: true
            tablePrefix: QRTZ_
          threadPool:
            threadCount: 20

3. Dịch vụ quản lý tác vụ động

Sử dụng Scheduler bean của Spring để điều khiển các tác vụ ngay trong lúc ứng dụng đang chạy:

@Service
public class TaskControlService {
    @Autowired
    private Scheduler coreScheduler;

    public void createNewTask(String name, String group, String cronExpr) throws SchedulerException {
        JobDetail info = JobBuilder.newJob(EmailReportTask.class)
                .withIdentity(name, group)
                .storeDurably()
                .build();

        CronTrigger cronTrigger = TriggerBuilder.newTrigger()
                .withIdentity(name + "_trigger", group)
                .withSchedule(CronScheduleBuilder.cronSchedule(cronExpr))
                .build();

        coreScheduler.scheduleJob(info, cronTrigger);
    }

    public void stopTask(String name, String group) throws SchedulerException {
        coreScheduler.pauseJob(JobKey.jobKey(name, group));
    }

    public void removeTask(String name, String group) throws SchedulerException {
        coreScheduler.deleteJob(JobKey.jobKey(name, group));
    }
}

Xử lý lỗi và Misfire Instruction

Trong thực tế, một tác vụ có thể không được thực thi đúng giờ do hệ thống bị sập hoặc thread pool bị đầy. Quartz cung cấp các chiến lược Misfire Instruction để xử lý trường hợp này:

• Fire and Proceed: Thực thi ngay lập tức một lần sau khi hệ thống ổn định lại, sau đó quay lại lịch trình cũ.
• Do Nothing: Bỏ qua lần thực thi bị lỡ và đợi đến chu kỳ tiếp theo theo lịch trình.
• Ignore Misfires: Cố gắng thực hiện bù tất cả các lần đã lỡ.

Đối với lỗi nghiệp vụ bên trong code, lập trình viên nên sử dụng khối try-catch và có thể ném ra JobExecutionException kèm cấu hình setRefireImmediately(true) để yêu cầu Quartz thực hiện lại tác vụ đó ngay lập tức.

So sánh Quartz và Spring @Scheduled

Kinh nghiệm tối ưu hóa hiệu suất

• Thread Pool: Điều chỉnh threadCount dựa trên số lượng tác vụ đồng thời. Nếu Job xử lý I/O nặng, nên tăng số luồng; nếu xử lý CPU nặng, nên giới hạn số luồng tương đương số nhân CPU.
• Database Index: Đảm bảo các bảng của Quartz được đánh index đầy đủ, đặc biệt là các cột về thời gian kích hoạt (next_fire_time).
• Tác vụ không đồng bộ: Đối với các tác vụ tốn quá nhiều thời gian, nên thiết kế Job theo hướng đẩy message vào Message Queue (RabbitMQ, Kafka) để xử lý bất đồng bộ, tránh chiếm dụng thread của Quartz quá lâu.