Alawn/udf
1
0
Fork 0
mirror of https://gitee.com/wangkang/udf.git synced 2026-10-30 13:53:45 +00:00
Code Issues Releases Wiki Activity

分布式ID重构

Browse Source
This commit is contained in:
wangkang
2017-09-07 20:13:39 +08:00
parent c737a5c7a9
commit e885465012
1 changed files with 2 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files
udf-starter-id/src/main/java/org/itkk/udf/id/IdWorkerFactory.java
+2
View File
@@ -293,6 +293,7 @@ public class IdWorkerFactory {
//远程请求失败,快速剔除远程节点,本地重试
log.error("rmsNexId failure , start fast switching , error ---------> {}", e.getMessage());
redisTemplate.delete(idWorkerWrapper.getCacheKey());
this.localCache.remove(idWorkerWrapper.getCacheKey());
return this.nextId(idWorkerWrapper.getDatacenterId(), idWorkerWrapper.getWorkerId());
}
}
@@ -319,6 +320,7 @@ public class IdWorkerFactory {
//远程请求失败,快速剔除远程节点,本地重试
log.error("rmsBatchNexId failure , start fast switching , error ---------> {}", e.getMessage());
redisTemplate.delete(idWorkerWrapper.getCacheKey());
this.localCache.remove(idWorkerWrapper.getCacheKey());
return this.batchNextId(idWorkerWrapper.getDatacenterId(), idWorkerWrapper.getWorkerId(), count);
}
}