>  기사  >  백엔드 개발  >  PHP는 redis 잠금을 사용하여 동시 액세스 클래스 예제를 제한합니다.

PHP는 redis 잠금을 사용하여 동시 액세스 클래스 예제를 제한합니다.

高洛峰
高洛峰원래의
2016-12-26 14:20:221492검색

이 글에서는 PHP에서 redis 잠금을 사용하여 동시 액세스 클래스를 제한하는 방법을 소개하고 동시 액세스 제한 방법을 자세히 소개합니다.

1. 동시 접근 제한 문제

동일한 사용자의 동시 접근을 제한해야 하는 경우, 사용자가 동시에 여러 번 요청하는 경우, 서버 프로세스에 잠금 제한이 없으면 사용자는 여러 번 성공적으로 요청할 수 있습니다.

예를 들어 쿠폰 사용 시 사용자가 동시에 사용 코드를 제출하면 동일한 사용 코드를 사용하여 잠금 제한 없이 동시에 여러 쿠폰을 사용할 수 있습니다.

의사 코드는 다음과 같습니다.

if A(상환 가능)
B(상환 실행)
C(상환됨으로 업데이트)
D(종료)

사용자가 상환 코드를 동시에 제출하면 모두 상환 가능(A)으로 판단될 수 있습니다. 왜냐하면 상환(B)을 실행해야 상환 칼라( 기음). 따라서 업데이트가 회수되기 전에 사용자가 여러 요청을 하면 해당 요청이 성공적으로 실행될 수 있습니다.

2. 동시 접근 제한 방법

파일 잠금을 사용하면 동시 접근 제한이 가능하지만, 분산 아키텍처 환경에서는 파일 잠금을 사용하면 여러 서버에 대한 동시 접근 제한을 보장할 수 없습니다.

Redis는 ANSI C 언어로 작성된 오픈소스 로그형 Key-Value 데이터베이스로, 네트워크를 지원하고, 메모리 기반 및 영속성이 있으며, 다국어로 API를 제공합니다.

이 기사에서는 setnx 메소드를 사용하여 분산 잠금 기능을 구현합니다. setnx는 존재하지 않는 것으로 설정됩니다.

키 값이 없으면 삽입 성공(잠금 획득 성공) 키 값이 이미 있으면 삽입 실패(잠금 획득 실패)

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[&#39;host&#39;],$this->_config[&#39;port&#39;],$this->_config[&#39;timeout&#39;],$this->_config[&#39;reserved&#39;],$this->_config[&#39;retry_interval&#39;]);
      if(empty($this->_config[&#39;auth&#39;])){
        $redis->auth($this->_config[&#39;auth&#39;]);
      }
      $redis->select($this->_config[&#39;index&#39;]);
    }catch(RedisException $e){
      throw new Exception($e->getMessage());
      return false;
    }
    return $redis;
  }
 
} // class end
 
?>

demo.php

<?php
require &#39;RedisLock.class.php&#39;;
 
$config = array(
  &#39;host&#39; => &#39;localhost&#39;,
  &#39;port&#39; => 6379,
  &#39;index&#39; => 0,
  &#39;auth&#39; => &#39;&#39;,
  &#39;timeout&#39; => 1,
  &#39;reserved&#39; => NULL,
  &#39;retry_interval&#39; => 100,
);
 
// 创建redislock对象
$oRedisLock = new RedisLock($config);
 
// 定义锁标识
$key = &#39;mylock&#39;;
 
// 获取锁
$is_lock = $oRedisLock->lock($key, 10);
 
if($is_lock){
  echo &#39;get lock success<br>&#39;;
  echo &#39;do sth..<br>&#39;;
  sleep(5);
  echo &#39;success<br>&#39;;
  $oRedisLock->unlock($key);
 
// 获取锁失败
}else{
  echo &#39;request too frequently<br>&#39;;
}
 
?>

테스트 방법:

두 개의 다른 브라우저를 열고 A와 B에서 동시에 데모.php에 액세스합니다.

먼저 액세스하면 잠금이 발생합니다.

출력

get lock Success
do sth..
success

다른 획득 잠금이 실패하면 너무 자주 요청하면 됩니다. 동일한 시간을 보장하기 위해

을 출력하여 한 번의 액세스만 유효하므로 동시 액세스를 효과적으로 제한합니다.

갑작스러운 시스템 오류로 인한 교착 상태를 방지하기 위해 잠금 획득 시 만료 시간을 추가하며, 만료 시간이 지나면 잠금 상태에서도 잠금이 해제되어 교착 상태로 인한 문제를 방지할 수 있습니다. .

redis 잠금을 사용하여 동시 액세스 예제를 제한하는 방법에 대한 더 많은 PHP 관련 기사를 보려면 PHP 중국어 웹사이트에 주목하세요!

성명:
본 글의 내용은 네티즌들의 자발적인 기여로 작성되었으며, 저작권은 원저작자에게 있습니다. 본 사이트는 이에 상응하는 법적 책임을 지지 않습니다. 표절이나 침해가 의심되는 콘텐츠를 발견한 경우 admin@php.cn으로 문의하세요.