国产av日韩一区二区三区精品,成人性爱视频在线观看,国产,欧美,日韩,一区,www.成色av久久成人,2222eeee成人天堂

Home Backend Development PHP Tutorial PHP operates the class encapsulated by redies

PHP operates the class encapsulated by redies

Jul 25, 2016 am 08:43 AM
  1. /**
  2. * Redis operation, supporting Master/Slave load cluster
  3. *
  4. * @author jackluo
  5. */
  6. class RedisCluster{
  8. // Whether to use the M/S read-write cluster solution
  9. private $_isUseCluster = false;
  11. // Slave handle tag
  12. private $_sn = 0;
  14. // Server connection handle
  15. private $_linkHandle = array(
  16. 'master'=>null,// Only supports one Master
  17. 'slave'=>array(),// Yes There are multiple Slave
  18. );
  20. /**
  21. * Constructor
  22. *
  23. * @param boolean $isUseCluster Whether to use the M/S scheme
  24. */
  25. public function __construct($isUseCluster=false){
  26. $this->_isUseCluster = $isUseCluster;
  27. }
  29. /**
  30. * Connect to the server, note: long connections are used here to improve efficiency, but will not automatically close
  31. *
  32. * @param array $config Redis server configuration
  33. * @param boolean $isMaster Whether the currently added server is a Master server
  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. // Set Master connection
  42. if($isMaster){
  43. $this->_linkHandle['master'] = new Redis ();
  44. $ret = $this->_linkHandle['master']->pconnect($config['host'],$config['port']);
  45. }else{
  46. // Multiple Slave Connection
  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. * Close connection
  56. *
  57. * @param int $flag Close selection 0: Close Master 1: Close Slave 2: Close all
  58. * @return boolean
  59. * /
  60. public function close($flag=2){
  61. switch($flag){
  62. // Close Master
  63. case 0:
  64. $this->getRedis()->close();
  65. break;
  66. // Close Slave
  67. case 1:
  68. for($i=0; $i<$this->_sn; ++$i){
  69. $this->_linkHandle['slave'][$i]->close ();
  70. }
  71. break;
  72. // Close all
  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. * Get the original Redis object to have more operations
  85. *
  86. * @param boolean $isMaster Returns the type of server true: Returns Master false: Returns Slave
  87. * @param boolean $slaveOne Returns Slave selection true: Load balancing returns randomly A Slave selection false: Return all Slave selections
  88. * @return redis object
  89. */
  90. public function getRedis($isMaster=true,$slaveOne=true){
  91. // Only return Master
  92. if($isMaster){
  93. return $this->_linkHandle['master'];
  94. }else{
  95. return $slaveOne ? $this->_getSlaveRedis() : $this->_linkHandle['slave'];
  96. }
  97. }
  99. /**
  100. * Write cache
  101. *
  102. * @param string $key group storage KEY
  103. * @param string $value cache value
  104. * @param int $expire expiration time, 0: means no expiration time
  105. */
  106. public function set($key, $value , $expire=0){
  107. // Never timeout
  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. * Read cache
  118. *
  119. * @param string $key Cache KEY, support fetching multiple $keys at one time = array('key1','key2')
  120. * @return string || boolean Return false on failure, return string on success
  121. */
  122. public function get($key){
  123. // Whether to get multiple values ??at once
  124. $func = is_array($key) ? 'mGet' : 'get';
  125. // No M/S is used
  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. * Conditional form to set the cache. If the key does not exist, it will be set. If it exists, the setting will fail.
  142. *
  143. * @param string $key cache KEY
  144. * @param string $value cache value
  145. * @return boolean
  146. */
  147. public function setnx($key, $value){
  148. return $this->getRedis()->setnx($key, $value);
  149. }
  151. /**
  152. * Delete cache
  153. *
  154. * @param string || array $key cache KEY, supports single key: "key1" or multiple keys: array('key1','key2')
  155. * @return int deleted key Quantity
  156. */
  157. public function remove($key){
  158. // $key => "key1" || array('key1','key2')
  159. return $this->getRedis()->delete($key);
  160. }
  162. /**
  163. * Value addition operation, similar to ++$i, if the key does not exist, it is automatically set to 0 and then the addition operation is performed
  164. *
  165. * @param string $key Cache KEY
  166. * @param int $default The default value during operation
  167. * @return int　Value after operation
  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. * Value subtraction operation, similar to --$i, if the key does not exist, it will be automatically set to 0 and then subtracted.
  179. *
  180. * @param string $key Cache KEY
  181. * @param int $default Default value during operation
  182. * @return int　Value after operation
  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. * Empty the current database
  194. *
  195. * @return boolean
  196. */
  197. public function clear(){
  198. return $this->getRedis()->flushDB();
  199. }
  201. /* =================== 以下私有方法 =================== */
  203. /**
  204. * Random HASH to get the Redis Slave server handle
  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. * Get the value between 0～m-1 after hashing based on ID
  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


Statement of this Website
The content of this article is voluntarily contributed by netizens, and the copyright belongs to the original author. This site does not assume corresponding legal responsibility. If you find any content suspected of plagiarism or infringement, please contact admin@php.cn

Hot AI Tools

Undress AI Tool

Undress AI Tool

Undress images for free

Undresser.AI Undress

Undresser.AI Undress

AI-powered app for creating realistic nude photos

AI Clothes Remover

AI Clothes Remover

Online AI tool for removing clothes from photos.

Clothoff.io

Clothoff.io

AI clothes remover

Video Face Swap

Video Face Swap

Swap faces in any video effortlessly with our completely free AI face swap tool!

Hot Tools

Notepad++7.3.1

Notepad++7.3.1

Easy-to-use and free code editor

SublimeText3 Chinese version

SublimeText3 Chinese version

Chinese version, very easy to use

Zend Studio 13.0.1

Zend Studio 13.0.1

Powerful PHP integrated development environment

Dreamweaver CS6

Dreamweaver CS6

Visual web development tools

SublimeText3 Mac version

SublimeText3 Mac version

God-level code editing software (SublimeText3)

How do I implement authentication and authorization in PHP? How do I implement authentication and authorization in PHP? Jun 20, 2025 am 01:03 AM

TosecurelyhandleauthenticationandauthorizationinPHP,followthesesteps:1.Alwayshashpasswordswithpassword_hash()andverifyusingpassword_verify(),usepreparedstatementstopreventSQLinjection,andstoreuserdatain$_SESSIONafterlogin.2.Implementrole-basedaccessc

How can you handle file uploads securely in PHP? How can you handle file uploads securely in PHP? Jun 19, 2025 am 01:05 AM

To safely handle file uploads in PHP, the core is to verify file types, rename files, and restrict permissions. 1. Use finfo_file() to check the real MIME type, and only specific types such as image/jpeg are allowed; 2. Use uniqid() to generate random file names and store them in non-Web root directory; 3. Limit file size through php.ini and HTML forms, and set directory permissions to 0755; 4. Use ClamAV to scan malware to enhance security. These steps effectively prevent security vulnerabilities and ensure that the file upload process is safe and reliable.

What are the differences between == (loose comparison) and === (strict comparison) in PHP? What are the differences between == (loose comparison) and === (strict comparison) in PHP? Jun 19, 2025 am 01:07 AM

In PHP, the main difference between == and == is the strictness of type checking. ==Type conversion will be performed before comparison, for example, 5=="5" returns true, and ===Request that the value and type are the same before true will be returned, for example, 5==="5" returns false. In usage scenarios, === is more secure and should be used first, and == is only used when type conversion is required.

How do I perform arithmetic operations in PHP ( , -, *, /, %)? How do I perform arithmetic operations in PHP ( , -, *, /, %)? Jun 19, 2025 pm 05:13 PM

The methods of using basic mathematical operations in PHP are as follows: 1. Addition signs support integers and floating-point numbers, and can also be used for variables. String numbers will be automatically converted but not recommended to dependencies; 2. Subtraction signs use - signs, variables are the same, and type conversion is also applicable; 3. Multiplication signs use * signs, which are suitable for numbers and similar strings; 4. Division uses / signs, which need to avoid dividing by zero, and note that the result may be floating-point numbers; 5. Taking the modulus signs can be used to judge odd and even numbers, and when processing negative numbers, the remainder signs are consistent with the dividend. The key to using these operators correctly is to ensure that the data types are clear and the boundary situation is handled well.

How can you interact with NoSQL databases (e.g., MongoDB, Redis) from PHP? How can you interact with NoSQL databases (e.g., MongoDB, Redis) from PHP? Jun 19, 2025 am 01:07 AM

Yes, PHP can interact with NoSQL databases like MongoDB and Redis through specific extensions or libraries. First, use the MongoDBPHP driver (installed through PECL or Composer) to create client instances and operate databases and collections, supporting insertion, query, aggregation and other operations; second, use the Predis library or phpredis extension to connect to Redis, perform key-value settings and acquisitions, and recommend phpredis for high-performance scenarios, while Predis is convenient for rapid deployment; both are suitable for production environments and are well-documented.

How do I stay up-to-date with the latest PHP developments and best practices? How do I stay up-to-date with the latest PHP developments and best practices? Jun 23, 2025 am 12:56 AM

TostaycurrentwithPHPdevelopmentsandbestpractices,followkeynewssourceslikePHP.netandPHPWeekly,engagewithcommunitiesonforumsandconferences,keeptoolingupdatedandgraduallyadoptnewfeatures,andreadorcontributetoopensourceprojects.First,followreliablesource

What is PHP, and why is it used for web development? What is PHP, and why is it used for web development? Jun 23, 2025 am 12:55 AM

PHPbecamepopularforwebdevelopmentduetoitseaseoflearning,seamlessintegrationwithHTML,widespreadhostingsupport,andalargeecosystemincludingframeworkslikeLaravelandCMSplatformslikeWordPress.Itexcelsinhandlingformsubmissions,managingusersessions,interacti

How to set PHP time zone? How to set PHP time zone? Jun 25, 2025 am 01:00 AM

TosettherighttimezoneinPHP,usedate_default_timezone_set()functionatthestartofyourscriptwithavalididentifiersuchas'America/New_York'.1.Usedate_default_timezone_set()beforeanydate/timefunctions.2.Alternatively,configurethephp.inifilebysettingdate.timez

See all articles