From 7bbb08b110c9b18b2c700678b4ed132f241e591a Mon Sep 17 00:00:00 2001
From: wodeyangzipingpingwuqi <zhengweilins@foxmail.com>
Date: Wed, 24 Jan 2024 01:27:38 +0000
Subject: [PATCH] =?UTF-8?q?!1=20=E3=80=90feat=202.6.0=E3=80=91=E6=96=B0?=
 =?UTF-8?q?=E5=A2=9E=E5=B9=BF=E6=92=AD=E3=80=81=E5=88=86=E5=8C=BA=E3=80=81?=
 =?UTF-8?q?=E5=B7=A5=E4=BD=9C=E6=B5=81=E8=8A=82=E7=82=B9=E5=AE=9A=E6=97=B6?=
 =?UTF-8?q?=E4=BB=BB=E5=8A=A1=E6=89=A7=E8=A1=8C=E5=99=A8=20*=20feat=202.6.?=
 =?UTF-8?q?0:?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../retry/job/TestBroadcastJobExecutor.java   | 30 +++++++++++++++++++
 .../retry/job/TestPartitionJobExecutor.java   | 27 +++++++++++++++++
 .../job/TestWorkflowAnnoJobExecutor.java      |  9 ++++--
 3 files changed, 63 insertions(+), 3 deletions(-)
 create mode 100644 src/main/java/com/example/easy/retry/job/TestBroadcastJobExecutor.java
 create mode 100644 src/main/java/com/example/easy/retry/job/TestPartitionJobExecutor.java

diff --git a/src/main/java/com/example/easy/retry/job/TestBroadcastJobExecutor.java b/src/main/java/com/example/easy/retry/job/TestBroadcastJobExecutor.java
new file mode 100644
index 0000000..4bb9190
--- /dev/null
+++ b/src/main/java/com/example/easy/retry/job/TestBroadcastJobExecutor.java
@@ -0,0 +1,30 @@
+package com.example.easy.retry.job;
+
+/**
+ * @author zhengweilin
+ * @version 1.0.0
+ * @date 2024/01/22
+ */
+
+import com.aizuda.easy.retry.client.job.core.annotation.JobExecutor;
+import com.aizuda.easy.retry.client.job.core.dto.JobArgs;
+import com.aizuda.easy.retry.client.model.ExecuteResult;
+import com.aizuda.easy.retry.common.core.util.JsonUtil;
+import com.example.easy.retry.po.FailOrderPo;
+import org.springframework.stereotype.Component;
+
+import java.util.Random;
+
+@Component
+@JobExecutor(name = "testBroadcastJobExecutor")
+public class TestBroadcastJobExecutor {
+
+    public ExecuteResult jobExecute(JobArgs jobArgs) {
+        if (new Random().nextInt(9) % 5 == 0) {
+            throw new NullPointerException("广播节点抛异常了" + JsonUtil.toJsonString(jobArgs));
+        }
+        FailOrderPo failOrderPo = new FailOrderPo();
+        failOrderPo.setOrderId("xiaowoniu");
+        return ExecuteResult.success(failOrderPo);
+    }
+}
diff --git a/src/main/java/com/example/easy/retry/job/TestPartitionJobExecutor.java b/src/main/java/com/example/easy/retry/job/TestPartitionJobExecutor.java
new file mode 100644
index 0000000..3b797ec
--- /dev/null
+++ b/src/main/java/com/example/easy/retry/job/TestPartitionJobExecutor.java
@@ -0,0 +1,27 @@
+package com.example.easy.retry.job;
+
+/**
+ * @author zhengweilin
+ * @version 1.0.0
+ * @date 2024/01/22
+ */
+
+import com.aizuda.easy.retry.client.job.core.annotation.JobExecutor;
+import com.aizuda.easy.retry.client.job.core.dto.JobArgs;
+import com.aizuda.easy.retry.client.model.ExecuteResult;
+import com.example.easy.retry.po.FailOrderPo;
+import org.springframework.stereotype.Component;
+
+@Component
+@JobExecutor(name = "testPartitionJobExecutor")
+public class TestPartitionJobExecutor {
+
+    public ExecuteResult jobExecute(JobArgs jobArgs) {
+        if (jobArgs.getArgsStr().equals("1")) {
+            throw new NullPointerException("分区空指针抛异常了");
+        }
+        FailOrderPo failOrderPo = new FailOrderPo();
+        failOrderPo.setOrderId("xiaowoniu");
+        return ExecuteResult.success(failOrderPo);
+    }
+}
diff --git a/src/main/java/com/example/easy/retry/job/TestWorkflowAnnoJobExecutor.java b/src/main/java/com/example/easy/retry/job/TestWorkflowAnnoJobExecutor.java
index 7979f21..b9ed2ca 100644
--- a/src/main/java/com/example/easy/retry/job/TestWorkflowAnnoJobExecutor.java
+++ b/src/main/java/com/example/easy/retry/job/TestWorkflowAnnoJobExecutor.java
@@ -3,6 +3,7 @@ package com.example.easy.retry.job;
 import com.aizuda.easy.retry.client.job.core.annotation.JobExecutor;
 import com.aizuda.easy.retry.client.job.core.dto.JobArgs;
 import com.aizuda.easy.retry.client.model.ExecuteResult;
+import com.aizuda.easy.retry.common.core.util.JsonUtil;
 import com.aizuda.easy.retry.common.log.EasyRetryLog;
 import com.example.easy.retry.po.FailOrderPo;
 import org.springframework.stereotype.Component;
@@ -16,11 +17,13 @@ import org.springframework.stereotype.Component;
 @JobExecutor(name = "testWorkflowAnnoJobExecutor")
 public class TestWorkflowAnnoJobExecutor {
 
-    public ExecuteResult jobExecute(JobArgs jobArgs) {
-        EasyRetryLog.REMOTE.info("任务执行开始. [{}]", jobArgs);
+    public ExecuteResult jobExecute(JobArgs jobArgs) throws InterruptedException {
+        for (int i = 0; i < 30; i++) {
+            EasyRetryLog.REMOTE.info("任务执行开始. [{}]", i + "" + JsonUtil.toJsonString(jobArgs));
+            Thread.sleep(1000);
+        }
         FailOrderPo failOrderPo = new FailOrderPo();
         failOrderPo.setOrderId("xiaowoniu");
-        EasyRetryLog.REMOTE.info("任务执行结束. [{}]", jobArgs);
         return ExecuteResult.success(failOrderPo);
     }