|
|
@ -18,14 +18,14 @@ public class ShardingJobHandler extends IJobHandler {
|
|
|
|
|
|
|
|
|
|
|
|
// 分片参数
|
|
|
|
// 分片参数
|
|
|
|
ShardingUtil.ShardingVO shardingVO = ShardingUtil.getShardingVo();
|
|
|
|
ShardingUtil.ShardingVO shardingVO = ShardingUtil.getShardingVo();
|
|
|
|
XxlJobLogger.log("分片参数:当前分片序号 = {0}, 总分片数 = {1}", shardingVO.getIndex(), shardingVO.getTotal());
|
|
|
|
XxlJobLogger.log("分片参数:当前分片序号 = {}, 总分片数 = {}", shardingVO.getIndex(), shardingVO.getTotal());
|
|
|
|
|
|
|
|
|
|
|
|
// 业务逻辑
|
|
|
|
// 业务逻辑
|
|
|
|
for (int i = 0; i < shardingVO.getTotal(); i++) {
|
|
|
|
for (int i = 0; i < shardingVO.getTotal(); i++) {
|
|
|
|
if (i == shardingVO.getIndex()) {
|
|
|
|
if (i == shardingVO.getIndex()) {
|
|
|
|
XxlJobLogger.log("第 {0} 片, 命中分片开始处理", i);
|
|
|
|
XxlJobLogger.log("第 {} 片, 命中分片开始处理", i);
|
|
|
|
} else {
|
|
|
|
} else {
|
|
|
|
XxlJobLogger.log("第 {0} 片, 忽略", i);
|
|
|
|
XxlJobLogger.log("第 {} 片, 忽略", i);
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|