Java Solon 的调度插件

 <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