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

fix: 2.0.0

Browse Source 
1. 修复回滚主键冲突问题
This commit is contained in:
byteblogs168 2023-06-14 16:10:21 +08:00
parent 10ec18adae
commit 846eb8693f
2 changed files with 5 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
easy-retry-server/src/main/java/com/aizuda/easy/retry/server/service/impl/RetryDeadLetterServiceImpl.java
View File

@ -89,6 +89,7 @@ public class RetryDeadLetterServiceImpl implements RetryDeadLetterService {
retryTask.setNextTriggerAt(WaitStrategies.randomWait(1, TimeUnit.SECONDS, 60, TimeUnit.SECONDS).computeRetryTime(null)); retryTask.setNextTriggerAt(WaitStrategies.randomWait(1, TimeUnit.SECONDS, 60, TimeUnit.SECONDS).computeRetryTime(null));
retryTask.setCreateDt(LocalDateTime.now()); retryTask.setCreateDt(LocalDateTime.now());
retryTask.setUpdateDt(LocalDateTime.now()); retryTask.setUpdateDt(LocalDateTime.now());
retryTask.setId(null);
RequestDataHelper.setPartition(groupName); RequestDataHelper.setPartition(groupName);
Assert.isTrue(1 == retryTaskMapper.insert(retryTask), () -> new EasyRetryServerException("新增重试任务失败")); Assert.isTrue(1 == retryTaskMapper.insert(retryTask), () -> new EasyRetryServerException("新增重试任务失败"));

6
easy-retry-server/src/main/java/com/aizuda/easy/retry/server/support/handler/ServerNodeBalance.java
View File

@ -164,7 +164,7 @@ public class ServerNodeBalance implements Lifecycle, Runnable {
try { try {
TimeUnit.SECONDS.sleep(INITIAL_DELAY); TimeUnit.SECONDS.sleep(INITIAL_DELAY);
} catch (InterruptedException e) { } catch (InterruptedException e) {
e.printStackTrace(); Thread.currentThread().interrupt();
} }
while (!Thread.currentThread().isInterrupted()) { while (!Thread.currentThread().isInterrupted()) {
@ -234,13 +234,15 @@ public class ServerNodeBalance implements Lifecycle, Runnable {
} catch (InterruptedException e) { } catch (InterruptedException e) {
LogUtils.error(log, "check balance interrupt"); LogUtils.error(log, "check balance interrupt");
Thread.currentThread().interrupt();
} catch (Exception e) { } catch (Exception e) {
LogUtils.error(log, "check balance error", e); LogUtils.error(log, "check balance error", e);
} finally { } finally {
try { try {
TimeUnit.SECONDS.sleep(1); TimeUnit.SECONDS.sleep(1);
} catch (InterruptedException e) { } catch (InterruptedException e) {
e.printStackTrace(); LogUtils.error(log, "check balance interrupt");
Thread.currentThread().interrupt();
} }
} }
} }