PHP+Redis implementiert Sperr- und Entsperrvorgänge

Geschäftshintergrund: Bei Raumschach- und Kartenspielen werden Sperren benötigt, um ein fehlerhaftes Lesen von Redis-Daten zu verhindern, das beispielsweise durch das Hinzufügen der Aktion eines Benutzers beim Betreten eines Raums verursacht wird:

Im Fall von Parallelität erhalten RoomUsers Dirty Reads.

Lösung: Sperren Sie den Raum, damit nur ein Client gleichzeitig in einem Raum arbeiten kann Zeit und andere gleichzeitige Clients Warten Sie; das ist ----- Blockierungssperre;

Sperren: Es gibt mehrere Redis-Sperrmethoden: incr, set, setnx, hSetnx, Sie können sich auf diesen Artikel beziehen: Anleitung lock redis Eine Art Implementierung

Empfohlen:PHP-Video-Tutorial

Hier verwende ich 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); // ['李四', '王五', '张三']

Entsperren: Natürlich muss man entsperren Nach dem Vorgang müssen Sie mindestens 3 Sekunden warten. Zum Entsperren verwenden Sie die Löschfunktion, um den Schlüssel zu löschen. Sie können die Löschfunktion jedoch nicht direkt verwenden Wenn Client01 die Sperre erhält und die Zeit beim Hinzufügen eines Benutzers zum Raum 3 Sekunden überschreitet, erhält Client02 zu diesem Zeitpunkt auch die Sperre und setzt 3S. Wenn Client01 den Vorgang abschließt und den Schlüssel löscht, wird die Sperre festgelegt von client02 wird gelöscht;

Es wird empfohlen, zum Löschen Lua-Code zu verwenden, da es sich bei der Lua-Ausführung um atomaren Sex handelt.

// 将用户添加进房间
$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);

Weitere Informationen zu diesem Thema finden Sie in der Spalte

Redis-Einführungs-Tutorial

Das obige ist der detaillierte Inhalt vonPHP+Redis implementiert Sperr- und Entsperrvorgänge. Für weitere Informationen folgen Sie bitte anderen verwandten Artikeln auf der PHP chinesischen Website!