时时商务社区

标题: PHP中使用Memache作为进程锁的操作类分享 [打印本页]

作者: qz234 时间: 2018-2-14 05:47

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

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

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

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

欢迎光临时时商务社区 (http://bbs.4435.cn/)