php中使用Memache作为进程锁的操作类分享

这篇文章主要介绍了PHP中使用Memache作为进程锁的操作类分享,本文直接给出类实现代码以及应用示例,需要的朋友可以参考下

<?php 
// 使用Memache 作为进程锁 
class lock_processlock{          
    // key 的前缀
    protected $sLockKeyPre;
    // 重试间隔
 protected $iLockRetryInterval;
    //重试次数
 protected $iLockRetryCount;
    //锁的过期时间
 protected $iLockCacheTimeout;
 // 锁过期后的回调函数
 protected $onLockTimeoutFunc;
    // memache 的实例
 protected $oMemcache;
    // 存储memcache失败后重试次数
 protected $iMemcacheRetryCount;     
     public function __construct ($onLockTimeoutFunc=NULL) {
  $aLockConfig = get_config('', 'lock');
  $this->sLockKeyPre = self::LOCK_KEY_PRE;
  $this->iLockRetryInterval = self::LOCK_RETRY_INTERVAL;
  $this->iLockRetryCount =self::LOCK_RETRY_COUNT;
  $this->iLockCacheTimeout = self::LOCK_CACHE_TIMEOUT;
  $this->iMemcacheRetryCount = self::LOCK_CACHE_TIMEOUT;
        if(!$onLockTimeoutFunc){
            // 如果加锁不成功则调用回调函数,如果没有回调函数,使用本类中所带的
            $onLockTimeoutFunc ='onLockTimeout' ;
        }
  $this->onLockTimeoutFunc = $onLockTimeoutFunc;
 }
     
     
    /**
    连接memcache 服务器
    */
    public function connect() {
        if (! isset ( $this->oMemcache )) {
            $this->oMemcache = new Memcache ();
            $this->oMemcache->connect ( '127.0.0.1', 11211 );
        }
        return $this->oMemcache;
    }
     
     
    /*
    向MeMcache中添加 key
    */
    public addMemcache($sKey, $sValue, $iTimeout){
         
        for($i= 0 ; $i<$this->iMemcacheRetryCount){
            $bRes = $this->oMemcache->add($sKey, $sValue, $iTimeout);
            if($bRes){
                return true ;
            }
                // 如果加锁不成功,sleep 之后,从新加锁
            usleep($this->iLockRetryInterval*1000);
             
        }
        return false ;
         
    }
     
     
    /*
    加锁
    */
    public function lock($sLockID){
         
        $oMemcache = $this->connect();
     $sKey = $this->sLockKeyPre . $sLockID;
         
        // 加锁如果不成功可以多试几次
         
        for($i = 0 ; $i <$this->iLockRetryCount ; $i++){
             
            // 这里设置value 的值可以随便设置
            if($this->addMemcache($sKey,'1',$this->iLockCacheTimeout)){
                return true ;
            }
             
            // 如果加锁不成功,sleep 之后,从新加锁
            usleep($this->iLockRetryInterval*1000);
             
        }
         
        // 若还不成功,则加锁失败,调用回调函数,.也就是失败后需要处理的操作
        if(is_callable($this->onLockTimeoutFunc)){
            // 调用函数
            call_user_func($this->onLockTimeoutFunc);
        }
         
    }
     
     
    /*
    解锁操作
    */
    public function unlock($sLockID){
         
        $oMemcache = $this->connect();
     $sKey = $this->sLockKeyPre . $sLockID;
        // 删除key
        return $this->oMemcache->DELETE($sKey);
         
    }
     
     
    /**
    如果加锁不成功,则执行如下操作
    */
     public function onLockTimeout(){
          
         echo ("加锁超时");
     }
   
}
 
 
 
// 应用实例
 
 $oLock = new lock_processlock();
 $lockResource = "test";
 // 加锁
 $oLock->lock($lockResource);
 // 解锁
 $oLock->unlock($lockResource);

更多关于php中使用Memache作为进程锁的操作类分享请关注PHP中文网（www.php.cn）其他文章！