您的位置:首页 > 教程 > PHP编程 > PHP使用redis位图bitMap 实现签到功能

PHP使用redis位图bitMap 实现签到功能

2020-09-05 11:10:38 来源:易采站长站 作者:

PHP使用redis位图bitMap 实现签到功能,用户,位图,方案,数据,操作

PHP使用redis位图bitMap 实现签到功能

易采站长站,站长之家为您整理了PHP使用redis位图bitMap 实现签到功能的相关内容。

一、需求

记录用户签到,查询用户签到

二、技术方案

1、使用mysql(max_time字段为连续签到天数)

 

思路:

(1)用户签到,插入一条记录,根据create_time查询昨日是否签到,有签到则max_time在原基础+1,否则,max_time=0

(2)检测签到,根据user_id、create_time查询记录是否存在,不存在则表示未签到

2、使用redis位图功能

思路:

(1)每个用户每个月单独一条redis记录,如00101010101010,从左往右代表01-31天(每月有几天,就到几天)
(2)每月8号凌晨,统一将redis的记录,搬至mysql,记录如图

 

(3)查询当月,从redis查,上月则从mysql获取

3、方案对比

举例:一万个用户签到365天

方案1、mysql 插入365万条记录

· 频繁请求数据库做一些日志记录浪费服务器开销。
·  随着时间推移数据急剧增大
· 海量数据检索效率也不高,同时只能用时间create_time作为区间查询条件,数据量大肯定慢

方案2、mysql 插入12w条记录

· 节省空间,每个用户每天只占用1bit空间 1w个用户每天产生10000bit=1050byte 大概为1kb的数据
· 内存操作存度快

3、实现(方案2)

(1)key结构

前缀_年份_月份:用户id -- sign_2019_10:01

查询:

单个:keys sign_2019_10_01

全部:keys sign_*

月份:keys sign_2019_10:*

(2)mysql表结构

 

(3)代码(列出1个调用方法,与三个类)

·签到方法

public static function userSignIn($userId)  {    $time = Time();    $today = date('d', $time);    $year = date('Y', $time);    $month = date('m', $time);    $signModel = new Sign($userId,$year,$month);    //1、查询用户今日签到信息    $todaySign = $signModel->getSignLog($today);    if ($todaySign) {      return self::jsonArr(-1, '您已经签到过了', []);    }    try {      Db::startTrans();      $signModel->setSignLog($today);      //4、赠送积分      if (self::SING_IN_SCORE > 0) {        $dataScore['order_id'] = $userId.'_'.$today;        $dataScore['type'] = 2;//2、签到        $dataScore['remark'] = '签到获得积分';        Finance::updateUserScore(Finance::OPT_ADD, $userId, self::SING_IN_SCORE, $dataScore);      }      $code = '0';      $msg = '签到成功';      $score = self::SING_IN_SCORE;      Db::commit();    } catch (\Exception $e) {      Db::rollback();      $code = '-2';      $msg = '签到失败';      $score = 0;    }    return self::jsonArr($code, $msg, ['score' => $score]);  }

·redis基类

<?phpnamespace app\common\redis\db1;/** * redis操作类 */class RedisAbstract{  /**   * 连接的库   * @var int   */  protected $_db = 1;//数据库名  protected $_tableName = '';//表名  static $redis = null;  public function __construct()  {    return $this->getRedis();  }  public function _calcKey($id)  {    return $this->_tableName . $id;  }  /**   * 查找key   * @param $key   * @return array   * @throws \Exception   * @author wenzhen-chen   */  public function keys($key)  {    return $this->getRedis()->keys($this->_calcKey($key));  }  /**   * 获取是否开启缓存的设置参数   *   * @return boolean   */  public function _getEnable()  {    $conf = Config('redis');    return $conf['enable'];  }  /**   * 获取redis连接   *   * @staticvar null $redis   * @return \Redis   * @throws \Exception   */  public function getRedis()  {    if (!self::$redis) {      $conf = Config('redis');      if (!$conf) {        throw new \Exception('redis连接必须设置');      }      self::$redis = new \Redis();      self::$redis->connect($conf['host'], $conf['port']);      self::$redis->select($this->_db);    }    return self::$redis;  }  /**   * 设置位图   * @param $key   * @param $offset   * @param $value   * @param int $time   * @return int|null   * @throws \Exception   * @author wenzhen-chen   */  public function setBit($key, $offset, $value, $time = 0)  {    if (!$this->_getEnable()) {      return null;    }    $result = $this->getRedis()->setBit($key, $offset, $value);    if ($time) {      $this->getRedis()->expire($key, $time);    }    return $result;  }  /**   * 获取位图   * @param $key   * @param $offset   * @return int|null   * @throws \Exception   * @author wenzhen-chen   */  public function getBit($key, $offset)  {    if (!$this->_getEnable()) {      return null;    }    return $this->getRedis()->getBit($key, $offset);  }  /**   * 统计位图   * @param $key   * @return int|null   * @throws \Exception   * @author wenzhen-chen   */  public function bitCount($key)  {    if (!$this->_getEnable()) {      return null;    }    return $this->getRedis()->bitCount($key);  }  /**   * 位图操作   * @param $operation   * @param $retKey   * @param mixed ...$key   * @return int|null   * @throws \Exception   * @author wenzhen-chen   */  public function bitOp($operation, $retKey, ...$key)  {    if (!$this->_getEnable()) {      return null;    }    return $this->getRedis()->bitOp($operation, $retKey, $key);  }  /**   * 计算在某段位图中 1或0第一次出现的位置   * @param $key   * @param $bit 1/0   * @param $start   * @param null $end   * @return int|null   * @throws \Exception   * @author wenzhen-chen   */  public function bitPos($key, $bit, $start, $end = null)  {    if (!$this->_getEnable()) {      return null;    }    return $this->getRedis()->bitpos($key, $bit, $start, $end);  }  /**   * 删除数据   * @param $key   * @return int|null   * @throws \Exception   * @author wenzhen-chen   */  public function del($key)  {    if (!$this->_getEnable()) {      return null;    }    return $this->getRedis()->del($key);  }}

·签到redis操作类

<?php/** * Created by PhpStorm. * User: Administrator * Date: 2019/9/30 * Time: 14:42 */namespace app\common\redis\db1;class Sign extends RedisAbstract{  public $keySign = 'sign';//签到记录key  public function __construct($userId,$year,$month)  {    parent::__construct();    //设置当前用户 签到记录的key    $this->keySign = $this->keySign . '_' . $year . '_' . $month . ':' . $userId;  }  /**   * 用户签到   * @param $day   * @return int|null   * @throws \Exception   * @author wenzhen-chen   */  public function setSignLog($day)  {    return $this->setBit($this->keySign, $day, 1);  }  /**   * 查询签到记录   * @param $day   * @return int|null   * @throws \Exception   * @author wenzhen-chen   */  public function getSignLog($userId,$day)  {    return $this->getBit($this->keySign, $day);  }  /**   * 删除签到记录   * @return int|null   * @throws \Exception   * @author wenzhen-chen   */  public function delSignLig()  {    return $this->del($this->keySign);  }}

· 定时更新至mysql的类

<?php/** * Created by PhpStorm. * User: Administrator * Date: 2019/10/4 * Time: 19:03 */namespace app\common\business;use app\common\mysql\SignLog;use app\common\redis\db1\Sign;class Cron{  /**   * 同步用户签到记录   * @throws \Exception   */  public static function addUserSignLogToMysql()  {    $data = [];    $time = Time();    //1、计算上月的年份、月份    $dataTime = Common::getMonthTimeByKey(0);    $year = date('Y', $dataTime['start_time']);    $month = date('m', $dataTime['start_time']);    //2、查询签到记录的key    $signModel = new Sign(0, $year, $month);    $keys = $signModel->keys('sign_' . $year . '_' . $month . ':*');    foreach ($keys as $key) {      $bitLog = '';//用户当月签到记录      $userData = explode(':', $key);      $userId = $userData[1];      //3、循环查询用户是否签到(这里没按每月天数存储,直接都存31天了)      for ($i = 1; $i <= 31; $i++) {        $isSign = $signModel->getBit($key, $i);        $bitLog .= $isSign;      }      $data[] = [        'user_id' => $userId,        'year' => $year,        'month' => $month,        'bit_log' => $bitLog,        'create_time' => $time,        'update_time' => $time      ];    }    //4、插入日志    if ($data) {      $logModel = new SignLog();      $logModel->insertAll($data, '', 100);    }  }}

以上所述是小编给大家介绍的PHP使用redis位图bitMap 实现签到功能,希望对大家有所帮助,如果大家有任何疑问请给我留言,小编会及时回复大家的。在此也非常感谢大家对我们网站的支持!
如果你觉得本文对你有帮助,欢迎转载,烦请注明出处,谢谢!

以上就是关于对PHP使用redis位图bitMap 实现签到功能的详细介绍。欢迎大家对PHP使用redis位图bitMap 实现签到功能内容提出宝贵意见

微信扫一扫

易采站长站微信账号