[java] Quartz Scheduler와 소켓 통신 연동하기

16 Nov 2023

java

소개

Quartz Scheduler는 자바 기반의 스케줄링 라이브러리로, 단일 서버 또는 클러스터 환경에서 작업을 스케줄링하는 데 사용됩니다. 여기서는 Quartz Scheduler와 소켓 통신을 연동하는 방법을 알아보겠습니다. 소켓 통신을 통해 외부 시스템으로부터 작업 스케줄링 요청을 받을 수 있습니다.

구현

SchedulerSocketServer 클래스를 작성합니다. 이 클래스는 소켓 서버로 동작하며, 외부 시스템에서 보낸 작업 스케줄링 요청을 받습니다.

import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.net.ServerSocket;
import java.net.Socket;

public class SchedulerSocketServer extends Thread {
    private ServerSocket serverSocket;

    public SchedulerSocketServer(int port) throws IOException {
        serverSocket = new ServerSocket(port);
    }

    @Override
    public void run() {
        while (true) {
            try {
                System.out.println("Waiting for client connections...");
                Socket clientSocket = serverSocket.accept();
                System.out.println("Client connected!");

                BufferedReader in = new BufferedReader(new InputStreamReader(clientSocket.getInputStream()));
                String scheduleRequest = in.readLine();
                System.out.println("Received schedule request: " + scheduleRequest);

                // 여기에서 작업 스케줄링 처리

                clientSocket.close();
            } catch (IOException e) {
                e.printStackTrace();
            }
        }
    }
}

SchedulerSocketServer를 Quartz Scheduler와 연동하기 위해 SchedulerListener 클래스를 작성합니다. Quartz Scheduler의 초기화 시점에서 소켓 서버를 실행시킵니다.

import org.quartz.ListenerManager;
import org.quartz.Scheduler;
import org.quartz.SchedulerException;
import org.quartz.SchedulerFactory;
import org.quartz.impl.StdSchedulerFactory;
import org.quartz.listeners.SchedulerListenerSupport;

public class SocketSchedulerListener extends SchedulerListenerSupport {
    private final int SOCKET_PORT = 9000;

    @Override
    public void schedulerStarting() {
        try {
            SchedulerSocketServer socketServer = new SchedulerSocketServer(SOCKET_PORT);
            socketServer.start();
        } catch (IOException e) {
            e.printStackTrace();
        }
    }
}

Quartz Scheduler를 사용하는 메인 클래스에서 SocketSchedulerListener를 등록하고 스케줄러를 초기화합니다.

import org.quartz.*;
import org.quartz.impl.StdSchedulerFactory;

public class MainScheduler {
    public static void main(String[] args) {
        try {
            // 스케줄러 초기화
            SchedulerFactory schedulerFactory = new StdSchedulerFactory();
            Scheduler scheduler = schedulerFactory.getScheduler();

            // 스케줄러 리스너 등록
            scheduler.getListenerManager().addSchedulerListener(new SocketSchedulerListener());

            // 작업 스케줄링

            scheduler.start();
        } catch (SchedulerException e) {
            e.printStackTrace();
        }
    }
}

사용 방법

위의 코드를 참고하여 SchedulerSocketServer, SocketSchedulerListener, MainScheduler 클래스를 작성합니다.
SchedulerSocketServer 클래스에서 받은 작업 스케줄링 요청을 처리하는 부분을 구현합니다.
MainScheduler 클래스에서 Quartz Scheduler를 설정하고 스케줄러 리스너로 SocketSchedulerListener를 등록합니다.
MainScheduler 클래스를 실행하고 외부 시스템으로부터 소켓을 통해 작업 스케줄링 요청을 보내면, SchedulerSocketServer에서 요청을 받고 처리합니다.

결론

이번 포스트에서는 Quartz Scheduler와 소켓 통신을 연동하는 방법에 대해 알아보았습니다. 이를 통해 외부 시스템에서 작업 스케줄링 요청을 받아 Quartz Scheduler를 사용하여 작업을 스케줄링할 수 있습니다. 자세한 내용은 Quartz Scheduler와 소켓 통신의 문서를 참고하시기 바랍니다.

참고 자료: