用redis实现用户登录计数
最近有个问题 :实现显示用户本月登录日期 ,累计天数到一定数目可参加活动,和下图展示的功能类似。
过去看过使用redis bitmap进行活跃用户统计的例子,觉得和本功能非常match,决定用redis的bitset来实现。
每个用户每月产生一个key,字段意义如下 0 位表示某月1日登录 ,1表示某月2日登录,以此类推。
每个用户一月的活跃度需要8byte,1W用户每年需要1W*12*8byte 约1M数据
用户每次登录系统,需要用setBit设置用户本日登录,可用bitcount的到用户本月登录天数总和,因为PHP原生不对bitset进行支持,采用get得到字符串进行操作得到用户登录日期
测试代码如下:
<?php
/**
*
* User: shikiliu
* Date: 14-8-27
*/
class ActiveDate
{
private $redisConf = array('host' => 'localhost', 'port' => 6379);
private $redis = null;
private $userPrefix = 'user_active_';
/**
* 设置用户某天登录过
*/
public function setActiveDate($userId, $time = null)
{
if (empty($time)) {
$time = time();
}
$redis = $this->getRedis();
$redis->setBit($this->userPrefix . $userId . '_' . date('Y-m', $time), intval(date('d', $time)) - 1, 1);
return true;
}
/**
* 得到用户本月登录天数
* redis >= 2.6.0 才可以
*/
public function getActiveDatesCount($userId, $time = null){
if (empty($time)) {
$time = time();
}
$redis = $this->getRedis();
return $redis->bitcount($this->userPrefix . $userId . '_' . date('Y-m', $time));
}
/**
* 得到用户某月所有的登录过日期
*/
public function getActiveDates($userId, $time = null)
{
$result = array();
if (empty($time)) {
$time = time();
}
$redis = $this->getRedis();
$strData = $redis->get($this->userPrefix . $userId . '_' . date('Y-m', $time));
if (empty($strData)) {
return $result;
}
$monthFirstDay = mktime(0, 0, 0, date("m", $time), 1, date("Y", $time));
$maxDay = cal_days_in_month(CAL_GREGORIAN, date("m", $time), date("Y", $time));
$charData = unpack("C*", $strData);
for ($index = 1; $index <= count($charData); $index++) {
for ($bit = 0; $bit < 8; $bit++) {
if ($charData[$index] & 1 << $bit) {
//$intervalDay = ($index - 1) * 8 + 8-$bit;
$intervalDay = $index * 8 -$bit;
//如果数据有大于当月最大天数的时候
if ($intervalDay > $maxDay) {
return $result;
}
$result [] = date('Y-m-d', $monthFirstDay + ($intervalDay-1) * 86400);
}
}
}
return $result;
}
/**
* redis连接
*/
private function getRedis()
{
if (empty($this->redis)) {
$redis = new Redis();
if (!$redis->connect($this->redisConf['host'], $this->redisConf['port'])) {
throw new Exception("Error Redis Connect", 100);
}
$redis->select(3);
$this->redis = $redis;
}
return $this->redis;
}
}
$activeDate = new ActiveDate();
var_dump($activeDate->setActiveDate(514540767,1406822600));// 2014/8/1 0:3:20
var_dump($activeDate->setActiveDate(514540767,1407225600));// 2014/8/5 16:0:0
var_dump($activeDate->setActiveDate(514540767,1409472000));// 2014/8/31 16:0:0
var_dump($activeDate->getActiveDates(514540767));
var_dump($activeDate->getActiveDatesCount(514540767));