执行器示例项目规范整理

This commit is contained in:
xueli.xue 2020-10-16 18:16:44 +08:00
parent 06ec530be3
commit 178253de5a
4 changed files with 33 additions and 21 deletions

View File

@ -2046,8 +2046,9 @@ data: post-data
- 8、调度线程连接池优化修复连接有效性校验超时问题
- 9、轮训路由策略优化修复小概率下并发问题
- 10、执行器日志清理优化修复小概率下日志文件为空导致清理异常问题
- 11、[规划中]任务触发参数优化:支持选择 "Cron触发"、"固定间隔时间触发"、"指定时间点触发"、"不选择" 等;
- 12、[规划中]分片任务:全部完成后才会出发后置节点;
- 11、执行器示例项目规范整理
- 12、[规划中]任务触发参数优化:支持选择 "Cron触发"、"固定间隔时间触发"、"指定时间点触发"、"不选择" 等;
- 13、[规划中]分片任务:全部完成后才会出发后置节点;
### 7.32 版本 v2.3.0 Release Notes[规划中]
- 1、[规划中]DAG流程任务

View File

@ -15,10 +15,16 @@
<!-- jfinal -->
<dependency>
<groupId>com.jfinal</groupId>
<artifactId>jfinal</artifactId>
<artifactId>jfinal-undertow</artifactId>
<version>2.2</version>
</dependency>
<dependency>
<groupId>com.jfinal</groupId>
<artifactId>jfinal</artifactId>
<version>4.9.02</version>
</dependency>
<!-- slf4j -->
<dependency>
<groupId>org.slf4j</groupId>

View File

@ -0,0 +1,12 @@
package com.xuxueli.executor.sample.jfinal;
import com.jfinal.server.undertow.UndertowServer;
import com.xuxueli.executor.sample.jfinal.config.JFinalCoreConfig;
public class XxlJobExecutorApplication {
public static void main(String[] args) {
UndertowServer.start(JFinalCoreConfig.class, 8082, true);
}
}

View File

@ -3,6 +3,7 @@ package com.xuxueli.executor.sample.jfinal.config;
import com.jfinal.config.*;
import com.jfinal.kit.Prop;
import com.jfinal.kit.PropKit;
import com.jfinal.template.Engine;
import com.xuxueli.executor.sample.jfinal.controller.IndexController;
import com.xuxueli.executor.sample.jfinal.jobhandler.CommandJobHandler;
import com.xuxueli.executor.sample.jfinal.jobhandler.DemoJobHandler;
@ -58,35 +59,27 @@ public class JFinalCoreConfig extends JFinalConfig {
// ---------------------- jfinal ----------------------
public void configRoute(Routes route) {
route.add("/", IndexController.class);
}
@Override
public void afterJFinalStart() {
public void onStart() {
initXxlJobExecutor();
}
@Override
public void beforeJFinalStop() {
public void onStop() {
destoryXxlJobExecutor();
}
public void configConstant(Constants constants) {
public void configConstant(Constants me) {
me.setDevMode(true);
}
public void configPlugin(Plugins plugins) {
}
public void configInterceptor(Interceptors interceptors) {
}
public void configHandler(Handlers handlers) {
public void configRoute(Routes routes) {
routes.add("/", IndexController.class);
}
public void configEngine(Engine me) {}
public void configPlugin(Plugins me) {}
public void configInterceptor(Interceptors me) {}
public void configHandler(Handlers me) {}
}