php中使用memache作为进程锁的操作类分享 这篇文章主要介绍了php中使用memache作为进程锁的操作类分享,本文直接给出类实现代码以及应用示例,需要的朋友可以参考下
?
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
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 ; $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);
// 解锁
http://www.bkjia.com/phpjc/976537.htmlwww.bkjia.comtruehttp://www.bkjia.com/phpjc/976537.htmltecharticlephp中使用memache作为进程锁的操作类分享 这篇文章主要介绍了php中使用memache作为进程锁的操作类分享,本文直接给出类实现代码以及应用示例...