Redisson单进程Redis分布式乐观锁的使用与实现
本文基于Redisson 3.7.5
4. 原子锁类
Redisson中实现了两种原子锁类:RAtomicLong和RAtomicDouble，还有RLongAdder和RDoubleAdder
RAtomicDouble和RAtomicLong其实一样的，RLongAdder和RDoubleAdder其实原理也是一样的，这里我们只说RAtomicLong和RLongAdder。
4.1. RedissonAtomicLong - 基于Redis实现的原子Long类
原子类的incrementAndGet，decrementAndGet，addandGet，主要通过INCR，DECR，INCRBY，DECRBY实现，其实redis的这些操作本身就是原子性的。
代码语言：javascript复制@Override
public RFuture<Long> getAndAddAsync(final long delta) {
//getAndAdd通过INCRBY实现
return commandExecutor.writeAsync(getName(), StringCodec.INSTANCE, new RedisStrictCommand<Long>("INCRBY", new SingleConvertor<Long>() {
@Override
public Long convert(Object obj) {
return ((Long) obj) - delta;
}
}), getName(), delta);
}
@Override
public RFuture<Long> getAndSetAsync(long newValue) {
//getAndSet通过GetSet实现
return commandExecutor.writeAsync(getName(), LongCodec.INSTANCE, RedisCommands.GETSET, getName(), newValue);
}
@Override
public RFuture<Long> incrementAndGetAsync() {
//incrementAndGet通过INCR实现
return commandExecutor.writeAsync(getName(), StringCodec.INSTANCE, RedisCommands.INCR, getName());
}
@Override
public RFuture<Long> decrementAndGetAsync() {
//减一通过DECR实现
return commandExecutor.writeAsync(getName(), StringCodec.INSTANCE, RedisCommands.DECR, getName());
}那么CAS更新呢？可以利用lua脚本的特性，也就是因为redis是单线程的，同时只能处理一个lua脚本，所以lua脚本具有原子性。
代码语言：javascript复制@Override
public RFuture<Boolean> compareAndSetAsync(long expect, long update) {
//CAS操作
//通过lua脚本的特性实现，lua脚本的原子性
//先检查值是否符合，如果符合再更新，返回true，否则返回false
return commandExecutor.evalWriteAsync(getName(), StringCodec.INSTANCE, RedisCommands.EVAL_BOOLEAN,
"local currValue = redis.call('get', KEYS[1]); "
"if currValue == ARGV[1] "
"or (tonumber(ARGV[1]) == 0 and currValue == false) then "
"redis.call('set', KEYS[1], ARGV[2]); "
"return 1 "
"else "
"return 0 "
"end",
Collections.<Object>singletonList(getName()), expect, update);
}4.2. RedissonLongAdder 基于Redis实现的LongAdder
在统计场景下（写多读少，且数值不用考虑并发安全），LongAdder表现比AtomicLong更好，那么基于redis是怎么实现呢？ Redisson的实现思路比较简单，本地留存一个longAdder，只有调用get或者sum的时候，才把本地的longAdder的数值加到redis中。
代码语言：javascript复制public class RedissonLongAdder extends RedissonBaseAdder<Long> implements RLongAdder {
//利用RAtomicLong实现redis中保存的数值
private final RAtomicLong atomicLong;
//本地longAdder
private final LongAdder counter = new LongAdder();
}统计但不get的操作都是对于本地longAdder操作：
代码语言：javascript复制@Override
public void add(long x) {
counter.add(x);
}
@Override
public void increment() {
add(1L);
}
@Override
public void decrement() {
add(-1L);
}与get还有sum相关的操作会把本地longAdder的数值加到redis中：
代码语言：javascript复制@Override
protected RFuture<Long> addAndGetAsync() {
return atomicLong.getAndAddAsync(counter.sum());
}
@Override
protected RFuture<Long> getAndDeleteAsync() {
return atomicLong.getAndDeleteAsync();
}
@Override
public long sum() {
return get(sumAsync());
}
