基于Redis实现基本抢红包算法详解

//这里输入的totalMoney单位是分,例如100元,totalMoney = 10000
public List<Integer> getRedPackage(Integer totalMoney,Integer totalPeopleCount) {
    List<Integer> moneyList = new ArrayList<>();
    //暂存剩余金额为红包的总金额
    Integer restMoney = totalMoney;
    //暂存剩余的总人数-初始化时即为指定的总人数
    Integer restPeopleCount = totalPeopleCount;    
    //随机数对象
    Random random = new Random();
    //开始循环迭代生成红包
    for (int i =0;i< totalPeopleNum-1;i++){
       //加1是为了至少抢到1分钱
       int money = random.nextInt (restMoney / restPeopleCount * 2) + 1;
       restMoney -= money;
       restPeopleCount--;
       moneyList.add(money);
    }
    //添加最后的一个红包金额
    amountList.add(restAmount);
    return amountList;
}

//随机生成全局唯一的红包id
redId = getRedId();
//首先生成红包金额
List<Integer> moneyList = getRedPackage(totalMoney,totalPeopleCount);
//放入redis
redisClient.lpush(redId, moneyList);
//redis中记录红包个数
redisClient.set(redId, moneyList.size());
//异步存储发红包记录到Mysql数据库
//将红包id返回
return redId;

redMoney = redisClient.get("rob" + redId + useId)
//如果不为空,则说明已经抢过了,直接返回抢过的红包金额
if (redMoney != null) {
    return redMoney
}

totalNum = redisClient.get("totalNum" + redId)
//如果为空或者小于等于0则代表没有了
if (totalNum == null || totalNum <= 0) {
    return null
}

money = redisClient.rpop(redId)
//如果不为空,则说明抢到了
if (money != null) {
    ....
    红包个数减1
    存储抢红包记录
    设置该用户已经抢过红包
    ....
    //返回抢到的金额
    return money
}
//没抢到
return null

money = redisClient.rpop(redId)
//如果不为空,则说明抢到了
if (money != null) {
    //红包个数减1
    redisClient.decr(redId)
    ....
    存储抢红包记录
    设置该用户已经抢过红包
    ....
    //返回抢到的金额
    return money
}
//没抢到
return null

money = redisClient.rpop(redId)
//如果不为空,则说明抢到了
if (money != null) {
    //红包个数减1
    redisClient.decr(redId)
    //异步存储抢红包记录
    这里可以使用mq或者多线程的方式来实现
    ....
    设置该用户已经抢过红包
    ....
    //返回抢到的金额
    return money
}
//没抢到
return null

money = redisClient.rpop(redId)
//如果不为空,则说明抢到了
if (money != null) {
    //红包个数减1
    redisClient.decr(redId)
    //异步存储抢红包记录
    这里可以使用mq或者多线程的方式来实现
    //设置该用户已经抢过红包
    redisClient.set("rob" + redId + useId, money)
    //返回抢到的金额
    return money
}
//没抢到
return null

redMoney = redisClient.get("rob" + redId + useId)
//如果不为空,则说明已经抢过了,直接返回抢过的红包金额
if (redMoney != null) {
    return redMoney
}
totalNum = redisClient.get("totalNum" + redId)
//如果红包总数小于0, 则代表已经抢完了, 直接返回空
if (totalNum == null || totalNum <= 0) {
    return null
}
money = redisClient.rpop(redId)
//如果不为空,则说明抢到了
if (money != null) {
    //红包个数减1
    redisClient.decr(redId)
    //异步存储抢红包记录
    这里可以使用mq或者多线程的方式来实现
    //设置该用户已经抢过红包
    redisClient.set("rob" + redId + useId, money)
    //返回抢到的金额
    return money
} 
//没抢到
return null

redMoney = redisClient.get("rob" + redId + useId)
//如果不为空,则说明已经抢过了,直接返回抢过的红包金额
if (redMoney != null) {
    return redMoney
}
totalNum = redisClient.get("totalNum" + redId)
//如果红包总数小于0, 则代表已经抢完了, 直接返回空
if (totalNum == null || totalNum <= 0) {
    return null
}
//加分布式锁
lockResut = redisClient.setNx(useId,redId,timeOut);
//加锁失败,直接返回
if(!lockResult){
    return;
}
try{
    money = redisClient.rpop(redId)
    //如果不为空,则说明抢到了
    if (money != null) {
        //红包个数减1
        redisClient.decr(redId)
        //异步存储抢红包记录
        这里可以使用mq或者多线程的方式来实现
        //设置该用户已经抢过红包
        redisClient.set("rob" + redId + useId, money)
        //返回抢到的金额
        return money
    }     
} finally {
    //删除锁
    redisClient.del(useId)
}
//没抢到
return null