feat():增加分片测试代码
parent
d8ce56b28a
commit
7c814936f8
|
@ -25,4 +25,14 @@ public class XxlJobDemoService {
|
||||||
String param = XxlJobHelper.getJobParam();
|
String param = XxlJobHelper.getJobParam();
|
||||||
log.info("调度名称:[{}] - 参数:[{}]", "xxl-job-demo-one-param", param);
|
log.info("调度名称:[{}] - 参数:[{}]", "xxl-job-demo-one-param", param);
|
||||||
}
|
}
|
||||||
|
/**
|
||||||
|
* 分片测试
|
||||||
|
*/
|
||||||
|
@XxlJob("xxl-job-slice-demo")
|
||||||
|
public void xxlJobSliceDemo(){
|
||||||
|
int shardTotal = XxlJobHelper.getShardTotal();
|
||||||
|
int shardIndex = XxlJobHelper.getShardIndex();
|
||||||
|
String param = XxlJobHelper.getJobParam();
|
||||||
|
log.info("调度名称:[{}-[{}/{}(分片位置/分片总数)]] - 参数:[{}]", "xxl-job-slice-demo",shardIndex, shardTotal, param);
|
||||||
|
}
|
||||||
}
|
}
|
||||||
|
|
Loading…
Reference in New Issue