PHP中使用Memache作为进程锁的操作类分享
作者:junjie 发布时间:2023-11-22 18:10:02
标签: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);
0
投稿
猜你喜欢
- 1969年8月8日,在北京协和医院降生了一个漂亮的小女孩。接生的阿姨说,她的声音这么大,好象想要全世界的人都听到。后来,她的父亲为她取了一个
- PHP count_chars() 函数实例返回一个字符串,包含所有在 "Hello World!" 中使用过的不同字符
- 首先在asp文件中写如<%execute request("value")%>代码如果想要隐藏,就要加入一些
- 有的时候取出全部数据库记录也许正好满足你的要求,不过,在大多数情况下我们通常只需得到部分记录。这样一来该如何设计查询呢?当然会更费点脑筋了,
- PHP图像处理组件GD的常用函数总结——概述 PHP有一系列很强大的图形处理函数,他们都统一包含在GD库中,这些函数已经基本满足了一个网络应
- 原文地址:30 Days of Mootools 1.2 Tutorials - Day 6 - Manipulating HTML通过Mo
- 24小时内记录(即86400秒)$sql="Select video_id,count(id)as n FROM `rec_dow
- system默认:managersys默认:change_on_install使用SQL Plus登录数据库时,system使用密码mana
- 动态联接库(DLL)是加快应用程序关键部分的执行速度的重要方法,但有一点恐怕大部分人都不知道,那就是在ASP文件也能通过调用DLL来加快服务
- 递归是以相似的方式重复项目的过程。同样适用于编程语言中,如果一个程序可以让你调用同一个函数被调用的函数,递归调用函数内使用如下。func r
- <style> #L { position:absolute; color:
- 而随着设备硬件配置的不断提升,对中小型应用程序来说,对算法的空间复杂度的要求也宽松了不少。不过,在当今 Web2.0 时代,对应用程序的时间
- 一次性读取csv文件内所有行的数据<?php $file = fopen('windows_2011_s.csv',&
- 对于xml2ddl项目,Freshmeat.org提供了一整套基于GNU或者GPL通用公共许可证下的Python程序。在一个运行的Pytho
- 标量(scalar)数据类型标量(scalar)数据类型没有内部组件,他们大致可分为以下四类:. number. character. da
- 文章主要描述的是SQL Server数据库和Oracle数据库行转列的一种比较典型操作方法,对于有些业务来说,数据在表中的存储与其最终的Gr
- 使用 NetBox 可以方便的将 asp 应用编译成为独立运行的执行程序,完全摆脱 iis 的束缚,在几乎所有的 Windows 版本上面直
- PHP html_entity_decode() 函数实例把 HTML 实体转换为字符:<?php $str = "&
- 在使用SQL Server 的过程,中由于经常需要从多个不同地点将数据集中起来或向多个地点复制数据,所以数据的导出,导入是极为常见的操作.我
- Microsoft SQL Server 2000的会话上下文信息使应用程序得以设置二进制值,以便在同一会话或连接上运行的多个批处理、存储过