redis乐观锁使用watch完成秒杀抢购功能

  •   
  • 219
  • php
  • 0
  • dodobook
  • 2019/03/18

乐观锁
大多数是基于数据版本(version)的记录机制实现的。即为数据增加一个版本标识,在基于数据库表的版本解决方案中,一般是通过为数据库表增加一个”version”字段来实现读取出数据时,将此版本号一同读出,之后更新时,对此版本号加1。此时,将提交数据的版本号与数据库表对应记录的当前版本号进行比对,如果提交的数据版本号大于数据库当前版本号,则予以更新,否则认为是过期数据。

Redis中可以使用watch命令会监视给定的key,当exec时候如果监视的key从调用watch后发生过变化,则整个事务会失败。也可以调用watch多次监视多个key。这样就可以对指定的key加乐观锁了。注意watch的key是对整个连接有效的,事务也一样。如果连接断开,监视和事务都会被自动清除。当然了exec,discard,unwatch命令都会清除连接中的所有监视。

Redis事务
Redis中的事务(transaction)是一组命令的集合。事务同命令一样都是Redis最小的执行单位,一个事务中的命令要么都执行,要么都不执行。Redis事务的实现需要用到 MULTI 和 EXEC 两个命令,事务开始的时候先向Redis服务器发送 MULTI 命令,然后依次发送需要在本次事务中处理的命令,最后再发送 EXEC 命令表示事务命令结束。

Redis的事务是下面4个命令来实现
1.multi,开启Redis的事务,置客户端为事务态。
2.exec,提交事务,执行从multi到此命令前的命令队列,置客户端为非事务态。
3.discard,取消事务,置客户端为非事务态。
4.watch,监视键值对,作用时如果事务提交exec时发现监视的监视对发生变化,事务将被取消。

使用redis中两个key完成秒杀抢购功能,sales用于存储抢购数量和user_list用户存储抢购列表。

它的优点如下:
1. 首先选用内存数据库来抢购速度极快。
2. 速度快并发自然没不是问题。
3. 使用悲观锁,会迅速增加系统资源。
4. 比队列强的多,队列会使你的内存数据库资源瞬间爆棚。
5. 使用乐观锁,达到综合需求。

我觉得以下代码肯定是你想要的。

 
	header("content-type:text/html;charset=utf-8");  
	$redis = new redis();  
	$result = $redis->connect('127.0.0.1', 6379);

	$store = 5;		//秒杀总库存

	//watch():监视一个或多个key,如果在事务执行之前这个(或这些)key被其他命令所改动,那么事务将被打断
	//WATCH命令可以监控一个或多个键,一旦其中有一个键被修改(或删除),之后的事务就不会执行。
	//监控一直持续到EXEC命令(事务中的命令是在EXEC之后才执行的,所以在MULTI命令后可以修改WATCH监控的键值)
	//加锁 set() 监视

	$redis->watch('sales');		//监视销量变化
	$sales = $redis->get('sales');	//获取销量
	if($sales >= $store) {
		exit('秒杀结束');
	}

	//sleep(3);  	设置延迟,方便测试效果。 

	//事务 要么成功提交 要么不提交

	$redis->multi();
	$redis->incr('sales');	//执行+1操作
	$redis->hSet("user_list","user_id_".mt_rand(1, 9999),time());
	$res = $redis->exec();

	if($res) {		//秒杀成功
		//TODO
		//写mysql 或者消息队列 或者 swoole

		$userList = $redis->hGetAll("user_list");  
		echo "抢购成功!<br/>";  
		echo "剩余数量:".($store - $sales -1)."<br/>";  
		echo "用户列表:<pre>";  
		var_dump($userList);  

	}

参考链接:

https://blog.csdn.net/qq_33862778/article/details/80651703

https://blog.csdn.net/hyfound/article/details/80618040

https://blog.csdn.net/m_nanle_xiaobudiu/article/details/80479666