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

            
sLockKeyPre = self:OCK_KEY_PRE;
  $this->iLockRetryInterval = self:OCK_RETRY_INTERVAL;
  $this->iLockRetryCount =self:OCK_RETRY_COUNT;
  $this->iLockCacheTimeout = self:OCK_CACHE_TIMEOUT;
  $this->iMemcacheRetryCount = self:OCK_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 ; $iiMemcacheRetryCount){
                        $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 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 多进程 解决难题

PHP 进程锁定问题分析研究

phplock(php进程锁) v1.0 beta1

Linux下实现PHP多进程的方法分享

解析PHP实现多进程并行执行脚本

深入解析PHP中的(伪)多线程与多进程

PHP多进程编程实例

PHP使用pcntl_fork实现多进程下载图片的方法

深入探究PHP的多进程编程方法

php中实现进程锁与多进程的方法