PHP基于redis计数器类定义与用法示例

　　本文实例讲述了PHP基于redis计数器类定义与用法。分享给大家供大家参考，具体如下：

　　Redis是一个开源的使用ANSI C语言编写、支持网络、可基于内存亦可持久化的日志型、Key-Value数据库，并提供多种语言的API。

　　这里使用其incr(自增)，get(获取)，delete(清除)方法来实现计数器类。

　　1.Redis计数器类代码及演示实例

　　RedisCounter.class.php

　　 <?php /** * PHP基于Redis计数器类 * Date: 2017-10-28 * Author: fdipzone * Version: 1.0 * * Descripton: * php基于Redis实现自增计数，主要使用redis的incr方法，并发执行时保证计数自增唯一。 * * Func: * public incr 执行自增计数并获取自增后的数值 * public get 获取当前计数 * public reset 重置计数 * private connect 创建redis连接 */ class RedisCounter{ // class start private $_config; private $_redis; /** * 初始化 * @param Array $config redis连接设定 */ public function __construct($config){ $this->_config = $config; $this->_redis = $this->connect(); } /** * 执行自增计数并获取自增后的数值 * @param String $key 保存计数的键值 * @param Int $incr 自增数量，默认为1 * @return Int */ public function incr($key, $incr=1){ return intval($this->_redis->incr($key, $incr)); } /** * 获取当前计数 * @param String $key 保存计数的健值 * @return Int */ public function get($key){ return intval($this->_redis->get($key)); } /** * 重置计数 * @param String $key 保存计数的健值 * @return Int */ public function reset($key){ return $this->_redis->delete($key); } /** * 创建redis连接 * @return Link */ private function connect(){ try{ $redis = new Redis(); $redis->connect($this->_config[host],$this->_config[port],$this->_config[timeout],$this->_config[reserved],$this->_config[retry_interval]); if(empty($this->_config[auth])){ $redis->auth($this->_config[auth]); } $redis->select($this->_config[index]); }catch(RedisException $e){ throw new Exception($e->getMessage()); return false; } return $redis; } } // class end ?>

　　demo.php

　　 <?php Require RedisCounter.class.php; // redis连接设定 $config = array( host => localhost, port => 6379, index => 0, auth => , timeout => 1, reserved => NULL, retry_interval => 100, ); // 创建RedisCounter对象 $oRedisCounter = new RedisCounter($config); // 定义保存计数的健值 $key = mycounter; // 执行自增计数，获取当前计数，重置计数 echo $oRedisCounter->get($key).PHP_EOL; // 0 echo $oRedisCounter->incr($key).PHP_EOL; // 1 echo $oRedisCounter->incr($key, 10).PHP_EOL; // 11 echo $oRedisCounter->reset($key).PHP_EOL; // 1 echo $oRedisCounter->get($key).PHP_EOL; // 0 ?>

　　输出：

　　 0 1 11 1 0

　　2.并发调用计数器，检查计数唯一性

　　测试代码如下：

　　 <?php Require RedisCounter.class.php; // redis连接设定 $config = array( host => localhost, port => 6379, index => 0, auth => , timeout => 1, reserved => NULL, retry_interval => 100, ); // 创建RedisCounter对象 $oRedisCounter = new RedisCounter($config); // 定义保存计数的健值 $key = mytestcounter; // 执行自增计数并返回自增后的计数，记录入临时文件 file_put_contents(/tmp/mytest_result.log, $oRedisCounter->incr($key).PHP_EOL, FILE_APPEND); ?>

　　测试并发执行，我们使用ab工具进行测试，设置执行150次，15个并发。

　　 ab -c 15 -n 150

　　执行结果：

　　 ab -c 15 -n 150

　　检查计数是否唯一

　　 生成的总计数 wc -l /tmp/mytest_result.log 150 /tmp/mytest_result.log 生成的唯一计数 sort -u /tmp/mytest_result.log wc -l 150

　　可以看到在并发调用的情况下，生成的计数也保证唯一。

　　更多关于PHP相关内容感兴趣的读者可查看本站专题：《php+redis数据库程序设计技巧总结》、《php面向对象程序设计入门教程》、《PHP基本语法入门教程》、《PHP数组(Array)操作技巧大全》、《php字符串(string)用法总结》、《php+mysql数据库操作入门教程》及《php常见数据库操作技巧汇总》

　　希望本文所述对大家PHP程序设计有所帮助。