Springboot基于ScheduledFuture如何實(shí)現(xiàn)定時(shí)任務(wù)

這篇文章主要為大家展示了Spring boot基于ScheduledFuture如何實(shí)現(xiàn)定時(shí)任務(wù)，內(nèi)容簡而易懂，希望大家可以學(xué)習(xí)一下，學(xué)習(xí)完之后肯定會(huì)有收獲的，下面讓小編帶大家一起來看看吧。

創(chuàng)新互聯(lián)是網(wǎng)站建設(shè)專家,致力于互聯(lián)網(wǎng)品牌建設(shè)與網(wǎng)絡(luò)營銷，專業(yè)領(lǐng)域包括成都網(wǎng)站制作、網(wǎng)站建設(shè)、電商網(wǎng)站制作開發(fā)、小程序開發(fā)、微信營銷、系統(tǒng)平臺(tái)開發(fā)，與其他網(wǎng)站設(shè)計(jì)及系統(tǒng)開發(fā)公司不同，我們的整合解決方案結(jié)合了恒基網(wǎng)絡(luò)品牌建設(shè)經(jīng)驗(yàn)和互聯(lián)網(wǎng)整合營銷的理念，并將策略和執(zhí)行緊密結(jié)合，且不斷評(píng)估并優(yōu)化我們的方案，為客戶提供全方位的互聯(lián)網(wǎng)品牌整合方案！

一、背景

接上一篇，完成存儲(chǔ)過程的動(dòng)態(tài)生成后，需要構(gòu)建定時(shí)任務(wù)執(zhí)行存儲(chǔ)過程

二、環(huán)境

1.此隨筆內(nèi)容基于spring boot項(xiàng)目

2.數(shù)據(jù)庫為MySQL 5.7.9版本

3.jdk 版本為1.8

三、內(nèi)容

1、定義接口和接口參數(shù)bean；

1）在上一篇博客bean 的基礎(chǔ)上把接口配置參數(shù)bean修改一下，添加一個(gè)配置參數(shù)值和排序字段；在添加一個(gè)監(jiān)測(cè)項(xiàng)的bean，想查看其他的bean信息，請(qǐng)移步

@Entity
@Table(name="monitor_warn_item")
public class MonitorWarnItem {
 @Id
 private String id;
 private String proName;//名稱
 private String rule;
 private String send_content;
 private String recommend_value;// 建議值
 private String standard_value; // 標(biāo)準(zhǔn)值
 private Integer fre_num;
 private String frequency;
 private String status;
 private String warnType;
 private String warn_date_num;// 監(jiān)測(cè)頻次
 
//此處省略get、set…
}
 
@Entity
@Table(name="qt_interface_parameter")
public class QtInterfaceParameter {
 @Id
 private String id;
 @Column(name="inter_id")
 private String interId;
 private String name; //參數(shù)名稱
 private String explain_info; //參數(shù)描述
 private String type;// 輸入輸出類型
 private String paraType; // 參數(shù)類型
 private Integer paraLen;
private Integer paraValue; // 參數(shù)值
private Integer order_num; // 排序字段
 
//此處省略get、set…
}

2、定義ScheduledFuture定時(shí)任務(wù)

1）添加接口

public interface TestService {
  ResultInfo initMonitor(String Id);<br>　　// 省略之前的...
}

2）編寫實(shí)現(xiàn)類

@Service
public class TestServiceImpl implements TestService {
 @Autowired
 private MonitorWarnItemRepository monitorWarnItemRepository
 @Autowired
 private ThreadPoolTaskScheduler threadPoolTaskScheduler;
 @Bean
 public ThreadPoolTaskScheduler threadPoolTaskScheduler() {
  return new ThreadPoolTaskScheduler();
 }
List<Map<String, Object>> mapList = new ArrayList<Map<String, Object>>(); // 新建任務(wù)信息集合
/**
 * 初始化監(jiān)測(cè)項(xiàng)
 *
 * @param Id
 * @return
 */
@Override
@Transactional
public ResultInfo initMonitor(String Id) {
  ResultInfo info = new ResultInfo();
  String msg = "";
  MonitorWarnItem item = monitorWarnItemRepository.findId(Id);
  msg =buildTask(item);
info.setResult(1);
info.setMsg("初始化成功，初始化返回信息：" + msg);
System.out.println(msg);// 日志打印
return info;
 
}
/**
 * 配置任務(wù)信息
 *
 * @param qt
 * @return
 */
private String buildTask(MonitorWarnItem qt) {
  String msg = "";
  if (IsFure(qt.getId())) {
    List<QtInterface> InterList = qtInterfaceRepository.QueryInterFaceByItemId(qt.getId());
    if (InterList.size() > 0) {
 
      Map<String, Object> map_future = new HashMap<>();
 
      ScheduledFuture<&#63;> future;// 監(jiān)測(cè)任務(wù)
      List<QtInterfaceParameter> para = qtInterfaceParameterRepository.QueryInfoByInterId(InterList.get(0).getId()); // 查找參數(shù)信息
      List<String> map = new ArrayList<>(para.size());
      if (para.size() > 0) { // 參數(shù)集合
        for (QtInterfaceParameter pa : para) {
          for (int item = 1; item <= para.size(); item++) {
            if (item == pa.getOrder_num()) { // 根據(jù)字段排序來設(shè)置參數(shù)值的順序
              map.add(pa.getPara_value()); // 設(shè)置值
              item++;
            }
          }
        }
      }
      QuartzTaskService service = new QuartzTaskService(InterList.get(0).getName(), map, jdbcTemplate, qt);
      if (!"".equals(qt.getWarn_date_num()) && qt.getWarn_date_num() != null) {
        future = threadPoolTaskScheduler.schedule(service, new CronTrigger(qt.getWarn_date_num()));// 初始化任務(wù)，第二個(gè)參數(shù)是Cron表達(dá)式
        if (future != null) {
          map_future.put("future", future);
          map_future.put("id", InterList.get(0).getItemId());
          map_future.put("status", "0");
           mapList.add(map_future);
        }
      } else {
        msg += " 監(jiān)測(cè)項(xiàng):" + qt.getProName() + " 監(jiān)測(cè)頻次字段為空，不能執(zhí)行計(jì)劃！";
      }
 
    } else {
      msg += " 監(jiān)測(cè)項(xiàng):" + qt.getProName() + " 沒有查找到接口配置信息";
 
    }
  } else {
    msg += " 監(jiān)測(cè)項(xiàng):" + qt.getProName() + " 已經(jīng)啟動(dòng)，請(qǐng)不要重復(fù)啟動(dòng)。";
  }
  return msg;
}
}

3）構(gòu)建任務(wù)處理線程類

public class QuartzTaskService implements Runnable {
 
  private JdbcTemplate jdbcTemplate;
  private String proName;
  private List<String> maplist;
  private MonitorWarnItem item;
  public QuartzTaskService(String proName,List<String> maplist,JdbcTemplate jdbcTemplate ,MonitorWarnItem item){
    this.proName=proName;
    this.maplist=maplist;
    this.jdbcTemplate=jdbcTemplate;
    this.item=item;
  }
 
  protected void executeInternal() throws JobExecutionException {
    SimpleDateFormat sdf=new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
    StringBuffer bf=new StringBuffer();
    bf.append("call ");
    bf.append(proName);
    bf.append("(");
    int i=1;
    for(String map:maplist){
      if(i==maplist.size()){ // 最后一位
        bf.append("'"+map+"')");
      }else {
        bf.append("'" + map + "',");
      }
     i++;
    }
    jdbcTemplate.batchUpdate(bf.toString());
 
    System.out.println("執(zhí)行了過程：" +proName+"當(dāng)前參數(shù)順序："+bf.toString()+ " 當(dāng)前時(shí)間 "+ sdf.format(new Date()));
  }
  @Override
  public void run() {
    try {
      executeInternal(); // 調(diào)用執(zhí)行
    } catch (JobExecutionException e) {
      e.printStackTrace();
    }
  }

4）此處是用的List保存的任務(wù)信息，在項(xiàng)目重啟之后這個(gè)東西就沒了，也就是說定時(shí)任務(wù)就全丟了，so，這里考慮使用數(shù)據(jù)庫來持久化保存調(diào)度任務(wù)信息，或者在項(xiàng)目啟動(dòng)的時(shí)候?qū)懸粋€(gè)配置來調(diào)用啟動(dòng)定時(shí)任務(wù)

@Component
@Order(1)
public class StartTask implements CommandLineRunner {
  @Autowired
  private TestService testService;
 
  public String setTask(){
    Calendar cale = null;
    cale = Calendar.getInstance();
    int year = cale.get(Calendar.YEAR);
    MonitorWarnItem itemList=testService.QueryByStatus ("1");// 根據(jù)狀態(tài)查詢需要啟動(dòng)的監(jiān)測(cè)項(xiàng)
    if(itemList.size()>0){ // 存在需要啟動(dòng)的檢測(cè)項(xiàng)
For(MonitorWarnItem qt: itemList)
      testService.initMonitor(qt);// 啟動(dòng)任務(wù)列表和消息
    }
    return "";
  }
 
  @Override
  public void run(String... args) throws Exception {
    setTask ();
  }
}

5）最后附上一個(gè)我使用的返回處理類

public class ResultInfo<T> {
  private Integer result;
  private String msg;
  private T rows;
  private int total;
//省略其他處理
}

以上就是關(guān)于Spring boot基于ScheduledFuture如何實(shí)現(xiàn)定時(shí)任務(wù)的內(nèi)容，如果你們有學(xué)習(xí)到知識(shí)或者技能，可以把它分享出去讓更多的人看到。

分享文章：Springboot基于ScheduledFuture如何實(shí)現(xiàn)定時(shí)任務(wù)
文章URL：http://aaarwkj.com/article24/igdcje.html

成都網(wǎng)站建設(shè)公司_創(chuàng)新互聯(lián)，為您提供用戶體驗(yàn)、網(wǎng)站內(nèi)鏈、電子商務(wù)、定制網(wǎng)站、網(wǎng)站營銷、建站公司

聲明：本網(wǎng)站發(fā)布的內(nèi)容（圖片、視頻和文字）以用戶投稿、用戶轉(zhuǎn)載內(nèi)容為主，如果涉及侵權(quán)請(qǐng)盡快告知，我們將會(huì)在第一時(shí)間刪除。文章觀點(diǎn)不代表本網(wǎng)站立場，如需處理請(qǐng)聯(lián)系客服。電話：028-86922220；郵箱：631063699@qq.com。內(nèi)容未經(jīng)允許不得轉(zhuǎn)載，或轉(zhuǎn)載時(shí)需注明來源：創(chuàng)新互聯(lián)

猜你還喜歡下面的內(nèi)容

欧美一级特黄大片做受成人-亚洲成人一区二区电影-激情熟女一区二区三区-日韩专区欧美专区国产专区

Springboot基于ScheduledFuture如何實(shí)現(xiàn)定時(shí)任務(wù)