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

feat(sj_1.1.0): 优化客户端传递上下文

Browse Source 
1. 优化分布式锁的重试间隔采用随机间隔
2.合并上下文重试采用随机间隔
This commit is contained in:
opensnail 2024-06-19 23:18:22 +08:00
parent 364cfa8ee8
commit 1fb21cee5f
3 changed files with 2 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
snail-job-server/snail-job-server-job-task/src/main/java/com/aizuda/snailjob/server/job/task/support/generator/batch/WorkflowBatchGenerator.java
View File

@ -13,7 +13,6 @@ import com.aizuda.snailjob.template.datasource.persistence.po.WorkflowTaskBatch;
import lombok.RequiredArgsConstructor; import lombok.RequiredArgsConstructor;
import lombok.extern.slf4j.Slf4j; import lombok.extern.slf4j.Slf4j;
import org.springframework.stereotype.Component; import org.springframework.stereotype.Component;
import org.springframework.transaction.annotation.Transactional;
import java.time.Duration; import java.time.Duration;
import java.util.Optional; import java.util.Optional;
@ -29,7 +28,6 @@ import java.util.Optional;
public class WorkflowBatchGenerator { public class WorkflowBatchGenerator {
private final WorkflowTaskBatchMapper workflowTaskBatchMapper; private final WorkflowTaskBatchMapper workflowTaskBatchMapper;
@Transactional
public void generateJobTaskBatch(WorkflowTaskBatchGeneratorContext context) { public void generateJobTaskBatch(WorkflowTaskBatchGeneratorContext context) {
// 生成任务批次 // 生成任务批次
@ -53,7 +51,5 @@ public class WorkflowBatchGenerator {
workflowTimerTaskDTO.setTaskExecutorScene(context.getTaskExecutorScene()); workflowTimerTaskDTO.setTaskExecutorScene(context.getTaskExecutorScene());
JobTimerWheel.registerWithWorkflow(() -> new WorkflowTimerTask(workflowTimerTaskDTO), Duration.ofMillis(delay)); JobTimerWheel.registerWithWorkflow(() -> new WorkflowTimerTask(workflowTimerTaskDTO), Duration.ofMillis(delay));
// JobTimerWheel.register(SyetemTaskTypeEnum.WORKFLOW.getType(), workflowTaskBatch.getId(),
// new WorkflowTimerTask(workflowTimerTaskDTO), delay, TimeUnit.MILLISECONDS);
} }
} }

2
snail-job-server/snail-job-server-job-task/src/main/java/com/aizuda/snailjob/server/job/task/support/handler/DistributedLockHandler.java
View File

@ -43,7 +43,7 @@ public class DistributedLockHandler {
Retryer<Boolean> retryer = RetryerBuilder.<Boolean>newBuilder() Retryer<Boolean> retryer = RetryerBuilder.<Boolean>newBuilder()
.retryIfResult(result -> result.equals(Boolean.FALSE)) .retryIfResult(result -> result.equals(Boolean.FALSE))
.retryIfException(ex -> true) .retryIfException(ex -> true)
.withWaitStrategy(WaitStrategies.fixedWait(sleepTime.toMillis(), TimeUnit.MILLISECONDS)) .withWaitStrategy(WaitStrategies.randomWait(sleepTime.toMillis(), TimeUnit.MILLISECONDS))
.withStopStrategy(StopStrategies.stopAfterAttempt(maxRetryTimes)) .withStopStrategy(StopStrategies.stopAfterAttempt(maxRetryTimes))
.withRetryListener(new RetryListener() { .withRetryListener(new RetryListener() {
@Override @Override

2
snail-job-server/snail-job-server-job-task/src/main/java/com/aizuda/snailjob/server/job/task/support/handler/WorkflowBatchHandler.java
View File

@ -335,7 +335,7 @@ public class WorkflowBatchHandler {
Retryer<Boolean> retryer = RetryerBuilder.<Boolean>newBuilder() Retryer<Boolean> retryer = RetryerBuilder.<Boolean>newBuilder()
.retryIfResult(result -> result.equals(Boolean.FALSE)) .retryIfResult(result -> result.equals(Boolean.FALSE))
.retryIfException(ex -> true) .retryIfException(ex -> true)
.withWaitStrategy(WaitStrategies.fixedWait(500, TimeUnit.MILLISECONDS)) .withWaitStrategy(WaitStrategies.randomWait(1000, TimeUnit.MILLISECONDS))
// 重试3秒 // 重试3秒
.withStopStrategy(StopStrategies.stopAfterAttempt(3)) .withStopStrategy(StopStrategies.stopAfterAttempt(3))
.withRetryListener(new RetryListener() { .withRetryListener(new RetryListener() {