gtsoft/gtsoft-snail-job-demo
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

!1 【feat 2.6.0】新增广播、分区、工作流节点定时任务执行器

Browse Source 
* feat 2.6.0:
This commit is contained in:
wodeyangzipingpingwuqi 2024-01-24 01:27:38 +00:00 committed by byteblogs168
parent 5128094594
commit 7bbb08b110
3 changed files with 63 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

30
src/main/java/com/example/easy/retry/job/TestBroadcastJobExecutor.java Normal file
View File

@ -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);
}
}

27
src/main/java/com/example/easy/retry/job/TestPartitionJobExecutor.java Normal file
View File

@ -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);
}
}

9
src/main/java/com/example/easy/retry/job/TestWorkflowAnnoJobExecutor.java
View File

@ -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);
}