欧美bbbwbbbw肥妇,免费乱码人妻系列日韩,一级黄片

springboot定時(shí)任務(wù)SchedulingConfigurer異步多線程實(shí)現(xiàn)方式

 更新時(shí)間：2024年04月15日 09:24:33   作者：wfreefish  
這篇文章主要介紹了springboot定時(shí)任務(wù)SchedulingConfigurer異步多線程實(shí)現(xiàn)方式,具有很好的參考價(jià)值,希望對(duì)大家有所幫助,如有錯(cuò)誤或未考慮完全的地方,望不吝賜教

1、設(shè)計(jì)定時(shí)任務(wù)數(shù)據(jù)庫(mysql)

CREATE TABLE `sys_scheduled`  (
  `id` varchar(32) CHARACTER SET utf8mb3 COLLATE utf8mb3_general_ci NOT NULL COMMENT '主鍵',
  `job_name` varchar(200) CHARACTER SET utf8mb3 COLLATE utf8mb3_general_ci NULL DEFAULT NULL COMMENT '定時(shí)任務(wù)名稱',
  `class_name` varchar(200) CHARACTER SET utf8mb3 COLLATE utf8mb3_general_ci NULL DEFAULT NULL COMMENT '類名',
  `method` varchar(250) CHARACTER SET utf8mb3 COLLATE utf8mb3_general_ci NULL DEFAULT NULL COMMENT '方法名',
  `cron` varchar(200) CHARACTER SET utf8mb3 COLLATE utf8mb3_general_ci NULL DEFAULT NULL COMMENT '定時(shí)任務(wù)表達(dá)式',
  `start_flag` tinyint(1) NULL DEFAULT NULL COMMENT '啟用標(biāo)記 1啟用 0停用',
  `create_date` varchar(32) CHARACTER SET utf8mb3 COLLATE utf8mb3_general_ci NULL DEFAULT NULL COMMENT '創(chuàng)建日期',
  `create_by` varchar(32) CHARACTER SET utf8mb3 COLLATE utf8mb3_general_ci NULL DEFAULT NULL COMMENT '創(chuàng)建人',
  `update_by` varchar(32) CHARACTER SET utf8mb3 COLLATE utf8mb3_general_ci NULL DEFAULT NULL COMMENT '更新人',
  `update_date` varchar(32) CHARACTER SET utf8mb3 COLLATE utf8mb3_general_ci NULL DEFAULT NULL COMMENT '更新日期',
  `del_flag` varchar(32) CHARACTER SET utf8mb3 COLLATE utf8mb3_general_ci NULL DEFAULT NULL COMMENT '刪除標(biāo)記',
  `temp` varchar(2500) CHARACTER SET utf8mb3 COLLATE utf8mb3_general_ci NULL DEFAULT NULL COMMENT '備注',
  PRIMARY KEY (`id`) USING BTREE
) ENGINE = MyISAM AUTO_INCREMENT = 1 CHARACTER SET = utf8mb3 COLLATE = utf8mb3_general_ci COMMENT = '定時(shí)任務(wù)配置表' ROW_FORMAT = Dynamic;

2、編寫批量獲取定時(shí)任務(wù)配置查詢服務(wù)SysScheduledService

package com.jdsoft.springbootmybatisplusgenrator.service.crm.impl;
 
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.jdsoft.springbootmybatisplusgenrator.bean.scheduled.SysScheduled;
import com.jdsoft.springbootmybatisplusgenrator.dao.crm.ScheduledMapper;
import com.jdsoft.springbootmybatisplusgenrator.service.crm.SysScheduledService;
import org.springframework.stereotype.Service;
 
 
import java.util.List;
 
/**
 * @author: wxf
 * Date: 2023/8/2
 * Time: 17:16
 * Description:
 */
@Service
public class SysScheduledServiceImpl extends ServiceImpl<ScheduledMapper,SysScheduled> implements SysScheduledService {
    @Override
    public List<SysScheduled> getAllConfig() {
        return this.getBaseMapper().getAllConfig();
    }
 
    @Override
    public SysScheduled getById(String id) {
        LambdaQueryWrapper<SysScheduled> lw = new LambdaQueryWrapper<>();
        lw.eq(SysScheduled::getId,id);
        return this.getBaseMapper().selectOne(lw);
    }
}

2.1 po  SysScheduled

package com.jdsoft.springbootmybatisplusgenrator.bean.scheduled;
 
import com.baomidou.mybatisplus.annotation.IdType;
import com.baomidou.mybatisplus.annotation.TableId;
import lombok.Data;
import java.io.Serializable;
 
@Data
public class SysScheduled  implements Serializable {
 
    @TableId(value = "id",type = IdType.ID_WORKER_STR)
    private String id;		// 主鍵
    @TableId(value = "job_name")  //表里的字段名稱映射到實(shí)體類
    private String jobName;		// 定時(shí)任務(wù)名稱
    @TableId(value = "class_name")
    private String className;		// 類名
    @TableId(value = "method")
    private String method;		// 方法名
    @TableId(value = "cron")
    private String cron;		// 定時(shí)任務(wù)表達(dá)式
    @TableId(value = "start_flag")
    private Boolean startFlag;		// 啟用標(biāo)記
    @TableId(value = "temp")
    private String temp;//備注
}

2.2 mybatisPlus業(yè)務(wù)mapper ScheduledMapper

package com.jdsoft.springbootmybatisplusgenrator.dao.crm;
 
import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import com.jdsoft.springbootmybatisplusgenrator.bean.scheduled.SysScheduled;
import org.apache.ibatis.annotations.Select;
 
import java.util.List;
 
/**
 * @author: wxf
 * Date: 2023/8/2
 * Time: 17:14
 * Description: 定時(shí)任務(wù)配置 mapper
 */
public interface ScheduledMapper extends BaseMapper<SysScheduled> {
    @Select("SELECT* FROM sys_scheduled u ")
    List<SysScheduled> getAllConfig();
}

3、在啟動(dòng)容器中添加@EnableScheduling注解

4、增加調(diào)度任務(wù)配置類實(shí)現(xiàn)

SchedulingConfigurer, AsyncConfigurer接口

說明：springboot項(xiàng)目啟動(dòng)會(huì)執(zhí)行configureTasks實(shí)現(xiàn)方法代碼

package com.scheduled;
 
import java.lang.reflect.Method;
import java.util.*;
import java.util.concurrent.CopyOnWriteArrayList;
import java.util.concurrent.ScheduledFuture;
 
import cn.hutool.core.collection.CollectionUtil;
import com.alibaba.druid.util.StringUtils;
import com.jdsoft.springbootmybatisplusgenrator.bean.scheduled.SysScheduled;
import com.jdsoft.springbootmybatisplusgenrator.service.crm.SysScheduledService;
import com.wxf.springdemo.redis.RedisUtil;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.scheduling.TaskScheduler;
import org.springframework.scheduling.annotation.AsyncConfigurer;
import org.springframework.scheduling.annotation.SchedulingConfigurer;
import org.springframework.scheduling.concurrent.ThreadPoolTaskScheduler;
import org.springframework.scheduling.config.CronTask;
import org.springframework.scheduling.config.ScheduledTaskRegistrar;
import org.springframework.stereotype.Component;
import org.springframework.util.ReflectionUtils;
 
/**
 * @Package: com.scheduled
 * @ClassName: ScheduleSetting
 * @Author: wxf
 * @Description: 任務(wù)調(diào)度
 * @Date: 2023/8/1 20:11
 * @Version: 1.0
 */
@Component
public class ScheduleSetting implements SchedulingConfigurer, AsyncConfigurer {
 
    @Autowired
    private SysScheduledService sysScheduledService;
 
    private volatile ScheduledTaskRegistrar scheduledTaskRegistrar;
    //調(diào)度器map
    private Map<String, ScheduledFuture<?>> scheduledFutures = new HashMap<String, ScheduledFuture<?>>();
    // 執(zhí)行任務(wù)map
    private Map<String, CronTask> cronTasks = new HashMap<String, CronTask>();
 
 
    @Autowired
    private RedisUtil redisUtil;
 
    private static List<SysScheduled> scheduleList;
 
    @Override
    public void configureTasks(ScheduledTaskRegistrar scheduledTaskRegistrar) {
        //異步執(zhí)行定時(shí)任務(wù)
        TaskScheduler taskScheduler = taskScheduler();
        scheduledTaskRegistrar.setTaskScheduler(taskScheduler);
        this.scheduledTaskRegistrar = scheduledTaskRegistrar;
        scheduleList = sysScheduledService.getAllConfig();
        redisUtil.setSysScheduledList("scheduleList", scheduleList);
        refresh(scheduleList);
    }
 
    /**
     * 刷新任務(wù)列表
     *
     * @param scheduleList 待執(zhí)行的任務(wù)列表
     */
    public void refresh(List<SysScheduled> scheduleList) {
        //取消停用的定時(shí)策略
        Set<String> keyIds = scheduledFutures.keySet();
        CopyOnWriteArrayList<String> copyKeyIds = CollectionUtil.newCopyOnWriteArrayList(keyIds);
 
        for (String scheduledFutureId : copyKeyIds) {
            if (!taskExit(scheduleList, scheduledFutureId)) {
                //cancel 參數(shù)  false 表示如果調(diào)度器當(dāng)前執(zhí)行任務(wù)時(shí) 不進(jìn)行打斷    true表示直接打斷進(jìn)程取消策略
                scheduledFutures.get(scheduledFutureId).cancel(false);
                scheduledFutures.remove(scheduledFutureId);
                cronTasks.remove(scheduledFutureId);
            }
        }
        if (CollectionUtil.isNotEmpty(scheduleList)) {
            for (SysScheduled sysScheduled : scheduleList) {
                //定時(shí)corn表達(dá)式
                String cron = sysScheduled.getCron();
                String keyId = sysScheduled.getId();
                //任務(wù)狀態(tài) 在新增任務(wù)時(shí)進(jìn)行判斷
                Boolean startFlag = sysScheduled.getStartFlag();
                // 如果啟動(dòng)狀態(tài)是false的話 , taskExit已進(jìn)行處理,不需要再進(jìn)行操作，直接跳下一次循環(huán)
                if (!startFlag) {
                    continue;
                }
                if (StringUtils.isEmpty(cron)) {
                    continue;
                }
                //定時(shí)任務(wù)存在的話，并且沒發(fā)生改變的話不進(jìn)行處理
                if (scheduledFutures.containsKey(keyId) &&
                        cronTasks.get(keyId).getExpression().equalsIgnoreCase(cron)) {
                    continue;
                } else if (scheduledFutures.containsKey(keyId)) {
                    //任務(wù)調(diào)度時(shí)間發(fā)生改變，取消當(dāng)前策略的任務(wù)
                    scheduledFutures.get(keyId).cancel(false);
                    scheduledFutures.remove(keyId);
                    cronTasks.remove(keyId);
                }
                //新建定時(shí)任務(wù)
                CronTask task = new CronTask(getRunnable(sysScheduled), cron);
                //將定時(shí)任務(wù)分配到對(duì)應(yīng)的調(diào)度器
                ScheduledFuture<?> scheduledFuture = scheduledTaskRegistrar.getScheduler().
                        schedule(task.getRunnable(), task.getTrigger());
                //保存緩存任務(wù)map
                cronTasks.put(keyId, task);
                //保存緩存調(diào)度器 map
                scheduledFutures.put(keyId, scheduledFuture);
            }
        }
 
 
    }
 
    /**
     * 判斷調(diào)度器緩存map中是否存在查詢到的配置調(diào)度任務(wù)
     *
     * @param scheduleList 數(shù)據(jù)庫查詢的調(diào)度任務(wù)
     * @param taskId       主鍵id
     * @return 判斷結(jié)果
     */
    private boolean taskExit(List<SysScheduled> scheduleList, String taskId) {
        if (CollectionUtil.isEmpty(scheduleList) || StringUtils.isEmpty(taskId)) {
            return false;
        }
        for (SysScheduled sysScheduled : scheduleList) {
            //id存在 且任務(wù)狀態(tài)是開啟狀態(tài) 判斷任務(wù)存在
            if (taskId.equalsIgnoreCase(sysScheduled.getId()) && sysScheduled.getStartFlag()) {
                return true;
            }
        }
        return false;
    }
 
    /**
     * 設(shè)置異步線程池 任務(wù)調(diào)度器
     *
     * @return 返回任務(wù)調(diào)度器對(duì)象
     */
    public ThreadPoolTaskScheduler taskScheduler() {
        ThreadPoolTaskScheduler scheduler = new ThreadPoolTaskScheduler();
        scheduler.initialize();
        //設(shè)置線程池?cái)?shù)量
        scheduler.setPoolSize(8);
        scheduler.setThreadNamePrefix("Mq-Listeners");
        //等待終止時(shí)間
        scheduler.setAwaitTerminationSeconds(60);
        //等待任務(wù)完成關(guān)閉
        scheduler.setWaitForTasksToCompleteOnShutdown(true);
        return scheduler;
    }
 
 
    /**
     * 轉(zhuǎn)換首字母小寫
     *
     * @param str
     * @return
     */
    public static String lowerFirstCapse(String str) {
        char[] chars = str.toCharArray();
        chars[0] += 32;
        return String.valueOf(chars);
    }
 
    /**
     * runnable
     *
     * @param scheduleConfig
     * @return
     */
    private Runnable getRunnable(final SysScheduled scheduleConfig) {
        return new Runnable() {
            @Override
            public void run() {
                Class<?> clazz;
                try {
                    //根據(jù)id查詢對(duì)應(yīng)的 啟動(dòng)狀態(tài)
                    clazz = Class.forName(scheduleConfig.getClassName());
                    String className = lowerFirstCapse(clazz.getSimpleName());
                    Object bean = (Object) ApplicationContextHelper.getBean(className);
                    Method method = ReflectionUtils.findMethod(bean.getClass(), scheduleConfig.getMethod());
                    ReflectionUtils.invokeMethod(method, bean);
                } catch (ClassNotFoundException e) {
                    e.printStackTrace();
                }
            }
        };
    }
}

5、當(dāng)數(shù)據(jù)庫配置發(fā)生改變后直接調(diào)用

ScheduleSetting.refresh()方法進(jìn)行刷新任務(wù)策略，實(shí)現(xiàn)動(dòng)態(tài)啟用、停用任務(wù)

總結(jié)

以上為個(gè)人經(jīng)驗(yàn)，希望能給大家一個(gè)參考，也希望大家多多支持腳本之家。

相關(guān)文章

  • java Swing組件setBounds()簡單用法實(shí)例分析

    java Swing組件setBounds()簡單用法實(shí)例分析

    這篇文章主要介紹了java Swing組件setBounds()簡單用法,結(jié)合實(shí)例形式分析了Swing組件setBounds()方法的功能與簡單使用方法,需要的朋友可以參考下
    2017-11-11
  • 詳解Spring AOP 實(shí)現(xiàn)主從讀寫分離

    詳解Spring AOP 實(shí)現(xiàn)主從讀寫分離

    本篇文章主要介紹了Spring AOP 實(shí)現(xiàn)主從讀寫分離，小編覺得挺不錯(cuò)的，現(xiàn)在分享給大家，也給大家做個(gè)參考。一起跟隨小編過來看看吧
    2017-03-03
  • Java微服務(wù)Filter過濾器集成Sentinel實(shí)現(xiàn)網(wǎng)關(guān)限流過程詳解

    Java微服務(wù)Filter過濾器集成Sentinel實(shí)現(xiàn)網(wǎng)關(guān)限流過程詳解

    這篇文章主要介紹了Java微服務(wù)Filter過濾器集成Sentinel實(shí)現(xiàn)網(wǎng)關(guān)限流過程，首先Sentinel規(guī)則的存儲(chǔ)默認(rèn)是存儲(chǔ)在內(nèi)存的，應(yīng)用重啟之后規(guī)則會(huì)丟失。因此我們通過配置中心Nacos保存規(guī)則，然后通過定時(shí)拉取Nacos數(shù)據(jù)來獲取規(guī)則配置，可以做到動(dòng)態(tài)實(shí)時(shí)的刷新規(guī)則
    2023-02-02
  • SpringMvc響應(yīng)數(shù)據(jù)及結(jié)果視圖實(shí)現(xiàn)代碼

    SpringMvc響應(yīng)數(shù)據(jù)及結(jié)果視圖實(shí)現(xiàn)代碼

    這篇文章主要介紹了SpringMvc響應(yīng)數(shù)據(jù)及結(jié)果視圖實(shí)現(xiàn)代碼,文中通過示例代碼介紹的非常詳細(xì)，對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值,需要的朋友可以參考下
    2020-08-08
  • Java里遍歷Map集合的多種方法總結(jié)

    Java里遍歷Map集合的多種方法總結(jié)

    Java中的Map是一種鍵值對(duì)映射的數(shù)據(jù)結(jié)構(gòu),它提供了一些常用的方法用于獲取、添加、刪除和修改元素,在Java中,有多種方式可以遍歷Map,本文將介紹其中的四種常用方式,并比較它們之間的優(yōu)缺點(diǎn),需要的朋友可以參考下
    2024-07-07
  • 淺析java中print和println的區(qū)別

    淺析java中print和println的區(qū)別

    以下是對(duì)java中print和println的區(qū)別進(jìn)行了詳細(xì)的分析介紹，需要的朋友可以過來參考下
    2013-08-08
  • java 之JNA中的Memory和Pointer的使用方法

    java 之JNA中的Memory和Pointer的使用方法

    這篇文章主要介紹了java 之JNA中的Memory和Pointer的使用方法，文章基于Java的相關(guān)自來哦展開對(duì)Pointer和Memory的使用介紹，需要的小伙伴可以參考一下
    2022-04-04
  • 深入了解SpringAOP中的jdk動(dòng)態(tài)代理與CGlib

    深入了解SpringAOP中的jdk動(dòng)態(tài)代理與CGlib

    這篇文章主要介紹了深入了解SpringAOP中的jdk動(dòng)態(tài)代理與CGlib,一般我們編寫程序的思想是縱向的,也就是一個(gè)方法代碼從該方法第一行開始往下一步一步走,直到走完最后一行代碼,也就是說很多業(yè)務(wù)都需要的比如用戶鑒權(quán),資源釋放等,需要的朋友可以參考下
    2023-12-12
  • Java泛型機(jī)制的程序演示詳解

    Java泛型機(jī)制的程序演示詳解

    這篇文章主要為大家詳細(xì)介紹了Java泛型機(jī)制的程序演示，具有一定的參考價(jià)值，感興趣的小伙伴們可以參考一下
    2018-08-08
  • Java字符串split使用方法代碼實(shí)例

    Java字符串split使用方法代碼實(shí)例

    這篇文章主要介紹了Java字符串split使用方法代碼實(shí)例,文中通過示例代碼介紹的非常詳細(xì)，對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值,需要的朋友可以參考下
    2020-07-07

最新評(píng)論