用户金额的终极解决方案--Redis Lua

咱们在开发各类订单系统的时候都会碰到一个必须面对的问题，用户金额的最终结算。通常咱们会把金额存在数据库中，采用行级锁的方式来对金额的变更来进行处理，可是在高并发下，对于结算时间有要求的状况下，这种方式是极为低效的。

因此咱们打算将用户的金额放在Redis中进行处理，不管用户的查询，充值，付帐，开奖增长都会有一个高效的返回。可是咱们遇到的问题依然是是否要用锁的问题。由于Redis是单线程的，在多个动做同时执行的时候，要保证咱们代码执行到每一步，他的金额都不会错乱，好比不会小于0的状况下依然能够付帐成功。若是使用分布式锁来锁定用户每次操做，那么大量的用户进行操做时对性能的影响是很是大的，这个时候咱们的主角登场了——Redis Lua，它能够将多条Redis命令合成一条原子操做命令，避免在判断金额大小的时候，其余线程修改了金额，在非加锁的状况下后续的操做殊不知道的尴尬。固然最后咱们能够经过异步的方式将数据更新到数据库中。再存储每一条金额的变更流水日志，以方便对帐和校准。

具体实现为

在接口中添加两个方法

/**
 * 支付金额
 * @param key
 * @param amount
 * @return
 */
Object payMonery(String key,String amount);

/**
 * 增长金额
 * @param key
 * @param amount
 * @return
 */
Object addMonery(String key,String amount);

集群实现类方法

@Override
public Object payMonery(String key, String amount) {
    String script = "if redis.call('exists',KEYS[1]) == 1 then if (redis.call('get',KEYS[1]) + ARGV[1]) >= 0 then" +
            " redis.call('incrbyfloat',KEYS[1],ARGV[1]) return redis.call('set',KEYS[1],string.format('%0.2f',redis.call('get',KEYS[1])))" +
            "  else return 0 end else return 0  end";
    return jedisCluster.eval(script,1,key,"-" + amount);
}

@Override
public Object addMonery(String key, String amount) {
    String script = "if redis.call('exists',KEYS[1]) == 1 then  redis.call('incrbyfloat',KEYS[1],ARGV[1])" +
            " return redis.call('set',KEYS[1],string.format('%0.2f',redis.call('get',KEYS[1]))) " +
            " else return 0  end";
    return jedisCluster.eval(script,1,key, amount);
}

单机实现类方法

@Override
public Object payMonery(String key, String amount) {
    String script = "if redis.call('exists',KEYS[1]) == 1 then if (redis.call('get',KEYS[1]) + ARGV[1]) >= 0 then" +
            " redis.call('incrbyfloat',KEYS[1],ARGV[1]) return redis.call('set',KEYS[1],string.format('%0.2f',redis.call('get',KEYS[1])))" +
            "  else return 0 end else return 0  end";
    return execute((jedis -> jedis.eval(script,1,key,"-" + amount)));
}

@Override
public Object addMonery(String key, String amount) {
    String script = "if redis.call('exists',KEYS[1]) == 1 then  redis.call('incrbyfloat',KEYS[1],ARGV[1])" +
            " return redis.call('set',KEYS[1],string.format('%0.2f',redis.call('get',KEYS[1]))) " +
            " else return 0  end";
    return execute((jedis -> jedis.eval(script,1,key, amount)));
}