欢迎您访问程序员文章站本站旨在为大家提供分享程序员计算机编程知识!
您现在的位置是: 首页  >  IT编程

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

程序员文章站 2023-02-08 11:51:42
本文实例讲述了php基于redis计数器类定义与用法。分享给大家供大家参考,具体如下: redis是一个开源的使用ansi c语言编写、支持网络、可基于内存亦可持久化的日...

本文实例讲述了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 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

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

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

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