腳本之家服務器常用軟件

快捷導航

Spring boot基于ScheduledFuture實現(xiàn)定時任務

更新時間：2020年06月03日 15:19:38 作者：畫筆灬

這篇文章主要介紹了Spring boot基于ScheduledFuture實現(xiàn)定時任務,文中通過示例代碼介紹的非常詳細，對大家的學習或者工作具有一定的參考學習價值,需要的朋友可以參考下

一、背景

　　接上一篇，完成存儲過程的動態(tài)生成后，需要構建定時任務執(zhí)行存儲過程

二、環(huán)境

　　1.此隨筆內容基于spring boot項目

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

　　3.jdk 版本為1.8

三、內容

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

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

@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; // 標準值
 private Integer fre_num;
 private String frequency;
 private String status;
 private String warnType;
 private String warn_date_num;// 監(jiān)測頻次
 
//此處省略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定時任務

1）添加接口

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

2）編寫實現(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>>(); // 新建任務信息集合
/**
 * 初始化監(jiān)測項
 *
 * @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;
 
}
/**
 * 配置任務信息
 *
 * @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<?> future;// 監(jiān)測任務
      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ù)值的順序
              map.add(pa.getPara_value()); // 設置值
              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()));// 初始化任務，第二個參數(shù)是Cron表達式
        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)測項:" + qt.getProName() + " 監(jiān)測頻次字段為空，不能執(zhí)行計劃！";
      }
 
    } else {
      msg += " 監(jiān)測項:" + qt.getProName() + " 沒有查找到接口配置信息";
 
    }
  } else {
    msg += " 監(jiān)測項:" + qt.getProName() + " 已經(jīng)啟動，請不要重復啟動。";
  }
  return msg;
}
}

3）構建任務處理線程類

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+"當前參數(shù)順序："+bf.toString()+ " 當前時間 "+ sdf.format(new Date()));
  }
  @Override
  public void run() {
    try {
      executeInternal(); // 調用執(zhí)行
    } catch (JobExecutionException e) {
      e.printStackTrace();
    }
  }

4）此處是用的List保存的任務信息，在項目重啟之后這個東西就沒了，也就是說定時任務就全丟了，so，這里考慮使用數(shù)據(jù)庫來持久化保存調度任務信息，或者在項目啟動的時候寫一個配置來調用啟動定時任務

@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)查詢需要啟動的監(jiān)測項
    if(itemList.size()>0){ // 存在需要啟動的檢測項
For(MonitorWarnItem qt: itemList)
      testService.initMonitor(qt);// 啟動任務列表和消息
    }
    return "";
  }
 
  @Override
  public void run(String... args) throws Exception {
    setTask ();
  }
}

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

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

以上就是本文的全部內容，希望對大家的學習有所幫助，也希望大家多多支持腳本之家。

您可能感興趣的文章:

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

Spring boot基于ScheduledFuture實現(xiàn)定時任務

相關文章

最新評論

大家感興趣的內容

最近更新的內容

常用在線小工具