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

1. <?php 
2.  
3. // 使用Memache 作为进程锁  
4.  
5. class lock_processlock{ 
6.       
7.       
8.     // key 的前缀 
9.     protected $sLockKeyPre; 
10.     // 重试间隔 
11.  protected $iLockRetryInterval; 
12.     //重试次数  
13.  protected $iLockRetryCount; 
14.     //锁的过期时间 
15.  protected $iLockCacheTimeout; 
16.  // 锁过期后的回调函数 
17.  protected $onLockTimeoutFunc; 
18.     // memache 的实例 
19.  protected $oMemcache; 
20.     // 存储memcache失败后重试次数  
21.  protected $iMemcacheRetryCount; 
22.       
23.       
24.       
25.       
26.      public function __construct ($onLockTimeoutFunc=NULL) { 
27.   $aLockConfig = get_config('', 'lock'); 
28.   $this->sLockKeyPre = self::LOCK_KEY_PRE; 
29.   $this->iLockRetryInterval = self::LOCK_RETRY_INTERVAL; 
30.   $this->iLockRetryCount =self::LOCK_RETRY_COUNT; 
31.   $this->iLockCacheTimeout = self::LOCK_CACHE_TIMEOUT; 
32.   $this->iMemcacheRetryCount = self::LOCK_CACHE_TIMEOUT; 
33.         if(!$onLockTimeoutFunc){ 
34.             // 如果加锁不成功则调用回调函数,如果没有回调函数,使用本类中所带的  
35.             $onLockTimeoutFunc ='onLockTimeout' ;  
36.         } 
37.   $this->onLockTimeoutFunc = $onLockTimeoutFunc; 
38.  } 
39.       
40.       
41.     /** 
42.     连接memcache 服务器  
43.     */ 
44.     public function connect() { 
45.         if (! isset ( $this->oMemcache )) { 
46.             $this->oMemcache = new Memcache (); 
47.             $this->oMemcache->connect ( '127.0.0.1', 11211 ); 
48.         } 
49.         return $this->oMemcache; 
50.     } 
51.       
52.       
53.     /* 
54.     向MeMcache中添加 key 
55.     */ 
56.     public addMemcache($sKey, $sValue, $iTimeout){ 
57.           
58.         for($i= 0 ; $i<$this->iMemcacheRetryCount){ 
59.             $bRes = $this->oMemcache->add($sKey, $sValue, $iTimeout); 
60.             if($bRes){ 
61.                 return true ;  
62.             } 
63.                 // 如果加锁不成功,sleep 之后,从新加锁 
64.             usleep($this->iLockRetryInterval*1000); 
65.               
66.         } 
67.         return false ;  
68.           
69.     } 
70.       
71.       
72.     /* 
73.     加锁  
74.     */ 
75.     public function lock($sLockID){ 
76.           
77.         $oMemcache = $this->connect(); 
78.      $sKey = $this->sLockKeyPre . $sLockID; 
79.           
80.         // 加锁如果不成功可以多试几次  
81.           
82.         for($i = 0 ; $i <$this->iLockRetryCount ; $i++){ 
83.               
84.             // 这里设置value 的值可以随便设置  
85.             if($this->addMemcache($sKey,'1',$this->iLockCacheTimeout)){ 
86.                 return true ;  
87.             } 
88.               
89.             // 如果加锁不成功,sleep 之后,从新加锁 
90.             usleep($this->iLockRetryInterval*1000); 
91.               
92.         } 
93.           
94.         // 若还不成功,则加锁失败,调用回调函数,.也就是失败后需要处理的操作  
95.         if(is_callable($this->onLockTimeoutFunc)){ 
96.             // 调用函数  
97.             call_user_func($this->onLockTimeoutFunc);  
98.         } 
99.           
100.     } 
101.       
102.       
103.     /* 
104.     解锁操作  
105.     */ 
106.     public function unlock($sLockID){ 
107.           
108.         $oMemcache = $this->connect(); 
109.      $sKey = $this->sLockKeyPre . $sLockID; 
110.         // 删除key 
111.         return $this->oMemcache->delete($sKey); 
112.           
113.     } 
114.       
115.       
116.     /** 
117.     如果加锁不成功,则执行如下操作  
118.     */ 
119.      public function onLockTimeout(){ 
120.            
121.          echo ("加锁超时"); 
122.      } 
123.     
124. } 
125.  
126.  
127.  
128. // 应用实例  
129.  
130.  $oLock = new lock_processlock(); 
131.  $lockResource = "test"; 
132.  // 加锁 
133.  $oLock->lock($lockResource); 
134.  // 解锁 
135.  $oLock->unlock($lockResource);

Tags: Memache PHP进程锁

分享到：