本文先容如何利用Redis完成秒杀功能。
秒杀功能是高并发的范例场景。整体的方案是：Redis缓存 + 异步同步数据到数据库
整体方案
方案1：Redis + MQ
秒杀之前，将产品的库存从数据库同步到Redis
秒杀时，通过lua脚本担保原子性
扣减库存
返回1（表示成功）
外部判断结果，若结果为1（成功），则将订单数据通过MQ投递出去
MQ消费者收到数据后，持久化到数据库中
方案2：Redis + Redis的发布订阅功能
秒杀之前，将产品的库存从数据库同步到Redis
秒杀时，通过lua脚本担保原子性
扣减库存
将订单数据通过Redis的发布订阅功能发布出去
返回1（表示成功）
订单数据的Redis订阅者处理订单数据
方案3：Redis + 定时任务（不推举）
利用定时任务读Redis中的订单数据列表。
不推举的缘故原由：麻烦。须要掌握定时任务的开启和关闭等。
秒杀的lua脚本示例
@Autowired
private StringRedisTemplate stringRedisTemplate = null;
String purchaseScript =
// 先将产品编号保存到凑集中
" redis.call('sadd', KEYS[1], ARGV[2]) \n"
// 购买列表
+ "local productPurchaseList = KEYS[2]..ARGV[2] \n"
// 用户编号
+ "local userId = ARGV[1] \n"
// 产品key
+ "local product = 'product_'..ARGV[2] \n"
// 购买数量
+ "local quantity = tonumber(ARGV[3]) \n"
// 当前库存
+ "local stock = tonumber(redis.call('hget', product, 'stock')) \n"
// 价格
+ "local price = tonumber(redis.call('hget', product, 'price')) \n"
// 购买韶光
+ "local purchase_date = ARGV[4] \n"
// 库存不敷，返回0
+ "if stock < quantity then return 0 end \n"
// 减库存
+ "stock = stock - quantity \n"
+ "redis.call('hset', product, 'stock', tostring(stock)) \n"
// 打算价格
+ "local sum = price quantity \n"
// 合并购买记录数据
+ "local purchaseRecord = userId..','..quantity..','"
+ "..sum..','..price..','..purchase_date \n"
// 保存到将购买记录保存到list里
+ "redis.call('rpush', productPurchaseList, purchaseRecord) \n"
// 返回成功
+ "return 1 \n";
// Redis购买记录凑集前缀
private static final String PURCHASE_PRODUCT_LIST = "purchase_list_";
// 抢购商品凑集
private static final String PRODUCT_SCHEDULE_SET = "product_schedule_set";
// 32位SHA1编码，第一次实行的时候先让Redis进行缓存脚本返回
private String sha1 = null;
@Override
public boolean purchaseRedis(Long userId, Long productId, int quantity) {
// 购买韶光
Long purchaseDate = System.currentTimeMillis();
Jedis jedis = null;
try {
// 获取原始连接
jedis = (Jedis) stringRedisTemplate
.getConnectionFactory().getConnection().getNativeConnection();
// 如果没有加载过，则先将脚本加载到Redis做事器，让其返回sha1
if (sha1 == null) {
sha1 = jedis.scriptLoad(purchaseScript);
}
// 实行脚本，返回结果
Object res = jedis.evalsha(sha1, 2, PRODUCT_SCHEDULE_SET,
PURCHASE_PRODUCT_LIST, userId + "", productId + "",
quantity + "", purchaseDate + "");
Long result = (Long) res;
return result == 1;
} finally {
// 关闭jedis连接
if (jedis != null && jedis.isConnected()) {
jedis.close();
}
}
}
可用于秒杀的操作
list（行列步队）
思路
把秒杀要求压入行列步队：RPUSH key value （当插入的秒杀要求数达到上限时，停滞所有后续插入。）
同时，从行列步队得到用户要求的用户ID等并进行处理
后台启动多个事情线程，利用LPOP key 或 LRANGE key start end
每完成一条秒杀记录的处理，就实行减库存操作：Decr/Decrby key （详见下方）
所有库存处理完毕，就结束该商品的本次秒杀，关闭事情线程，也不再吸收秒杀要求。
将数据同步到磁盘（数据库）：可以利用定时任务
原子增减
紧张是这几个命令：incr、incrby、decr、decrby
逻辑：
1，调用 incrby ，此时返回数字为减少后的数字。
2，如果此时返回小于 0，返回库存不敷。否则就成功获取到库存。
3，如果用户下单失落败，须要用 lua 脚本操作。内容为判断库存是否小于 0 ，小于 0 时直接将新库存 set 进去，否则还是用 incr 自增。要加库存也是用这个脚本的逻辑。
示例
local nowNum = redis.call("get","STOCK_KEY")
if (nowNum == nil or nowNum < 0) then
redis.call("set","STOCK_KEY",INCR)
return INCR
end
return redis.call("incrby","STOCK_KEY",INCR)
INCR 为要返还的库存或新增库存数
把稳
如果是减库存，要用decrby count_key 1。incrby count_key -1 会涌现负值，用这种办法的话得采取lua脚本的办法，先要判断count_key的值是否>0 才连续扣减，这样才能防止超卖。
不可用于秒杀的操作
锁
剖析：
Redis事务是乐不雅观锁，它不能锁住操作，仅仅只是监听事务内的key是否已经被操作过。
之以是会超发，是由于你代码中 获取库存-减少库存-放入新库存数 这期间不是原子性的。
比如 A 获取是库存为 100，B 获取时库存为 100，两方经由打算之后得到的剩余库存数都是99，然后 set 到 Redis 去，以是末了的结果是99。
当然，你可以给“获取库存=> 减少库存=> 放入新库存数”过程加锁，但是在秒杀高并发下，系统会卡去世。办理办法是，用 Redis 原生的 hincrby 或 incrby 方法，该方法用于原子性操作 Hash 工具中的数字自增或自减。（见上方）
利用锁的超发例子
<?php
header("content-type:text/html;charset=utf-8");
$redis = new redis();
$result = $redis->connect('10.10.10.119', 6379);
$mywatchkey = $redis->get("mywatchkey");
$rob_total = 100; //抢购数量
if($mywatchkey<$rob_total){
$redis->watch("mywatchkey");
$redis->multi();
//设置延迟，方便测试效果。
sleep(5);
//插入抢购数据
$redis->hSet("mywatchlist","user_id_".mt_rand(1, 9999),time());
$redis->set("mywatchkey",$mywatchkey+1);
$rob_result = $redis->exec();
if($rob_result){
$mywatchlist = $redis->hGetAll("mywatchlist");
echo "抢购成功！
<br/>";
echo "剩余数量：".($rob_total-$mywatchkey-1)."<br/>";
echo "用户列表：<pre>";
var_dump($mywatchlist);
}else{
echo "手气不好，再抢购！
";exit;
}
}
?>
Redis Cluster撑不住怎么办
若客户很多。纵然支配了Redis Cluster，仍旧撑不住，那该怎么办呢？ 下面，我们详细剖析下，还有哪些情形会压垮我们架构在Redis（Cluster）上的秒杀系统。
脚本攻击
如现在有很多抢火车票的软件。它们会自动发起http要求。一个客户端一秒会发起很多次要求。如果有很多用户利用了这样的软件，就可能会直接把我们的交流机给压垮了。
这个问题实在属于网络问题的范畴，和我们的秒杀系统不在一个层面上。因此不应该由我们来办理。很多交流机都有防止一个源IP发起过多要求的功能。开源软件也有不少能实现这点。如linux上的TC可以掌握。盛行的Web做事器Nginx（它也可以看做是一个七层软交流机）也可以通过配置做到这一点。一个IP，一秒钟我就许可你访问我2次，其他软件包直接给你丢了，你还能压垮我吗？
交流机撑不住了
可能你们的客户并发访问量实在太大了，交流机都撑不住了。 这也有办法。我们可以用多个交流机为我们的秒杀系统做事。 事理便是DNS可以对一个域名返回多个IP，并且对不同的源IP，同一个域名返回不同的IP。如网通用户访问，就返回一个网通机房的IP；电信用户访问，就返回一个电信机房的IP。也便是用CDN了！
我们可以支配多台交流机为不同的用户做事。 用户通过这些交流机访问后面数据中央的Redis Cluster进行秒杀作业。
