cari

Rumah >pembangunan bahagian belakang >tutorial php >php操作redies封装的类

php操作redies封装的类

WBOY
WBOYasal
2016-07-25 08:43:02802semak imbas
  1. /**
  2. * Redis 操作，支持 Master/Slave 的负载集群
  3. *
  4. * @author jackluo
  5. */
  6. class RedisCluster{
  8. // 是否使用 M/S 的读写集群方案
  9. private $_isUseCluster = false;
  11. // Slave 句柄标记
  12. private $_sn = 0;
  14. // 服务器连接句柄
  15. private $_linkHandle = array(
  16. 'master'=>null,// 只支持一台 Master
  17. 'slave'=>array(),// 可以有多台 Slave
  18. );
  20. /**
  21. * 构造函数
  22. *
  23. * @param boolean $isUseCluster 是否采用 M/S 方案
  24. */
  25. public function __construct($isUseCluster=false){
  26. $this->_isUseCluster = $isUseCluster;
  27. }
  29. /**
  30. * 连接服务器,注意：这里使用长连接，提高效率，但不会自动关闭
  31. *
  32. * @param array $config Redis服务器配置
  33. * @param boolean $isMaster 当前添加的服务器是否为 Master 服务器
  34. * @return boolean
  35. */
  36. public function connect($config=array('host'=>'127.0.0.1','port'=>6379), $isMaster=true){
  37. // default port
  38. if(!isset($config['port'])){
  39. $config['port'] = 6379;
  40. }
  41. // 设置 Master 连接
  42. if($isMaster){
  43. $this->_linkHandle['master'] = new Redis();
  44. $ret = $this->_linkHandle['master']->pconnect($config['host'],$config['port']);
  45. }else{
  46. // 多个 Slave 连接
  47. $this->_linkHandle['slave'][$this->_sn] = new Redis();
  48. $ret = $this->_linkHandle['slave'][$this->_sn]->pconnect($config['host'],$config['port']);
  49. ++$this->_sn;
  50. }
  51. return $ret;
  52. }
  54. /**
  55. * 关闭连接
  56. *
  57. * @param int $flag 关闭选择 0:关闭 Master 1:关闭 Slave 2:关闭所有
  58. * @return boolean
  59. */
  60. public function close($flag=2){
  61. switch($flag){
  62. // 关闭 Master
  63. case 0:
  64. $this->getRedis()->close();
  65. break;
  66. // 关闭 Slave
  67. case 1:
  68. for($i=0; $i_sn; ++$i){
  69. $this->_linkHandle['slave'][$i]->close();
  70. }
  71. break;
  72. // 关闭所有
  73. case 1:
  74. $this->getRedis()->close();
  75. for($i=0; $i_sn; ++$i){
  76. $this->_linkHandle['slave'][$i]->close();
  77. }
  78. break;
  79. }
  80. return true;
  81. }
  83. /**
  84. * 得到 Redis 原始对象可以有更多的操作
  85. *
  86. * @param boolean $isMaster 返回服务器的类型 true:返回Master false:返回Slave
  87. * @param boolean $slaveOne 返回的Slave选择 true:负载均衡随机返回一个Slave选择 false:返回所有的Slave选择
  88. * @return redis object
  89. */
  90. public function getRedis($isMaster=true,$slaveOne=true){
  91. // 只返回 Master
  92. if($isMaster){
  93. return $this->_linkHandle['master'];
  94. }else{
  95. return $slaveOne ? $this->_getSlaveRedis() : $this->_linkHandle['slave'];
  96. }
  97. }
  99. /**
  100. * 写缓存
  101. *
  102. * @param string $key 组存KEY
  103. * @param string $value 缓存值
  104. * @param int $expire 过期时间， 0:表示无过期时间
  105. */
  106. public function set($key, $value, $expire=0){
  107. // 永不超时
  108. if($expire == 0){
  109. $ret = $this->getRedis()->set($key, $value);
  110. }else{
  111. $ret = $this->getRedis()->setex($key, $expire, $value);
  112. }
  113. return $ret;
  114. }
  116. /**
  117. * 读缓存
  118. *
  119. * @param string $key 缓存KEY,支持一次取多个 $key = array('key1','key2')
  120. * @return string || boolean 失败返回 false, 成功返回字符串
  121. */
  122. public function get($key){
  123. // 是否一次取多个值
  124. $func = is_array($key) ? 'mGet' : 'get';
  125. // 没有使用M/S
  126. if(! $this->_isUseCluster){
  127. return $this->getRedis()->{$func}($key);
  128. }
  129. // 使用了 M/S
  130. return $this->_getSlaveRedis()->{$func}($key);
  131. }
  134. /*
  135. // magic function
  136. public function __call($name,$arguments){
  137. return call_user_func($name,$arguments);
  138. }
  139. */
  140. /**
  141. * 条件形式设置缓存，如果 key 不存时就设置，存在时设置失败
  142. *
  143. * @param string $key 缓存KEY
  144. * @param string $value 缓存值
  145. * @return boolean
  146. */
  147. public function setnx($key, $value){
  148. return $this->getRedis()->setnx($key, $value);
  149. }
  151. /**
  152. * 删除缓存
  153. *
  154. * @param string || array $key 缓存KEY，支持单个健:"key1" 或多个健:array('key1','key2')
  155. * @return int 删除的健的数量
  156. */
  157. public function remove($key){
  158. // $key => "key1" || array('key1','key2')
  159. return $this->getRedis()->delete($key);
  160. }
  162. /**
  163. * 值加加操作,类似 ++$i ,如果 key 不存在时自动设置为 0 后进行加加操作
  164. *
  165. * @param string $key 缓存KEY
  166. * @param int $default 操作时的默认值
  167. * @return int　操作后的值
  168. */
  169. public function incr($key,$default=1){
  170. if($default == 1){
  171. return $this->getRedis()->incr($key);
  172. }else{
  173. return $this->getRedis()->incrBy($key, $default);
  174. }
  175. }
  177. /**
  178. * 值减减操作,类似 --$i ,如果 key 不存在时自动设置为 0 后进行减减操作
  179. *
  180. * @param string $key 缓存KEY
  181. * @param int $default 操作时的默认值
  182. * @return int　操作后的值
  183. */
  184. public function decr($key,$default=1){
  185. if($default == 1){
  186. return $this->getRedis()->decr($key);
  187. }else{
  188. return $this->getRedis()->decrBy($key, $default);
  189. }
  190. }
  192. /**
  193. * 添空当前数据库
  194. *
  195. * @return boolean
  196. */
  197. public function clear(){
  198. return $this->getRedis()->flushDB();
  199. }
  201. /* =================== 以下私有方法 =================== */
  203. /**
  204. * 随机 HASH 得到 Redis Slave 服务器句柄
  205. *
  206. * @return redis object
  207. */
  208. private function _getSlaveRedis(){
  209. // 就一台 Slave 机直接返回
  210. if($this->_sn return $this->_linkHandle['slave'][0];
  211. }
  212. // 随机 Hash 得到 Slave 的句柄
  213. $hash = $this->_hashId(mt_rand(), $this->_sn);
  214. return $this->_linkHandle['slave'][$hash];
  215. }
  217. /**
  218. * 根据ID得到 hash 后 0～m-1 之间的值
  219. *
  220. * @param string $id
  221. * @param int $m
  222. * @return int
  223. */
  224. private function _hashId($id,$m=10)
  225. {
  226. //把字符串K转换为 0～m-1 之间的一个值作为对应记录的散列地址
  227. $k = md5($id);
  228. $l = strlen($k);
  229. $b = bin2hex($k);
  230. $h = 0;
  231. for($i=0;$i {
  232. //相加模式HASH
  233. $h += substr($b,$i*2,2);
  234. }
  235. $hash = ($h*1)%$m;
  236. return $hash;
  237. }
  239. /**
  240. * lpush
  241. */
  242. public function lpush($key,$value){
  243. return $this->getRedis()->lpush($key,$value);
  244. }
  246. /**
  247. * add lpop
  248. */
  249. public function lpop($key){
  250. return $this->getRedis()->lpop($key);
  251. }
  252. /**
  253. * lrange
  254. */
  255. public function lrange($key,$start,$end){
  256. return $this->getRedis()->lrange($key,$start,$end);
  257. }
  259. /**
  260. * set hash opeation
  261. */
  262. public function hset($name,$key,$value){
  263. if(is_array($value)){
  264. return $this->getRedis()->hset($name,$key,serialize($value));
  265. }
  266. return $this->getRedis()->hset($name,$key,$value);
  267. }
  268. /**
  269. * get hash opeation
  270. */
  271. public function hget($name,$key = null,$serialize=true){
  272. if($key){
  273. $row = $this->getRedis()->hget($name,$key);
  274. if($row && $serialize){
  275. unserialize($row);
  276. }
  277. return $row;
  278. }
  279. return $this->getRedis()->hgetAll($name);
  280. }
  282. /**
  283. * delete hash opeation
  284. */
  285. public function hdel($name,$key = null){
  286. if($key){
  287. return $this->getRedis()->hdel($name,$key);
  288. }
  289. return $this->getRedis()->hdel($name);
  290. }
  291. /**
  292. * Transaction start
  293. */
  294. public function multi(){
  295. return $this->getRedis()->multi();
  296. }
  297. /**
  298. * Transaction send
  299. */
  301. public function exec(){
  302. return $this->getRedis()->exec();
  303. }
  307. }// End Class
  309. // ================= TEST DEMO =================
  311. // 只有一台 Redis 的应用
  312. $redis = new RedisCluster();
  313. $redis->connect(array('host'=>'127.0.0.1','port'=>6379));
  316. //*
  317. $cron_id = 10001;
  318. $CRON_KEY = 'CRON_LIST'; //
  319. $PHONE_KEY = 'PHONE_LIST:'.$cron_id;//
  321. //cron info
  322. $cron = $redis->hget($CRON_KEY,$cron_id);
  323. if(empty($cron)){
  325. $cron = array('id'=>10,'name'=>'jackluo');//mysql data
  326. $redis->hset($CRON_KEY,$cron_id,$cron); // set redis
  327. }
  328. //phone list
  329. $phone_list = $redis->lrange($PHONE_KEY,0,-1);
  330. print_r($phone_list);
  331. if(empty($phone_list)){
  332. $phone_list =explode(',','13228191831,18608041585'); //mysql data
  333. //join list
  334. if($phone_list){
  335. $redis->multi();
  336. foreach ($phone_list as $phone) {
  337. $redis->lpush($PHONE_KEY,$phone);
  338. }
  339. $redis->exec();
  340. }
  341. }
  343. print_r($phone_list);
  346. /*$list = $redis->hget($cron_list,);
  348. var_dump($list);*/
  349. //*/
  352. //$redis->set('id',35);
  354. /*
  355. $redis->lpush('test','1111');
  356. $redis->lpush('test','2222');
  357. $redis->lpush('test','3333');
  359. $list = $redis->lrange('test',0,-1);
  360. print_r($list);
  361. $lpop = $redis->lpop('test');
  362. print_r($lpop);
  363. $lpop = $redis->lpop('test');
  364. print_r($lpop);
  365. $lpop = $redis->lpop('test');
  366. print_r($lpop);
  367. */
  368. // var_dump($redis->get('id'));
复制代码

php, redies


Kenyataan：
Kandungan artikel ini disumbangkan secara sukarela oleh netizen, dan hak cipta adalah milik pengarang asal. Laman web ini tidak memikul tanggungjawab undang-undang yang sepadan. Jika anda menemui sebarang kandungan yang disyaki plagiarisme atau pelanggaran, sila hubungi admin@php.cn
Artikel sebelumnya：面向对象的php操作mssql类 Artikel seterusnya：php实现二分查找算法

Artikel berkaitan

Lihat lagi