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

Shun

这篇文章主要介绍了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个调用方法，与三个类）
·签到方法

{
  $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基类

php
namespace 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 实现签到功能,希望对大家有所帮助，如果大家有任何疑问请给我留言，小编会及时回复大家的。在此也非常感谢大家对网站的支持！
如果你觉得本文对你有帮助，欢迎转载，烦请注明出处，谢谢！
原文链接：https://segmentfault.com/a/1190000020594802