任务新增的API服务接口返回任务ID,方便调用方实用;
This commit is contained in:
parent
d4c9eb5db1
commit
0142b353b5
|
@ -1334,6 +1334,7 @@ Tips: 历史版本(V1.3.x)目前已经Release至稳定版本, 进入维护阶段
|
||||||
- 8、[迭代中]cron在线生成工具,如 "cronboot/cron.qqe2";
|
- 8、[迭代中]cron在线生成工具,如 "cronboot/cron.qqe2";
|
||||||
- 9、[迭代中]原生提供通用命令行任务Handler(Bean任务,"CommandJobHandler");业务方只需要提供命令行即可,可执行任意命令;
|
- 9、[迭代中]原生提供通用命令行任务Handler(Bean任务,"CommandJobHandler");业务方只需要提供命令行即可,可执行任意命令;
|
||||||
- 10、IP获取逻辑优化,优先遍历网卡来获取可用IP;
|
- 10、IP获取逻辑优化,优先遍历网卡来获取可用IP;
|
||||||
|
- 11、任务新增的API服务接口返回任务ID,方便调用方实用;
|
||||||
|
|
||||||
### TODO LIST
|
### TODO LIST
|
||||||
- 1、任务分片路由:分片采用一致性Hash算法计算出尽量稳定的分片顺序,即使注册机器存在波动也不会引起分批分片顺序大的波动;目前采用IP自然排序,可以满足需求,待定;
|
- 1、任务分片路由:分片采用一致性Hash算法计算出尽量稳定的分片顺序,即使注册机器存在波动也不会引起分批分片顺序大的波动;目前采用IP自然排序,可以满足需求,待定;
|
||||||
|
|
|
@ -36,7 +36,7 @@ public class ExecutorRouteLRU extends ExecutorRouter {
|
||||||
* a、accessOrder:ture=访问顺序排序(get/put时排序);false=插入顺序排期;
|
* a、accessOrder:ture=访问顺序排序(get/put时排序);false=插入顺序排期;
|
||||||
* b、removeEldestEntry:新增元素时将会调用,返回true时会删除最老元素;可封装LinkedHashMap并重写该方法,比如定义最大容量,超出是返回true即可实现固定长度的LRU算法;
|
* b、removeEldestEntry:新增元素时将会调用,返回true时会删除最老元素;可封装LinkedHashMap并重写该方法,比如定义最大容量,超出是返回true即可实现固定长度的LRU算法;
|
||||||
*/
|
*/
|
||||||
lruItem = new LinkedHashMap<>(16, 0.75f, true);
|
lruItem = new LinkedHashMap<String, String>(16, 0.75f, true);
|
||||||
jobLRUMap.putIfAbsent(jobId, lruItem);
|
jobLRUMap.putIfAbsent(jobId, lruItem);
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
|
@ -62,7 +62,7 @@ public class I18nUtil {
|
||||||
* @return
|
* @return
|
||||||
*/
|
*/
|
||||||
public static String getMultString(String... keys) {
|
public static String getMultString(String... keys) {
|
||||||
Map<String, String> map = new HashMap<>();
|
Map<String, String> map = new HashMap<String, String>();
|
||||||
|
|
||||||
Properties prop = loadI18nProp();
|
Properties prop = loadI18nProp();
|
||||||
if (keys!=null && keys.length>0) {
|
if (keys!=null && keys.length>0) {
|
||||||
|
|
|
@ -130,7 +130,7 @@ public class XxlJobServiceImpl implements XxlJobService {
|
||||||
try {
|
try {
|
||||||
XxlJobDynamicScheduler.addJob(qz_name, qz_group, jobInfo.getJobCron());
|
XxlJobDynamicScheduler.addJob(qz_name, qz_group, jobInfo.getJobCron());
|
||||||
//XxlJobDynamicScheduler.pauseJob(qz_name, qz_group);
|
//XxlJobDynamicScheduler.pauseJob(qz_name, qz_group);
|
||||||
return new ReturnT<>(qz_name);
|
return new ReturnT<String>(qz_name);
|
||||||
} catch (SchedulerException e) {
|
} catch (SchedulerException e) {
|
||||||
logger.error(e.getMessage(), e);
|
logger.error(e.getMessage(), e);
|
||||||
try {
|
try {
|
||||||
|
|
Loading…
Reference in New Issue