php redis緩存操作
|
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
|
<?php/** * Redis緩存操作 * @author hxm * @version 1.0 * @since 2015.05.04 */class RCache extends Object implements CacheFace { private $redis = null; //redis對象 private $sId = 1; //servier服務ID private $con = null;//鏈接資源 /** * 初始化Redis * * @return Object */ public function __construct() { if ( !class_exists('Redis') ) { throw new QException('PHP extension does not exist: Redis'); } $this->redis = new Redis(); } /** * 鏈接memcahce服務 * * @access private * @param string $key 關鍵字 * @param string $value 緩存內容 * @return array */ private function connect( $sid ) { $file = $this->CacheFile(); require $file; if(! isset($cache) ) { throw new QException('緩存配置文件不存在'.$file); } $server = $cache[$this->cacheId]; $sid = isset($sid) == 0 ? $this->sId : $sid;//memcache服務選擇 if ( ! $server[$sid]) { throw new QException('當前操作的緩存服務器配置文件不存在'); } $host = $server[$sid]['host']; $port = $server[$sid]['port']; try { $this->redis->connect( $host , $port ); } catch (Exception $e) { exit('memecache連接失敗，錯誤信息：'. $e->getMessage()); } } /** * 寫入緩存 * * @access private * @param string $key 關鍵字 * @param string $value 緩存內容 * @return array */ public function set( $key , $value , $sid , $expire = 0) { $data = $this->get($key , $sid); //如果已經存在key值 if( $data ) { return $this->redis->getset( $key , $value); } else { return $this->redis->set( $key , $value); } } /** * 讀取緩存 * * @access private * @param string $key 關鍵字 * @param int $sid 選擇第幾臺memcache服務器 * @return array */ public function get( $key , $sid) { $this->connect( $sid ); return $this->redis->get($key); } /** * 清洗（刪除）已經存儲的所有的元素 * * @access private * @return array */ public function flush() { $this->connect(); return $this->redis->flushall(); } /** * 刪除緩存 * * @access private * @param string $key 關鍵字 * @param int $sid 選擇第幾臺memcache服務器 * @return array */ public function remove( $key , $sid) { $this->connect(); return $this->redis->del($key); } /** * 析構函數 * 最后關閉memcache */ public function __destruct() { if($this->redis) { $this->redis->close(); } }} |
以上所述就是本文的全部內容了，希望大家能夠喜歡。
