solon.scheduling

<dependency>
    <groupId>org.noear</groupId>
    <artifactId>solon.scheduling</artifactId>
</dependency>

1、描述

调度扩展插件。为代码执行提供“定时调度”和“异步调度”的标准接口定义。目前，“定时调度”有 simple、quartz 两种实现。（v1.11.4 后支持）

2、定时调度方面

定时调度方面，只定义了标准与接口。由适配插件进行实现：

实现插件	适配情况	备注
solon.scheduling.simple	基于本地的简单实现	用于替代旧的 solon.schedule 插件（它没标准化）
solon.scheduling.quartz	基于 quartz 的适配	支持像 jdbc 等分布式调度

认识 @Scheduled 注解属性：

属性	说明	备注	支持情况
name	任务名字	一般为自动生成	simple，quartz
enable	是否启用		simple，quartz

cron	cron 表达式：支持7位	将并行执行	simple，quartz
zone	时区	配合 cron 使用	simple，quartz

fixedRate	固定频率毫秒数	将并行执行	simple，quartz
fixedDelay	固定延时毫秒数	将串行执行	simple
initialDelay	初次执行前延时（毫秒数）	配合 fixedRate 或 fixedDelay 使用	simple

3、异步调度方面

异步调度方面，已提供直接实现。但，这是不建议使用的能力：

即不能参与事务链
出异常时也没有后手
排除待处理的过多，重启一下全没了
虽然可无可有的处理可用，但团队人多就会乱用

具体示例：

@EnableAsync
public class DemoApp{
    public void static void main(String[] args){
        Solon.start(DemoApp.class, args);
    }
}

//定义个服务
@Component
public class AsyncTask {
    //会被异步运行（提交到异步执行器运行）//不要返回值（返回也拿不到）
    @Async
    public void testAsync(String hint){
        System.out.println(Thread.currentThread().getName());
    }
}

//应用
@Controller
public class DemoController{
    @Inject
    AsyncTask asyncTask;
    
    @Mapping("/test")
    public void test(){
        //调用
        asyncTask.testAsync("test");
    }
}

定制运行器工厂（能起到拦截的意思）：

@Component
public class InvocationRunnableFactoryImpl implements InvocationRunnableFactory {
    @Override
    public Runnable create(Invocation inv) {
        //可以改造这里的代码 //Runnable 最终会提交给异步执行器执行
        return new InvocationRunnable(inv);
    }
}

@Component
public class InvocationRunnableFactoryImpl implements InvocationRunnableFactory {
    @Override
    public Runnable create(Invocation inv) {
        RunUtil.async(new InvocationRunnable(inv));
        //如果返回为null，则不再进入内部的异步执行器执行（即，可以自己定制执行策略）
        return null;
    }
}

4、重试调度方面

具体示例：（v2.4.1 后支持）

//定义个服务
@Component
public class RetryTask {
    //有异常，会重试执行
    @Retry(Throwable.class)
    public void test(String hint){
        System.out.println(Thread.currentThread().getName());
    }
}

//如果需要保底
@Component
public class RetryTask implements Recover {
    //有异常，会重试执行
    @Retry(include=Throwable.class, recover=RetryTask.class) //保底可能是任何 Recover 实现
    public void test(String hint){
        System.out.println(Thread.currentThread().getName());
    }
    
    @Override
    public Object recover(Callee callee, Throwable e) throws Throwable{
        //保底处理
        return null;
    }
}

//应用
@Controller
public class DemoController{
    @Inject
    RetryTask retryTask;
    
    @Mapping("/test")
    public void test(){
        //调用
        retryTask.test("test");
    }
}