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基类
<?php
namespace appcommonredisdb1;
/**
* 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 appcommonredisdb1;
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 appcommonbusiness;
use appcommonmysqlSignLog;
use appcommonredisdb1Sign;
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 实现签到功能,希望对大家有所帮助,如果大家有任何疑问请给我留言,小编会及时回复大家的。在此也非常感谢大家对ZaLou.Cn网站的支持! 如果你觉得本文对你有帮助,欢迎转载,烦请注明出处,谢谢!
- JavaScript 教程
- JavaScript 编辑工具
- JavaScript 与HTML
- JavaScript 与Java
- JavaScript 数据结构
- JavaScript 基本数据类型
- JavaScript 特殊数据类型
- JavaScript 运算符
- JavaScript typeof 运算符
- JavaScript 表达式
- JavaScript 类型转换
- JavaScript 基本语法
- JavaScript 注释
- Javascript 基本处理流程
- Javascript 选择结构
- Javascript if 语句
- Javascript if 语句的嵌套
- Javascript switch 语句
- Javascript 循环结构
- Javascript 循环结构实例
- Javascript 跳转语句
- Javascript 控制语句总结
- Javascript 函数介绍
- Javascript 函数的定义
- Javascript 函数调用
- Javascript 几种特殊的函数
- JavaScript 内置函数简介
- Javascript eval() 函数
- Javascript isFinite() 函数
- Javascript isNaN() 函数
- parseInt() 与 parseFloat()
- escape() 与 unescape()
- Javascript 字符串介绍
- Javascript length属性
- javascript 字符串函数
- Javascript 日期对象简介
- Javascript 日期对象用途
- Date 对象属性和方法
- Javascript 数组是什么
- Javascript 创建数组
- Javascript 数组赋值与取值
- Javascript 数组属性和方法
- 十七、详解 ES6 Modules
- 超干货!为了让你彻底弄懂 MySQL 事务日志,我通宵肝出了这份图解!
- 什么情况下不能使用最坏情况评估算法的复杂度?
- Python运算符
- kubeadm高可用集群意外删除一mater节点,重新加入失败
- Chevereto——简介及安装
- Typecho开启伪静态并隐藏index.php
- Prism代码高亮Pjax重载函数
- Qt示例-AnalogClock-自定义窗体-使用QPainter的转换和缩放特性简化绘图
- 2019-12-27-traefik
- 2019-12-05-eck-qustion
- 聊聊dubbo-go的ConsumerSignFilter
- Javascript错误处理
- 程序员说模型过拟合的时候,说的是什么?
- 分分钟教会你搭建企业级的 npm 私有仓库