Maison > Article > base de données > PHP+redis implémente les opérations de verrouillage et de déverrouillage
Contexte professionnel : des verrous sont nécessaires dans les jeux d'échecs et de cartes en salle pour empêcher une lecture sale des données Redis causée par des opérations simultanées, par exemple l'ajout de l'action d'un utilisateur entrant dans une salle :
En cas de concurrence, get RoomUsers aura des lectures sales
Solution : verrouiller la salle pour permettre à un seul client d'opérer dans une salle à la fois ; time et autres clients simultanés Attendez ; c'est-à-dire ----- blocage du verrouillage ;
Verrouillage : Il existe plusieurs méthodes de verrouillage Redis : incr, set, setnx, hSetnx, vous pouvez vous référer à cet article : Comment lock redis Une sorte d'implémentation
Recommandé :Tutoriel vidéo PHP
Ici, j'utilise set this way
$roomId = $_GET['roomId']; $user = $_GET['user']; // '张三' $key = "LockRoom:{$roomId}"; $value = $roomId.uniqid(); $ex = 3; // 如果 $key 不存在的话,就设置 $key 的值为 $value,且有效期为 3s; // return TRUE / FALSE while(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); // ['李四', '王五', '张三']
Déverrouillage : bien sûr, vous devez déverrouiller après l'opération, non Pour déverrouiller, il faut attendre au moins 3 secondes ;
Pour déverrouiller, utilisez delete pour supprimer la clé mais il y a un écueil ici Vous ne pouvez pas utiliser delete directement car c'est supposé. que le client01 obtient le verrou et que le temps dépasse 3 secondes pendant le processus d'ajout d'un utilisateur à la salle, à ce moment-là, le client02 obtiendra également le verrou et définira 3S, puis lorsque le client01 terminera l'opération et supprimera la clé, le verrou sera défini. par client02 sera supprimé
Il est recommandé d'utiliser le code Lua pour effectuer la suppression, car l'exécution de Lua est du sexe atomique.
// 将用户添加进房间 $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] then return redis.call("del",KEYS[1]) else return 0 end '; $this->redis->eval($script, array($key , $value), 1);
Pour plus de connaissances connexes, veuillez prêter attention à la colonne tutoriel d'introduction à Redis
Ce qui précède est le contenu détaillé de. pour plus d'informations, suivez d'autres articles connexes sur le site Web de PHP en chinois!