From 7c814936f88c9ead13416bced83b9c6042728a19 Mon Sep 17 00:00:00 2001 From: DongZeLiang <2746733890@qq.com> Date: Sun, 21 Jul 2024 20:22:24 +0800 Subject: [PATCH] =?UTF-8?q?feat()=EF=BC=9A=E5=A2=9E=E5=8A=A0=E5=88=86?= =?UTF-8?q?=E7=89=87=E6=B5=8B=E8=AF=95=E4=BB=A3=E7=A0=81?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../com/muyu/common/xxl/demo/XxlJobDemoService.java | 10 ++++++++++ 1 file changed, 10 insertions(+) diff --git a/cloud-common/cloud-common-xxl/src/main/java/com/muyu/common/xxl/demo/XxlJobDemoService.java b/cloud-common/cloud-common-xxl/src/main/java/com/muyu/common/xxl/demo/XxlJobDemoService.java index 9b5dabf..51cd2a4 100644 --- a/cloud-common/cloud-common-xxl/src/main/java/com/muyu/common/xxl/demo/XxlJobDemoService.java +++ b/cloud-common/cloud-common-xxl/src/main/java/com/muyu/common/xxl/demo/XxlJobDemoService.java @@ -25,4 +25,14 @@ public class XxlJobDemoService { String param = XxlJobHelper.getJobParam(); 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); + } }