支持宕机自动恢复触发一次性或周期性任务执行的组件包-easyTask

Posted 2021-12-22 liuche

easyTask

• 一个方便触发一次性或周期性任务执行的工具包，支持海量,高并发,高可用,宕机自动恢复任务
• 开源项目地址：https://github.com/liuche51/easyTask   请多多关注

Usage scenarios

• 需要精确到秒的某一时刻触发任务执行。比如订单交易完成24小时后如果客户未评价，则系统自动给出评价。
• 需要周期性的执行某个任务。比如每天下午6点，提醒员工下班关机。

Features

• 使用简单
• 秒级精度任务执行计划
• 支持海量任务提交执行
• 支持高并发执行任务
• 支持任务持久化，宕机自动恢复任务计划
• 支持自定义线程池、任务持久化保存路径

Architecture

Getting started

• pom添加引用

<dependency>
    <groupId>com.github.liuche51</groupId>
    <artifactId>easyTask</artifactId>
    <version>1.0.1</version>
</dependency>

• 定义好您要执行的任务类 Define the task class you want to perform

public class CusTask1 extends Schedule implements Runnable 
    private static Logger log = LoggerFactory.getLogger(CusTask1.class);

    @Override
    public void run() 
        Map<String, String> param = getParam();
        if (param != null && param.size() > 0)
            log.info("任务1已执行!姓名: 生日: 年龄: 线程ID:", param.get("name"), param.get("birthday"), param.get("age"),param.get("threadid"));

    

• 简单应用示例代码 Simply apply the sample code

public class Main 
    private static Logger log = LoggerFactory.getLogger(Main.class);
    private static AnnularQueue annularQueue=AnnularQueue.getInstance();
    private static Object obj=new Object();
    public static void main(String[] args)
        allcustomSimpleSetTest();
    
    static void allcustomSimpleSetTest()
        try 
            annularQueue.start();
            CusTask1 task1 = new CusTask1();
            task1.setEndTimestamp(ZonedDateTime.now().plusSeconds(10).toInstant().toEpochMilli());
            Map<String,String> param=new HashMap<String,String>()
                
                    put("name","刘彻");
                    put("birthday","1988-1-1");
                    put("age","25");
                    put("threadid",String.valueOf(Thread.currentThread().getId()));
                
            ;
            task1.setParam(param);
            CusTask1 task2 = new CusTask1();
            task2.setPeriod(30);
            task2.setImmediateExecute(true);
            task2.setTaskType(TaskType.PERIOD);
            task2.setUnit(TimeUnit.SECONDS);
            Map<String,String> param2=new HashMap<String,String>()
                
                    put("name","Jack");
                    put("birthday","1986-1-1");
                    put("age","32");
                    put("threadid",String.valueOf(Thread.currentThread().getId()));
                
            ;
            task2.setParam(param2);
            annularQueue.submit(task1);
            annularQueue.submit(task2);
            obj.wait();
         catch (Exception e) 
            e.printStackTrace();
        
    

Notice

• 此构件已在Windows和centos下做了适当测试，目前未在生产环境中使用过
• 为了更好的保证系统故障自动恢复任务，请自定义程序任务持久化文件保存的路径(不同应用文件路径定义不同为好，以免被其他应用覆盖)，并确保读写权限。如果以 jar包运行,文件默认在同级目录；如果以war包在tomcat下运行，文件默认在tomcat的bin目录下。
• 如果您在使用过程中遇到问题，可以在这里提交