<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
