Maison >développement back-end >tutoriel php >PHP utilise le verrouillage Redis pour limiter les classes d'accès simultanées
PHP utilise le verrouillage Redis pour limiter les classes d'accès simultanées
- 黄舟original
- 2017-02-17 10:07:051830parcourir
1. Problèmes de restriction d'accès simultané
Pour certains scénarios où l'accès simultané du même utilisateur doit être restreint, si le l'utilisateur a de nombreuses demandes simultanées, et il n'y a pas de limite de verrouillage pour le traitement du serveur, et les utilisateurs peuvent demander avec succès plusieurs fois.
Par exemple, lors de l'échange de coupons, si l'utilisateur soumet le code d'échange simultanément en même temps, l'utilisateur peut utiliser le même code d'échange pour utiliser plusieurs coupons en même temps sans restrictions de verrouillage.
Le pseudo-code est le suivant :
if A(可以换领)
B(执行换领)
C(更新为已换领)D(结束)Si les utilisateurs soumettent des codes d'échange simultanément, ils jugeront tous qu'ils peuvent les utiliser (A), car il doit y avoir une exécution Après rachat (B), il sera mis à jour en rachat (C). Par conséquent, si l'utilisateur effectue plusieurs demandes avant qu'une mise à jour ne soit disponible, ces demandes peuvent être exécutées avec succès.
2. Méthode de restriction d'accès simultané
L'utilisation de verrous de fichiers peut obtenir des restrictions d'accès simultanés, mais pour les environnements d'architecture distribuée, l'utilisation de verrous de fichiers ne peut pas garantir la sécurité de plusieurs serveurs. Limites d’accès simultanées.
Redis est une base de données de valeurs-clés de type journal open source écrite en langage ANSI C, prend en charge le réseau, peut être basée sur la mémoire et persistante et fournit des API dans plusieurs langues.
Cet article utilisera sa méthode setnx pour implémenter la fonction de verrouillage distribué. setnx est Set il Npas eXistes.
Lorsque la valeur de la clé n'existe pas, l'insertion est réussie (le verrou est acquis avec succès). Si la valeur de la clé existe déjà, l'insertion échoue (l'acquisition du verrou échoue)
RedisLock.class.php
<?php/**
* Redis锁操作类
* Date: 2016-06-30
* Author: fdipzone
* Ver: 1.0
*
* Func:
* public lock 获取锁
* public unlock 释放锁
* private connect 连接
*/class RedisLock { // class start
private $_config; private $_redis; /**
* 初始化
* @param Array $config redis连接设定
*/
public function __construct($config=array()){
$this->_config = $config;
$this->_redis = $this->connect();
} /**
* 获取锁
* @param String $key 锁标识
* @param Int $expire 锁过期时间
* @return Boolean
*/
public function lock($key, $expire=5){
$is_lock = $this->_redis->setnx($key, time()+$expire); // 不能获取锁
if(!$is_lock){ // 判断锁是否过期
$lock_time = $this->_redis->get($key); // 锁已过期，删除锁，重新获取
if(time()>$lock_time){
$this->unlock($key);
$is_lock = $this->_redis->setnx($key, time()+$expire);
}
} return $is_lock? true : false;
} /**
* 释放锁
* @param String $key 锁标识
* @return Boolean
*/
public function unlock($key){ return $this->_redis->del($key);
} /**
* 创建redis连接
* @return Link
*/
private function connect(){ try{
$redis = new Redis();
$redis->connect($this->_config['host'],
$this->_config['port'],$this->_config['timeout'],
$this->_config['reserved'],$this->_config['retry_interval']);
if(empty($this->_config['auth'])){
$redis->auth($this->_config['auth']);
}
$redis->select($this->_config['index']);
}catch(RedisException $e){
throw new Exception($e->getMessage());
return false;
}
return $redis;
}
} // class end?>demo.php
<?php
require 'RedisLock.class.php';
$config = array( 'host' => 'localhost', 'port' => 6379, 'index' => 0, 'auth' => '', 'timeout' => 1,
'reserved' => NULL, 'retry_interval' => 100,
);
// 创建redislock对象$oRedisLock = new RedisLock($config);
// 定义锁标识$key = 'mylock';
// 获取锁$is_lock = $oRedisLock->lock($key, 10);
if($is_lock){
echo 'get lock success<br>';
echo 'do sth..<br>';
sleep(5);
echo 'success<br>';
$oRedisLock->unlock($key);
// 获取锁失败
}
else{
echo 'request too frequently<br>';
}?>
Méthode de test : Ouvrez deux navigateurs différents et accédez à demo.php en A et B en même temps
Si vous y accédez en premier, le verrou sera obtenu
Sortie
obtenir le succès du verrouillage
faire quelque chose..
succès
demande trop fréquemment
pour garantir qu'un seul accès est valide à la fois, valide Limiter l'accès simultané.
Afin d'éviter les blocages causés par des erreurs soudaines du système, un délai d'expiration est ajouté lors de l'acquisition du verrou. Si le délai d'expiration est dépassé, le verrou sera libéré même à l'état verrouillé. pour éviter un problème de blocage.
Adresse de téléchargement du code source : cliquez pour voir
Le pseudo-code est le suivant :
if A(可以换领)
B(执行换领)
C(更新为已换领)D(结束)Si les utilisateurs soumettent des codes d'échange simultanément, ils jugeront tous qu'ils peuvent les utiliser (A), car il doit y avoir une exécution Après rachat (B), il sera mis à jour en rachat (C). Par conséquent, si l'utilisateur effectue plusieurs demandes avant qu'une mise à jour ne soit disponible, ces demandes peuvent être exécutées avec succès. Redis est une base de données de valeurs-clés de type journal open source écrite en langage ANSI C, prend en charge le réseau, peut être basée sur la mémoire et persistante et fournit des API dans plusieurs langues. Cet article utilisera sa méthode setnx pour implémenter la fonction de verrouillage distribué.
setnx est Set il Npas eXistes. Lorsque la valeur de la clé n'existe pas, l'insertion est réussie (le verrou est acquis avec succès). Si la valeur de la clé existe déjà, l'insertion échoue (l'acquisition du verrou échoue)
RedisLock.class.php
<?php/**
* Redis锁操作类
* Date: 2016-06-30
* Author: fdipzone
* Ver: 1.0
*
* Func:
* public lock 获取锁
* public unlock 释放锁
* private connect 连接
*/class RedisLock { // class start
private $_config; private $_redis; /**
* 初始化
* @param Array $config redis连接设定
*/
public function __construct($config=array()){
$this->_config = $config;
$this->_redis = $this->connect();
} /**
* 获取锁
* @param String $key 锁标识
* @param Int $expire 锁过期时间
* @return Boolean
*/
public function lock($key, $expire=5){
$is_lock = $this->_redis->setnx($key, time()+$expire); // 不能获取锁
if(!$is_lock){ // 判断锁是否过期
$lock_time = $this->_redis->get($key); // 锁已过期，删除锁，重新获取
if(time()>$lock_time){
$this->unlock($key);
$is_lock = $this->_redis->setnx($key, time()+$expire);
}
} return $is_lock? true : false;
} /**
* 释放锁
* @param String $key 锁标识
* @return Boolean
*/
public function unlock($key){ return $this->_redis->del($key);
} /**
* 创建redis连接
* @return Link
*/
private function connect(){ try{
$redis = new Redis();
$redis->connect($this->_config['host'],
$this->_config['port'],
$this->_config['timeout'],
$this->_config['reserved'],
$this->_config['retry_interval']);
if(empty($this->_config['auth'])){
$redis->auth($this->_config['auth']);
}
$redis->select($this->_config['index']);
}catch(RedisException $e){ throw new Exception($e->getMessage());
return false;
} return $redis;
}
} // class end?>demo.php
<?phprequire 'RedisLock.class.php';
$config = array( 'host' => 'localhost', 'port' => 6379, 'index' => 0, 'auth' => '', 'timeout' => 1,
'reserved' => NULL, 'retry_interval' => 100,
);
// 创建redislock对象$oRedisLock = new RedisLock($config);
// 定义锁标识$key = 'mylock';
// 获取锁$is_lock = $oRedisLock->lock($key, 10);
if($is_lock){
echo 'get lock success<br>';
echo 'do sth..<br>';
sleep(5);
echo 'success<br>';
$oRedisLock->unlock($key);
// 获取锁失败
}
else{
echo 'request too frequently<br>';
}?>
Méthode de test :
Ouvrez deux navigateurs différents et accédez à demo.php en A et B en même temps Si vous y accédez en premier, le verrou sera obtenu
Sortie
obtenir le succès du verrouillage faire quelque chose..
succès
Si un autre ne parvient pas à acquérir le verrou, il émettra une
pour garantir qu'un seul accès est valide à la fois, valide Limiter l'accès simultané.
Afin d'éviter les blocages causés par des erreurs soudaines du système, un délai d'expiration est ajouté lors de l'acquisition du verrou. Si le délai d'expiration est dépassé, le verrou sera libéré même à l'état verrouillé. pour éviter un problème de blocage.
Ce qui précède est le contenu de PHP utilisant le verrouillage Redis pour limiter l'accès simultané. Pour plus de contenu connexe, veuillez faire attention au site Web PHP chinois (www.php). .cn) !
Articles Liés
Voir plus- Comment utiliser cURL pour implémenter les requêtes Get et Post en PHP
- Comment utiliser cURL pour implémenter les requêtes Get et Post en PHP
- Comment utiliser cURL pour implémenter les requêtes Get et Post en PHP
- Comment utiliser cURL pour implémenter les requêtes Get et Post en PHP
- Tous les symboles d'expression dans les expressions régulières (résumé)