Alawn/udf
1
0
Fork 0
mirror of https://gitee.com/wangkang/udf.git synced 2026-10-31 19:43:41 +00:00
Code Issues Releases Wiki Activity

更新逻辑,防止死锁

Browse Source
This commit is contained in:
王康
2017-09-06 22:03:48 +08:00
parent 6a90e737c6
commit 2bcc7832d4
2 changed files with 24 additions and 12 deletions
Download Patch File Download Diff File Expand all files Collapse all files
udf-starter-id/src/main/java/org/itkk/udf/id/IdWorker.java
+12 -12
View File
@@ -21,62 +21,62 @@ public class IdWorker {
/**
* 描述 : 时间起始标记点，作为基准，一般取系统的最近时间（一旦确定不能变动）
*/
private final long twepoch = 1288834974657L;
private long twepoch = 1288834974657L;
/**
* 描述 : 机器标识位数
*/
private final long workerIdBits = 5L;
private long workerIdBits = 5L;
/**
* 描述 : 数据中心标识位数
*/
private final long datacenterIdBits = 5L;
private long datacenterIdBits = 5L;
/**
* 描述 : 机器ID最大值
*/
private final long maxWorkerId = -1L ^ (-1L << workerIdBits);
private long maxWorkerId = -1L ^ (-1L << workerIdBits);
/**
* 描述 : 数据中心ID最大值
*/
private final long maxDatacenterId = -1L ^ (-1L << datacenterIdBits);
private long maxDatacenterId = -1L ^ (-1L << datacenterIdBits);
/**
* 描述 : 毫秒内自增位
*/
private final long sequenceBits = 12L;
private long sequenceBits = 12L;
/**
* 描述 : 机器ID偏左移12位
*/
private final long workerIdShift = sequenceBits;
private long workerIdShift = sequenceBits;
/**
* 描述 : 数据中心ID左移17位
*/
private final long datacenterIdShift = sequenceBits + workerIdBits;
private long datacenterIdShift = sequenceBits + workerIdBits;
/**
* 描述 : 时间毫秒左移22位
*/
private final long timestampLeftShift = sequenceBits + workerIdBits + datacenterIdBits;
private long timestampLeftShift = sequenceBits + workerIdBits + datacenterIdBits;
/**
* 描述 : 序列号最大值 , 一微秒能产生的ID个数
*/
private final long sequenceMask = -1L ^ (-1L << sequenceBits);
private long sequenceMask = -1L ^ (-1L << sequenceBits);
/**
* 描述 : 机器ID( 0 - 31 )
*/
private final long workerId;
private long workerId;
/**
* 描述 : 数据中心ID( 0 - 31 )
*/
private final long datacenterId;
private long datacenterId;
/**
* 描述 : 序列号( 0 - 4095)
udf-starter-id/src/main/java/org/itkk/udf/id/IdWorkerInit.java
+12
View File
@@ -133,6 +133,18 @@ public class IdWorkerInit {
String key = cacheRedisProperties.getPrefix().concat(SPLIT).concat(CACHE_NAME).concat(SPLIT).concat(Integer.toString(i)).concat(SPLIT).concat(Integer.toString(j));
//创建锁
lock = connection.setNX(serializer.serialize(key), jdkSerializationRedisSerializer.serialize(this.cacheValue));
//检查是否是死锁
if (!lock) {
//获得缓存过期时间
long expiration = connection.ttl(serializer.serialize(key));
//如果等于-1,则代表死锁
if (expiration == -1) {
//删除缓存
connection.del(serializer.serialize(key));
//重新创建锁
lock = connection.setNX(serializer.serialize(key), jdkSerializationRedisSerializer.serialize(this.cacheValue));
}
}
//获取失败
if (!lock) {
//获得数据