业务背景:在房间棋牌游戏中需要用到锁来防止并发操作引起的 redis 数据脏读问题;例如添加用户进入房间的动作:
并发的情况下,get RoomUsers 会有脏读现象;
解决思路:加锁房间来实现 一个房间每次只允许一个客户端操作,其他并发客户端则等待;也就是-----堵塞锁;
加锁:redis加锁方式有几种: incr、set、setnx、hSetnx,可以参考这篇文章:redis加锁的几种实现
这里我用到 set 这种方式
$roomId = $_GET[ roomId $user = $_GET[ user // 张三 $key = LockRoom:{$roomId} $html' target='_blank'>value = $roomId.uniqid();$ex = 3;// 如果 $key 不存在的话,就设置 $key 的值为 $value,且有效期为 3s; // return TRUE / FALSEwhile(true){ $res = $this- redis- set($key, $value, [ nx , ex = $ex]); if($res) { break; } usleep(5000);// 将用户添加进房间$roomUsers = $this- redis- get( Room:{$roomId}:Users // [ 李四 , 王五 ]$roomUsers[] = $user;$this- redis- set( Room:{$roomId}:Users , $roomUsers); // [ 李四 , 王五 , 张三 ]
解锁:操作完当然要解锁了,不解锁起码要等待 3秒;
解锁用 delete 删除 key; 但是这里有个坑,不能直接用 delete,因为假设 client01 获得了锁,在添加用户进入房间的过程中 时间超过了 3秒 ,这个时候client02 就会同样获得锁并且设置3S,然后当client01 操作完之后 delete key , 就把 client02 设置的锁删除了;
这里推荐用 lua 代码执行删除,因为lua 执行具有原子性。
// 将用户添加进房间$roomUsers = $this- redis- get( Room:{$roomId}:Users // [ 李四 , 王五 ]$roomUsers[] = $user;$this- redis- set( Room:{$roomId}:Users , $roomUsers); // [ 李四 , 王五 , 张三 ]// lua 脚本解锁// 先判断 key的值是否为 value, TRUE 才会删除, 所以 $value 的设计要有随机唯一性$script = if redis.call( get ,KEYS[1]) == ARGV[1] return redis.call( del ,KEYS[1]) return 0$this- redis- eval($script, array($key , $value), 1);
具体还可以看看 这篇文章:解锁 Redis 锁的正确姿势
还有php操作redis的文档:PhpRedis 里面有 set()、eval() 函数的解释
注意:用 lua 脚本这里 php.ini 需要开放 shell_exec() 等系统函数
以上代码仅作参考!!
以上就是本文的全部内容,希望对大家的学习有所帮助,更多相关内容请关注PHP !
相关推荐:
PHP操作Beanstalkd的方法及参数注释
PHP实现的内网穿透应用Spike重构完成
以上就是php redis的加锁与解锁的详细内容,PHP教程
郑重声明:本文版权归原作者所有,转载文章仅为传播更多信息之目的,如作者信息标记有误,请第一时间联系我们修改或删除,多谢。
新闻热点
疑难解答