Java Solon 的调度插件

来源: 投稿
2024-02-21 14:22:00
<dependency>
    <groupId>org.noear</groupId>
    <artifactId>solon.scheduling</artifactId>
</dependency>

1、描述

调度扩展插件。为 Solon 的代码执行 提供“定时调度”、“异步调度”、“重试调度”、“命令行调度”的标准接口定义。目前,“定时调度”有 simple、quartz 两种实现。

2、定时调度方面

定时调度方面,只定义了标准与接口(起到防腐和按需切换的效果)。由适配插件进行实现:

实现插件 适配情况 备注
solon.scheduling.simple 基于本地的简单实现  
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、重试调度方面

重试用调度还是不错的。偶尔有需要:

//定义个服务
@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");
    }
}

5、命令行调度方面

对命令行的一些场景,非常友好

@Command("cmd:test")
public class Cmd1 implements CommandExecutor {
    @Override
    public void execute(String command) {
        System.out.println("exec: " + command);
    }
}

打包后,运行示例:

java -jar demo.jar cmd:test 
展开阅读全文
点击引领话题📣 发布并加入讨论🔥
0 评论
1 收藏
分享
返回顶部
顶部