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

·签到方法

1. public static function userSignIn($userId) 
2.   { 
3.     $time = Time(); 
4.     $today = date('d', $time); 
5.     $year = date('Y', $time); 
6.     $month = date('m', $time); 
7.     $signModel = new Sign($userId,$year,$month); 
8.     //1、查询用户今日签到信息 
9.     $todaySign = $signModel->getSignLog($today); 
10.     if ($todaySign) { 
11.       return self::jsonArr(-1, '您已经签到过了', []); 
12.     } 
13.     try { 
14.       Db::startTrans(); 
15.       $signModel->setSignLog($today); 
16.       //4、赠送积分 
17.       if (self::SING_IN_SCORE > 0) { 
18.         $dataScore['order_id'] = $userId.'_'.$today; 
19.         $dataScore['type'] = 2;//2、签到 
20.         $dataScore['remark'] = '签到获得积分'; 
21.         Finance::updateUserScore(Finance::OPT_ADD, $userId, self::SING_IN_SCORE, $dataScore); 
22.       } 
23.       $code = '0'; 
24.       $msg = '签到成功'; 
25.       $score = self::SING_IN_SCORE; 
26.       Db::commit(); 
27.     } catch (\Exception $e) { 
28.       Db::rollback(); 
29.       $code = '-2'; 
30.       $msg = '签到失败'; 
31.       $score = 0; 
32.     } 
33.     return self::jsonArr($code, $msg, ['score' => $score]); 
34.   } 

·redis基类

1. <?php 
2. namespace app\common\redis\db1; 
3. /** 
4.  * redis操作类 
5.  */ 
6. class RedisAbstract 
7. { 
8.   /** 
9.    * 连接的库 
10.    * @var int 
11.    */ 
12.   protected $_db = 1;//数据库名 
13.   protected $_tableName = '';//表名 
14.   static $redis = null; 
15.   public function __construct() 
16.   { 
17.     return $this->getRedis(); 
18.   } 
19.   public function _calcKey($id) 
20.   { 
21.     return $this->_tableName . $id; 
22.   } 
23.   /** 
24.    * 查找key 
25.    * @param $key 
26.    * @return array 
27.    * @throws \Exception 
28.    * @author wenzhen-chen 
29.    */ 
30.   public function keys($key) 
31.   { 
32.     return $this->getRedis()->keys($this->_calcKey($key)); 
33.   } 
34.   /** 
35.    * 获取是否开启缓存的设置参数 
36.    * 
37.    * @return boolean 
38.    */ 
39.   public function _getEnable() 
40.   { 
41.     $conf = Config('redis'); 
42.     return $conf['enable']; 
43.   } 
44.   /** 
45.    * 获取redis连接 
46.    * 
47.    * @staticvar null $redis 
48.    * @return \Redis 
49.    * @throws \Exception 
50.    */ 
51.   public function getRedis() 
52.   { 
53.     if (!self::$redis) { 
54.       $conf = Config('redis'); 
55.       if (!$conf) { 
56.         throw new \Exception('redis连接必须设置'); 
57.       } 
58.       self::$redis = new \Redis(); 
59.       self::$redis->connect($conf['host'], $conf['port']); 
60.       self::$redis->select($this->_db); 
61.     } 
62.     return self::$redis; 
63.   } 
64.   /** 
65.    * 设置位图 
66.    * @param $key 
67.    * @param $offset 
68.    * @param $value 
69.    * @param int $time 
70.    * @return int|null 
71.    * @throws \Exception 
72.    * @author wenzhen-chen 
73.    */ 
74.   public function setBit($key, $offset, $value, $time = 0) 
75.   { 
76.     if (!$this->_getEnable()) { 
77.       return null; 
78.     } 
79.     $result = $this->getRedis()->setBit($key, $offset, $value); 
80.     if ($time) { 
81.       $this->getRedis()->expire($key, $time); 
82.     } 
83.     return $result; 
84.   } 
85.   /** 
86.    * 获取位图 
87.    * @param $key 
88.    * @param $offset 
89.    * @return int|null 
90.    * @throws \Exception 
91.    * @author wenzhen-chen 
92.    */ 
93.   public function getBit($key, $offset) 
94.   { 
95.     if (!$this->_getEnable()) { 
96.       return null; 
97.     } 
98.     return $this->getRedis()->getBit($key, $offset); 
99.   } 
100.   /** 
101.    * 统计位图 
102.    * @param $key 
103.    * @return int|null 
104.    * @throws \Exception 
105.    * @author wenzhen-chen 
106.    */ 
107.   public function bitCount($key) 
108.   { 
109.     if (!$this->_getEnable()) { 
110.       return null; 
111.     } 
112.     return $this->getRedis()->bitCount($key); 
113.   } 
114.   /** 
115.    * 位图操作 
116.    * @param $operation 
117.    * @param $retKey 
118.    * @param mixed ...$key 
119.    * @return int|null 
120.    * @throws \Exception 
121.    * @author wenzhen-chen 
122.    */ 
123.   public function bitOp($operation, $retKey, ...$key) 
124.   { 
125.     if (!$this->_getEnable()) { 
126.       return null; 
127.     } 
128.     return $this->getRedis()->bitOp($operation, $retKey, $key); 
129.   } 
130.   /** 
131.    * 计算在某段位图中 1或0第一次出现的位置 
132.    * @param $key 
133.    * @param $bit 1/0 
134.    * @param $start 
135.    * @param null $end 
136.    * @return int|null 
137.    * @throws \Exception 
138.    * @author wenzhen-chen 
139.    */ 
140.   public function bitPos($key, $bit, $start, $end = null) 
141.   { 
142.     if (!$this->_getEnable()) { 
143.       return null; 
144.     } 
145.     return $this->getRedis()->bitpos($key, $bit, $start, $end); 
146.   } 
147.   /** 
148.    * 删除数据 
149.    * @param $key 
150.    * @return int|null 
151.    * @throws \Exception 
152.    * @author wenzhen-chen 
153.    */ 
154.   public function del($key) 
155.   { 
156.     if (!$this->_getEnable()) { 
157.       return null; 
158.     } 
159.     return $this->getRedis()->del($key); 
160.   } 
161. } 

·签到redis操作类

1. <?php 
2. /** 
3.  * Created by PhpStorm. 
4.  * User: Administrator 
5.  * Date: 2019/9/30 
6.  * Time: 14:42 
7.  */ 
8. namespace app\common\redis\db1; 
9. class Sign extends RedisAbstract 
10. { 
11.   public $keySign = 'sign';//签到记录key 
12.   public function __construct($userId,$year,$month) 
13.   { 
14.     parent::__construct(); 
15.     //设置当前用户 签到记录的key 
16.     $this->keySign = $this->keySign . '_' . $year . '_' . $month . ':' . $userId; 
17.   } 
18.   /** 
19.    * 用户签到 
20.    * @param $day 
21.    * @return int|null 
22.    * @throws \Exception 
23.    * @author wenzhen-chen 
24.    */ 
25.   public function setSignLog($day) 
26.   { 
27.     return $this->setBit($this->keySign, $day, 1); 
28.   } 
29.   /** 
30.    * 查询签到记录 
31.    * @param $day 
32.    * @return int|null 
33.    * @throws \Exception 
34.    * @author wenzhen-chen 
35.    */ 
36.   public function getSignLog($userId,$day) 
37.   { 
38.     return $this->getBit($this->keySign, $day); 
39.   } 
40.   /** 
41.    * 删除签到记录 
42.    * @return int|null 
43.    * @throws \Exception 
44.    * @author wenzhen-chen 
45.    */ 
46.   public function delSignLig() 
47.   { 
48.     return $this->del($this->keySign); 
49.   } 
50. } 

· 定时更新至mysql的类

1. <?php 
2. /** 
3.  * Created by PhpStorm. 
4.  * User: Administrator 
5.  * Date: 2019/10/4 
6.  * Time: 19:03 
7.  */ 
8. namespace app\common\business; 
9. use app\common\mysql\SignLog; 
10. use app\common\redis\db1\Sign; 
11. class Cron 
12. { 
13.   /** 
14.    * 同步用户签到记录 
15.    * @throws \Exception 
16.    */ 
17.   public static function addUserSignLogToMysql() 
18.   { 
19.     $data = []; 
20.     $time = Time(); 
21.     //1、计算上月的年份、月份 
22.     $dataTime = Common::getMonthTimeByKey(0); 
23.     $year = date('Y', $dataTime['start_time']); 
24.     $month = date('m', $dataTime['start_time']); 
25.     //2、查询签到记录的key 
26.     $signModel = new Sign(0, $year, $month); 
27.     $keys = $signModel->keys('sign_' . $year . '_' . $month . ':*'); 
28.     foreach ($keys as $key) { 
29.       $bitLog = '';//用户当月签到记录 
30.       $userData = explode(':', $key); 
31.       $userId = $userData[1]; 
32.       //3、循环查询用户是否签到（这里没按每月天数存储，直接都存31天了） 
33.       for ($i = 1; $i <= 31; $i++) { 
34.         $isSign = $signModel->getBit($key, $i); 
35.         $bitLog .= $isSign; 
36.       } 
37.       $data[] = [ 
38.         'user_id' => $userId, 
39.         'year' => $year, 
40.         'month' => $month, 
41.         'bit_log' => $bitLog, 
42.         'create_time' => $time, 
43.         'update_time' => $time 
44.       ]; 
45.     } 
46.     //4、插入日志 
47.     if ($data) { 
48.       $logModel = new SignLog(); 
49.       $logModel->insertAll($data, '', 100); 
50.     } 
51.   } 
52. }

Tags: redis bitMap PHP签到功能

分享到：