// cron表達(dá)式
@Scheduled(cron="0 0/30 9-17 * * ?") //按cron規(guī)則執(zhí)行,朝九晚五工作時間內(nèi)每半小時
@Scheduled(cron="0 0 12 ? * WED") //按cron規(guī)則執(zhí)行,表示每個星期三中午12點(diǎn)

// fixedRated類配置
@Scheduled(fixedRate=5000) //上一次開始執(zhí)行時間點(diǎn)后5秒再次執(zhí)行；
@Scheduled(fixedDelay=3000) //上一次執(zhí)行完畢時間點(diǎn)后3秒再次執(zhí)行；
@Scheduled(initialDelay=1000, fixedDelay=2000) //第一次延遲1秒執(zhí)行，然后在上一次執(zhí)行完畢時間點(diǎn)后2秒再次執(zhí)行；

/**
* 根據(jù)配置中心的dataFlag過濾
* 1、默認(rèn)ALL不區(qū)分
* 2、ODD 表示僅分發(fā)奇數(shù)表號
* 3、EVEN 標(biāo)識僅分發(fā)偶數(shù)表號
*
* @param eidList
*/
public void filteByDataFlag(List<String> eidList) {
    String dataFlag = SchedulerConfigDrmUtil.getIndexFilterFlag();
    int strategy = -1;
    if (StringUtil.equalsIgnoreCase("ODD", dataFlag)) {
        strategy = 1;
    } else if (StringUtil.equalsIgnoreCase("EVEN", dataFlag)) {
        strategy = 0;
    }
    if (strategy == -1) {
        // ALL
        return;
    }
    // filter
    Iterator<String> it = eidList.iterator();
    while (it.hasNext()) {
        String str = it.next();
        int index = NumberUtils.toInt(str, -1);
        if (index % 2 != strategy) {
            it.remove();
        }
    }
}

/**
 * 計(jì)算定時任務(wù)的相關(guān)配置
 *
 * 主要計(jì)算：
 *    scheduleSingleLimit 單機(jī)限流值
 *    scheduleLoaderCount loader撈取條數(shù)
 *
 * @param scheduleConfig
 */
public static SchedulerConfig calculateScheduleConfig(SchedulerConfig scheduleConfig) {
    final int qpsLimit = scheduleConfig.getScheduleWholeLimit();
    final int machineCounts = scheduleConfig.getScheduleMachineCounts();
    MtLogger.info(LOGGER,
        "【計(jì)算定時任務(wù)配置】-開始 任務(wù)名稱:{0},機(jī)器數(shù)量:{1},任務(wù)吞吐量:{2}.", scheduleConfig.getScheduleType(),
        machineCounts, qpsLimit);

    //定時任務(wù)的調(diào)度頻率是scheduleRate 秒執(zhí)行一次 所以scheduleRate秒中內(nèi)集群的整體吞吐量=qps限制*scheduleRate
    final int scheduleRate = scheduleConfig.getScheduleRatePerSec();
    long totalLoaderCounts = qpsLimit * TimeUnit.SECONDS.toSeconds(scheduleRate);

    //定時任務(wù)撈取的表數(shù)量為1000 所以到每個表的限制=totalLoaderCounts/1000
    long loaderCountPerTask = totalLoaderCounts / 1000;
    if (loaderCountPerTask < 1) {
        loaderCountPerTask = 1;
    }
    scheduleConfig.setScheduleLoaderCount((int) loaderCountPerTask);

    //整體限流通過單機(jī)限流實(shí)現(xiàn) 整體限流=單機(jī)限流*machineCounts
    final double singleQps = ((double) qpsLimit / machineCounts);
    //創(chuàng)建的限流需要1秒的預(yù)熱
    scheduleConfig.setScheduleSingleLimit(RateLimiter.create(singleQps, 1, TimeUnit.SECONDS));

    MtLogger.info(LOGGER,
        "【計(jì)算定時任務(wù)配置】-結(jié)束 任務(wù)名稱:{0},撈取條數(shù):{1},單機(jī)限流:{2}.", scheduleConfig.getScheduleType(),
        scheduleConfig.getScheduleLoaderCount(),
        scheduleConfig.getScheduleSingleLimit().getRate());

    return scheduleConfig;

}