当前位置：Gxlcms > PHP教程 > php操作redies封装的类

php操作redies封装的类

时间：2021-07-01 10:21:17 帮助过：23人阅读

  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<$this->_sn; ++$i){
  69. $this->_linkHandle['slave'][$i]->close();
  70. }
  71. break;
  72. // 关闭所有
  73. case 1:
  74. $this->getRedis()->close();
  75. for($i=0; $i<$this->_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 <= 1){
  211. return $this->_linkHandle['slave'][0];
  212. }
  213. // 随机 Hash 得到 Slave 的句柄
  214. $hash = $this->_hashId(mt_rand(), $this->_sn);
  215. return $this->_linkHandle['slave'][$hash];
  216. }
  218. /**
  219. * 根据ID得到 hash 后 0～m-1 之间的值
  220. *
  221. * @param string $id
  222. * @param int $m
  223. * @return int
  224. */
  225. private function _hashId($id,$m=10)
  226. {
  227. //把字符串K转换为 0～m-1 之间的一个值作为对应记录的散列地址
  228. $k = md5($id);
  229. $l = strlen($k);
  230. $b = bin2hex($k);
  231. $h = 0;
  232. for($i=0;$i<$l;$i++)
  233. {
  234. //相加模式HASH
  235. $h += substr($b,$i*2,2);
  236. }
  237. $hash = ($h*1)%$m;
  238. return $hash;
  239. }
  241. /**
  242. * lpush
  243. */
  244. public function lpush($key,$value){
  245. return $this->getRedis()->lpush($key,$value);
  246. }
  248. /**
  249. * add lpop
  250. */
  251. public function lpop($key){
  252. return $this->getRedis()->lpop($key);
  253. }
  254. /**
  255. * lrange
  256. */
  257. public function lrange($key,$start,$end){
  258. return $this->getRedis()->lrange($key,$start,$end);
  259. }
  261. /**
  262. * set hash opeation
  263. */
  264. public function hset($name,$key,$value){
  265. if(is_array($value)){
  266. return $this->getRedis()->hset($name,$key,serialize($value));
  267. }
  268. return $this->getRedis()->hset($name,$key,$value);
  269. }
  270. /**
  271. * get hash opeation
  272. */
  273. public function hget($name,$key = null,$serialize=true){
  274. if($key){
  275. $row = $this->getRedis()->hget($name,$key);
  276. if($row && $serialize){
  277. unserialize($row);
  278. }
  279. return $row;
  280. }
  281. return $this->getRedis()->hgetAll($name);
  282. }
  284. /**
  285. * delete hash opeation
  286. */
  287. public function hdel($name,$key = null){
  288. if($key){
  289. return $this->getRedis()->hdel($name,$key);
  290. }
  291. return $this->getRedis()->hdel($name);
  292. }
  293. /**
  294. * Transaction start
  295. */
  296. public function multi(){
  297. return $this->getRedis()->multi();
  298. }
  299. /**
  300. * Transaction send
  301. */
  303. public function exec(){
  304. return $this->getRedis()->exec();
  305. }
  309. }// End Class
  311. // ================= TEST DEMO =================
  313. // 只有一台 Redis 的应用
  314. $redis = new RedisCluster();
  315. $redis->connect(array('host'=>'127.0.0.1','port'=>6379));
  318. //*
  319. $cron_id = 10001;
  320. $CRON_KEY = 'CRON_LIST'; //
  321. $PHONE_KEY = 'PHONE_LIST:'.$cron_id;//
  323. //cron info
  324. $cron = $redis->hget($CRON_KEY,$cron_id);
  325. if(empty($cron)){
  327. $cron = array('id'=>10,'name'=>'jackluo');//mysql data
  328. $redis->hset($CRON_KEY,$cron_id,$cron); // set redis
  329. }
  330. //phone list
  331. $phone_list = $redis->lrange($PHONE_KEY,0,-1);
  332. print_r($phone_list);
  333. if(empty($phone_list)){
  334. $phone_list =explode(',','13228191831,18608041585'); //mysql data
  335. //join list
  336. if($phone_list){
  337. $redis->multi();
  338. foreach ($phone_list as $phone) {
  339. $redis->lpush($PHONE_KEY,$phone);
  340. }
  341. $redis->exec();
  342. }
  343. }
  345. print_r($phone_list);
  348. /*$list = $redis->hget($cron_list,);
  350. var_dump($list);*/
  351. //*/
  354. //$redis->set('id',35);
  356. /*
  357. $redis->lpush('test','1111');
  358. $redis->lpush('test','2222');
  359. $redis->lpush('test','3333');
  361. $list = $redis->lrange('test',0,-1);
  362. print_r($list);
  363. $lpop = $redis->lpop('test');
  364. print_r($lpop);
  365. $lpop = $redis->lpop('test');
  366. print_r($lpop);
  367. $lpop = $redis->lpop('test');
  368. print_r($lpop);
  369. */
  370. // var_dump($redis->get('id'));

php, redies

人气教程排行

本站所有资源全部来源于网络，若本站发布的内容侵害到您的隐私或者利益，请联系我们删除！