github
/
jeecg-boot
mirror of https://github.com/jeecgboot/jeecg-boot
1
0
Fork 0
Code Issues Projects Releases Wiki Activity

XXL-JOB（2.4.0 及以上）已被移除，分片参数获取方式变更。

pull/8300/merge
JEECG 2025-07-30 18:23:09 +08:00
parent 9356b04741
commit c44b66128e
1 changed files with 10 additions and 10 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

20
jeecg-boot/jeecg-server-cloud/jeecg-visual/jeecg-cloud-test/jeecg-cloud-test-more/src/main/java/org/jeecg/modules/test/xxljob/DemoJobHandler.java
View File

@ -3,10 +3,9 @@ package org.jeecg.modules.test.xxljob;
import com.xxl.job.core.biz.model.ReturnT; import com.xxl.job.core.biz.model.ReturnT;
import com.xxl.job.core.context.XxlJobHelper;
import com.xxl.job.core.handler.IJobHandler; import com.xxl.job.core.handler.IJobHandler;
import com.xxl.job.core.handler.annotation.XxlJob; import com.xxl.job.core.handler.annotation.XxlJob;
import com.xxl.job.core.log.XxlJobLogger;
import com.xxl.job.core.util.ShardingUtil;
import lombok.extern.slf4j.Slf4j; import lombok.extern.slf4j.Slf4j;
import org.springframework.stereotype.Component; import org.springframework.stereotype.Component;
import java.io.BufferedInputStream; import java.io.BufferedInputStream;
@ -16,7 +15,7 @@ import java.io.InputStreamReader;
import java.net.HttpURLConnection; import java.net.HttpURLConnection;
import java.net.URL; import java.net.URL;
import java.util.Arrays; import java.util.Arrays;
import com.xxl.job.core.context.XxlJobHelper;
/** /**
* xxl-job定时任务测试 * xxl-job定时任务测试
@ -46,13 +45,14 @@ public class DemoJobHandler {
@XxlJob("shardingJobHandler") @XxlJob("shardingJobHandler")
public ReturnT<String> shardingJobHandler(String param) throws Exception { public ReturnT<String> shardingJobHandler(String param) throws Exception {
// 分片参数 // 获取分片序号和总分片数
ShardingUtil.ShardingVO shardingVO = ShardingUtil.getShardingVo(); int shardIndex = XxlJobHelper.getShardIndex();
log.info("分片参数：当前分片序号 = {}, 总分片数 = {}", shardingVO.getIndex(), shardingVO.getTotal()); int shardTotal = XxlJobHelper.getShardTotal();
log.info("分片参数：当前分片序号 = {}, 总分片数 = {}", shardIndex, shardTotal);
// 业务逻辑 // 业务逻辑
for (int i = 0; i < shardingVO.getTotal(); i++) { for (int i = 0; i < shardTotal; i++) {
if (i == shardingVO.getIndex()) { if (i == shardIndex) {
log.info("第 {} 片, 命中分片开始处理", i); log.info("第 {} 片, 命中分片开始处理", i);
} else { } else {
log.info("第 {} 片, 忽略", i); log.info("第 {} 片, 忽略", i);
@ -98,9 +98,9 @@ public class DemoJobHandler {
} }
if (exitValue == 0) { if (exitValue == 0) {
return IJobHandler.SUCCESS; return ReturnT.SUCCESS;
} else { } else {
return new ReturnT<String>(IJobHandler.FAIL.getCode(), "command exit value(" + exitValue + ") is failed"); return new ReturnT<String>(ReturnT.FAIL_CODE, "command exit value(" + exitValue + ") is failed");
} }
} }