phpredis存储对象(PHP使用redis位图bitMap 实现签到功能)
phpredis存储对象
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
- pythonredis使用场景(python redis 删除key脚本的实例)
- redis在php中的使用(PHP+Redis开发的书签案例实战详解)
- redis新增数据分页(Scrapy-Redis结合POST请求获取数据的方法示例)
- docker部署tomcat(Docker安装Tomcat、MySQL和Redis的步骤详解)
- php消息队列redis(redis+php实现微博二发布与关注功能详解)
- docker进入redis容器(Docker配置redis哨兵模式的方法多服务器上)
- phpredis消息队列(PHP+redis实现微博的推模型案例分析)
- docker快速配置redis集群(基于docker搭建redis集群的方法)
- django测试服务器静态资源放哪里(Django使用redis缓存服务器的实现代码示例)
- redis的scan命令的使用(scrapy-redis源码分析之发送POST请求详解)
- phpredis怎么测试成功(PHP+redis实现的限制抢购防止商品超发功能详解)
- python编辑redis(python使用pipeline批量读写redis的方法)
- python ssh登录服务器(python利用跳板机ssh远程连接redis的方法)
- docker实现redis集群(详解使用Docker进行Redis主从复制实践)
- phpredis怎么实现任务(PHP swoole和redis异步任务实现方法分析)
- 用docker搭建redis集群(docker实现redis集群搭建的方法步骤)
- 14岁丧父 20岁丧母,从苦难走向辉煌的银泰创始人沈国军(14岁丧父20岁丧母从苦难走向辉煌的银泰创始人沈国军)
- 银泰集团董事长沈国军获评 北京影响力 十大企业家(银泰集团董事长沈国军获评)
- 15帅气男士发型,清爽时尚很有型,喜欢就试试(清爽时尚很有型)
- 哪几个历史人物被影协主席李雪健演的活灵活现(哪几个历史人物被影协主席李雪健演的活灵活现)
- 王伦狭隘,晁盖霸道,宋江奸诈骨头软,只有鲁智深才适合当寨主(王伦狭隘晁盖霸道)
- 他是梁山最早的头目,江湖人称 旱地忽律 ,宋江几乎将其遗忘(他是梁山最早的头目)
热门推荐
- python 获取天气预报(详解用python自制微信机器人,定时发送天气预报)
- dedecms搬家乱码(dedecms 的cn_substr_utf8字符串截取函数商榷)
- 使用Console命令调试JS
- _viewstart.cshtml的作用
- python弹球游戏编写过程(python实现坦克大战游戏 附详细注释)
- reactnative ios(详解React Native与IOS端之间的交互)
- python处理时间序列常用方法汇总(python整小时 整天时间戳获取算法示例)
- js弹出新窗口被拦截的解决方法
- canvas 中增加组件(如何在Canvas中添加事件的方法示例)
- mysql允许远程访问docker(Docker部署mysql远程连接 解决2003的问题)
排行榜
- 1
- 2
- 3
- 4
- 5
- 6
- 7
- 8
- 9