Microservices Engine:10 分で始める

@Component
public class SampleXxlJob {
    private static Logger logger = LoggerFactory.getLogger(SampleXxlJob.class);

    /**
     * 1. 結果をすぐに返すサンプルの単純なジョブ。
     */
    @XxlJob("helloworld") // ジョブハンドラー名
    public ReturnT<String> helloworld(String param) throws Exception {
        XxlJobLogger.log("XXL-JOB, Hello World, param=" + param); // ログ出力
        System.out.println("XXL-JOB, Hello World, finished");
        return ReturnT.SUCCESS; // 成功ステータスを返す
    }

    /**
     * 2. 5 回繰り返すサンプルの単純なジョブ。
     */
    @XxlJob("demoJobHandler")
    public ReturnT<String> demoJobHandler(String param) throws Exception {
        XxlJobLogger.log("XXL-JOB, demoJobHandler, param=" + param);
        System.out.println("XXL-JOB, demoJobHandler, start...");
        for (int i = 0; i < 5; i++) {
            System.out.println("beat at:" + i);
            XxlJobLogger.log("beat at:" + i);
            TimeUnit.SECONDS.sleep(2);
        }
        System.out.println("XXL-JOB, demoJobHandler, end...");
        return ReturnT.SUCCESS;
    }

    /**
     * 3. シャーディングブロードキャストジョブ。
     */
    @XxlJob("shardingJobHandler")
    public ReturnT<String> shardingJobHandler(String param) throws Exception {

        // シャードパラメーター
        ShardingUtil.ShardingVO shardingVO = ShardingUtil.getShardingVo();
        XxlJobLogger.log("シャードパラメーター: 現在のシャード ID = {}, シャードの総数 = {}", shardingVO.getIndex(), shardingVO.getTotal());

        // ビジネスロジック
        for (int i = 0; i < shardingVO.getTotal(); i++) {
            if (i == shardingVO.getIndex()) {
                XxlJobLogger.log("シャード {}, 一致するシャードを処理する", i);
            } else {
                XxlJobLogger.log("シャード {}, 無視する", i);
            }
        }

        return ReturnT.SUCCESS;
    }

    /**
     * 4. ライフサイクルジョブ: ジョブが初期化または破棄されるときにカスタムロジックがサポートされます。
     */
    @XxlJob(value = "demoJobHandler2", init = "init", destroy = "destroy")
    public ReturnT<String> demoJobHandler2(String param) throws Exception {
        XxlJobLogger.log("XXL-JOB, Hello World.");
        return ReturnT.SUCCESS;
    }
    public void init(){
        logger.info("init");
    }
    public void destroy(){
        logger.info("destory");
    }

    /**
     * 5. 失敗したジョブと 1/0 例外がスローされます。
     */
    @XxlJob(value = "failedJobHandler")
    public ReturnT<String> failedJobHandler(String param) throws Exception {
        XxlJobLogger.log("XXL-JOB, Hello World.");
        int a = 1/0;
        return ReturnT.SUCCESS;
    }

}