这里 使用其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 http://localhost/test.php
执行结果：
ab -c 15 -n 150 http://localhost/test.php this is apachebench, version 2.3 <$revision: 1554214 $> copyright 1996 adam twiss, zeus technology ltd, http://www.zeustech.net/ licensed to the apache software foundation, http://www.apache.org/ benchmarking home.rabbit.km.com (be patient).....done server software: nginx/1.6.3 server hostname: localhost server port: 80 document path: /test.php document length: 0 bytes concurrency level: 15 time taken for tests: 0.173 seconds complete requests: 150 failed requests: 0 total transferred: 24150 bytes html transferred: 0 bytes requests per second: 864.86 [#/sec] (mean) time per request: 17.344 [ms] (mean) time per request: 1.156 [ms] (mean, across all concurrent requests) transfer rate: 135.98 [kbytes/sec] received connection times (ms) min mean[+/-sd] median max connect: 0 0 0.2 0 1 processing: 3 16 3.2 16 23 waiting: 3 16 3.2 16 23 total: 4 16 3.1 17 23 percentage of the requests served within a certain time (ms) 50% 17 66% 18 75% 18 80% 19 90% 20 95% 21 98% 22 99% 22 100% 23 (longest request)
检查计数是否唯一
生成的总计数 wc -l /tmp/mytest_result.log 150 /tmp/mytest_result.log 生成的唯一计数 sort -u /tmp/mytest_result.log | wc -l 150
可以看到在并发调用的情况下，生成的计数也保证唯一。
相关推荐：
redis计数器防止刷单方法介绍
以上就是redis计数器类定义与用法的详细内容。