一 加入排行榜

public function addSumRank(){
        $cache = Cache::init();
        $redis = $cache->handler();
        $uid = 100;//新注册用户
        $key = 'duty_test';
        //$gold = 0 * 10000000000;//由于初始分数为0 故省略此处
        $gold += 9999999999 - time();
        $redis->zAdd($key,$gold,$uid);
    }

二 记录日排行

 //记录日排行
    public function daily_rank(){
        $cache = Cache::init();
        $redis = $cache->handler();
        // $key = 'duty_test:daily:'.date('Y-m-d');
        // $uid = 1;
        $gold = 10;
        // $score = $redis->zScore($key,$uid);
        // if($score == false){
        //     $redis->zAdd($key,$gold,$uid);
        // }else{
        //     $redis->zIncrBy($key,$gold,$uid);
        // }
        for($i = 0;$i<6;$i++){
            $key = 'duty_test:daily:'.date('Y-m-d',strtotime('-'.$i.' day'));
            for($is = 1;$is<6;$is++){
                $redis->zIncrBy($key,$is,$is);
            }
            
        }
        
    }

三 更新用户收益

public function updateSumScore(){
        $cache = Cache::init();
        $redis = $cache->handler();
        $uid = 3;
        $key = 'duty_test';
        $score = $redis->zScore($key,$uid);
        $gold = 10;
        if($score == false){
            $gold = $gold * 10000000000;
            $gold +=9999999999 - time();
            $redis->zAdd($key,$gold,$uid);
        }else{
            $gold = $gold * 10000000000;
            $redis->zIncrBy($key,$gold,$uid);
        }
    }

四 获取排行榜 用户的排名 以及近段时间收益

//获取排行榜前10 
    public function getRankList(){
        $cache = Cache::init();
        $redis = $cache->handler();
        $key = 'duty_test';
        $list  = $redis->ZREVRANGE($key,0,9);
        print_r($list);die;
    }
    //获取用户的排名
    public function getUserRank(){
        $cache = Cache::init();
        $redis = $cache->handler();
        $key = 'duty_test';
        $uid = 3;
        $key = 'duty_test';
        $rank = $redis->zRevRank($key,$uid);
        if($rank !==false){
            $rank = $rank +1;
        }else{
            $rank = 0;
        }
        var_dump($rank);
    }
    //获取该用户 近1周内总的收益 没有则 更新所有用户 近一周内的总收益情况
    public function RecentUserIncome(){
        $cache = Cache::init();
        $redis = $cache->handler();
        $key = 'duty_test:daily:';
        for($i = 1;$i<6;$i++){
            $keys[] = $key.date('Y-m-d',strtotime('-'.$i.' day'));
        }
        /*
        var_dump($keys);die;
        array(5) { [0]=> string(26) "duty_test:daily:2020-08-18" [1]=> string(26) "duty_test:daily:2020-08-17" [2]=> string(26) "duty_test:daily:2020-08-16" [3]=> string(26) "duty_test:daily:2020-08-15" [4]=> string(26) "duty_test:daily:2020-08-14" }
        */
       if(!$redis->exists('duty_test:week:')){
            $result = $redis->zunionstore('duty_test:week:',$keys);
            if(!$result){
                return 0 ;
            }
            //每300 s 更新缓存
            $redis->expire('duty_test:week',300);
       }else{
            $score = $redis->zScore('duty_test:week:',1);
            $rank = $redis->zRevRank('duty_test:week:',1);
            //实际排名
            $rank = $rank + 1;  
            print_r($rank);die;
       }
        
    }

用户的实际得分 即去除后10位后

每日排行 以及周排行

加入排行榜操作
用户的实际得分 * 10000000000 + 9999999999 - time() 加入排行榜缓存
更新操作时候
redis->zIncrBy($key,$gold,$uid)获取用户排名redis->zRevRank($key,$uid)获取前10名redis->ZREVRANGE($key,0,9)

redis中有一个有序集合(sorted set)，通过此数据结构可以很轻松的实现排行榜的功能，例如直播中的排行榜，今日头条的热度榜等等。笔者阐述下实现思路，请大家参考。如有疑问请留言。

一、redis实现排行榜
      Redis 有序集合和集合一样也是 string 类型元素的集合,且不允许重复的成员。不同的是每个元素都会关联一个 double 类型的分数。redis 正是通过分数来为集合中的成员进行从小到大的排序。有序集合的成员是唯一的,但分数(score)却可以重复。正是因为有分值，所以很适合用在排行榜的功能中。此以直播的排行榜为例。
      每个直播间都有粉丝的排行榜，可以通过key+直播间id来作为redis的key。例如broadcast:20210108231。每个直播间的观众按照点赞数排序。则观众刚刚进入直播间即可通过ZADD添加排行榜。

1、新增操作
张三观众进入直播间。
李四进入直播间
ZADD [key] [score] [value]

ZADD broadcast:20210108231 1 zhangsan
ZADD broadcast:20210108231 1 lisi

王五进入直播间。
赵六进入直播间。

ZADD broadcast:20210108231 1 wangwu
ZADD broadcast:20210108231 1 zhaoliu

2、加分值
李四送了直播间两颗小红心。李四分值加2。
ZINCRBY [key] increment [member]

ZINCRBY broadcast:20210108231 2 lisi

3、展示榜单
通过如上指令对直播间分值进行设置之后，得到redis的value如下：

127.0.0.1:6379> ZRANGE broadcast:20210108231 0 -1 WITHSCORES
1) "zhaoliu"
2) "2"
3) "wangwu"
4) "5"
5) "lisi"
6) "8"
7) "zhangsan"
8) "10"

获取直播间前三名进行展示，按照分值排序
      ZREVRANGE 命令返回有序集中，指定区间内的成员。其中成员的位置按分数值递减(从大到小)来排列。具有相同分数值的成员按字典序的逆序(reverse lexicographical order)排列。

ZREVRANGE key start stop [WITHSCORES]

127.0.0.1:6379> ZREVRANGE broadcast:20210108231 0 2
1) "zhangsan"
2) "lisi"
3) "wangwu"

4、查看直播间人数
ZCARD key 返回集合数量。

127.0.0.1:6379> zcard  broadcast:20210108231
(integer) 4

5、离开直播间
张三离开直播间，则删除对应key。
ZREM [key] [value]

127.0.0.1:6379>  ZREM broadcast:20210108231 zhangsan
(integer) 1
127.0.0.1:6379>  ZREVRANGE broadcast:20210108231 0 2
1) "lisi"
2) "wangwu"
3) "zhaoliu"

6、周榜
      真实场景中肯定会有时间段的划分，例如查看日榜、周榜、月榜。只需要按照最小的单位按照时间区分成不同的集合，最后求出这些集合的并集即可。

ZADD hotnews:1 10 zhangsan
ZADD hotnews:1 10 lisi
ZADD hotnews:2 5 zhangsan
ZADD hotnews:2 5 wangwu
如此，得到两个zset集合，最后得到两个集合的并集。
ZUNIONSTORE destination numkeys key [key ...] [WEIGHTS weight [weight ...]] [AGGREGATE SUM|MIN|MAX]

127.0.0.1:6379> ZUNIONSTORE hotnews:week:1 2 hotnews:1 hotnews:2
(integer) 3
127.0.0.1:6379> ZRANGE hotnews:week:1 0 -1 WITHSCORES
1) "wangwu"
2) "5"
3) "lisi"
4) "10"
5) "zhangsan"
6) "15"

      WEIGHTS 可以设置每个集合的权重，意为在原来集合分数乘权重得到输出集合的值。
两个集合并集时，如果有相同的key，则可以通过 SUM|MIN|MAX 进行控制。默认为SUM。
 

<?php  
    $redis = new redis();  
    $redis->connect('192.168.1.108', 6379);  
    $redis->flushall();   
       
    $array=array('tank'=>'1',  
              'zhang'=>'2',  
              'ying'=>'3',  
              'test'=>'4');  
    $redis->mset($array);  
    print_r($redis->keys('*s*'));        // 结果：Array ( [0] => test )  
    print_r($redis->keys('y???'));       // 结果：Array ( [0] => ying )  
    print_r($redis->keys('t[e]*'));  // 结果：Array ( [0] => test )  
    print_r($redis->keys('*'));      // 结果：Array ( [0] => ying [1] => test [2] => zhang [3] => tank )   
       
    print_r($redis->mget(array("tank","ying")));     // 结果：Array ( [0] => 1 [1] => 3 )  
?>
 

4） sort

--最简单的 SORT 使用方法是 SORT key 和 SORT key DESC 

--因为 SORT 命令默认排序对象为数字， 当需要对字符串进行排序时， 需要显式地在 SORT 命令之后添加 ALPHA 修饰符：

# 网址

redis> LPUSH website "www.reddit.com"
(integer) 1

redis> LPUSH website "www.slashdot.com"
(integer) 2

redis> LPUSH website "www.infoq.com"
(integer) 3

# 默认（按数字）排序

redis> SORT website
1) "www.infoq.com"
2) "www.slashdot.com"
3) "www.reddit.com"

# 按字符排序

redis> SORT website ALPHA
1) "www.infoq.com"
2) "www.reddit.com"
3) "www.slashdot.com"

 

描述：按条件取得数据
参数：

代码如下:

array(
    'by' => 'pattern', //匹配模式
    'limit' => array(0, 1),
    'get' => 'pattern'
    'sort' => 'asc' or 'desc',
    'alpha' => TRUE,
    'store' => 'external-key'
)

返回或保存给定列表、集合、有序集合key中经过排序的元素。

 

一般排序

代码如下:

<?php  
    $redis = new redis();  
    $redis->connect('192.168.1.108', 6379);  
    $redis->flushall();  
    $redis->lpush('test', 1);  
    $redis->lpush('test', 10);  
    $redis->lpush('test', 8);  
       
    print_r($redis->sort('test')); //结果：Array ( [0] => 1 [1] => 8 [2] => 10 )  
?>
 

字母排序

 

代码如下:

<?php  
    $redis = new redis();  
    $redis->connect('192.168.1.108', 6379);  
    $redis->flushall();  
    $redis->lpush('test', 'a');  
    $redis->lpush('test', 'd');  
    $redis->lpush('test', 'b');  
       
    print_r($redis->sort('test')); //结果：Array ( [0] => b [1] => d [2] => a )  
    print_r($redis->sort('test',array('ALPHA'=>TRUE))); //结果：Array ( [0] => a [1] => b [2] => d )  
?>
 
 

排序取部分数据

 

代码如下:

<?php  
    $redis = new redis();  
    $redis->connect('192.168.1.108', 6379);  
    $redis->flushall();  
    $redis->lpush('test', 31);  
    $redis->lpush('test', 5);  
    $redis->lpush('test', 2);  
    $redis->lpush('test', 23);    
       
    $array = array('LIMIT'=>array(0,3),"SORT"=>'DESC');  
    print_r($redis->sort('test',$array));  //结果：Array ( [0] => 31 [1] => 23 [2] => 5 )  
?>
 

使用外部key进行排序

有时候你会希望使用外部的key作为权重来比较元素，代替默认的对比方法。

假设现在有用户(user)表数据如下：

 

代码如下:

id　　　  name　　　　score  
-------------------------------  
1　　　　 tank　　　   89  
2　　　　 zhang　　　  40  
4 　     ying 　　　  70  
3 　　   fXXK 　　    90
 

id数据保存在key名为id的列表中。
name数据保存在key名为name_{id}的列表中
score数据保存在score_{id}的key中。

 

代码如下:

<?php  
    $redis = new redis();  
    $redis->connect('192.168.1.108', 6379);  
    $redis->flushall();   
       
    $redis->lpush('id', 1);  
    $redis->set('name_1', 'tank');  
    $redis->set('score_1',89);  
       
    $redis->lpush('id', 2);  
    $redis->set('name_2', 'zhang');  
    $redis->set('score_2', 40);  
       
    $redis->lpush('id', 4);  
    $redis->set('name_4','ying');  
    $redis->set('score_4', 70);  
       
    $redis->lpush('id', 3);  
    $redis->set('name_3', 'fXXK');  
    $redis->set('score_3', 90);  
 --通过使用 BY 选项，可以让 uid 按其他键的元素来排序。
比如说， 以下代码让 uid 键按照 user_level_{uid} 的大小来排序：
--使用 GET 选项， 可以根据排序的结果来取出相应的键值。
比如说， 以下代码先排序 uid ， 再取出键 user_name_{uid} 的值：
    /** 
     * 按score从大到小排序,取得id 
     */ 
    $sort=array('BY'=>'score_*',  
                'SORT'=>'DESC' 
                );  
    print_r($redis->sort('id',$sort)); //结果:Array ( [0] => 3 [1] => 1 [2] => 4 [3] => 2 )   
       
    /** 
     * 按score从大到小排序,取得name 
     */ 
    $sort=array('BY'=>'score_*',  
                'SORT'=>'DESC',  
                'GET'=>'name_*' 
                );  
    print_r($redis->sort('id',$sort)); //结果:Array ( [0] => fXXK [1] => tank [2] => ying [3] => zhang )    
       
    /** 
     * 按score从小到大排序,取得name，score 
     */ 
    $sort=array('BY'=>'score_*',  
                'SORT'=>'DESC',  
                'GET'=>array('name_*','score_*')  
                );  
    print_r($redis->sort('id',$sort));  
    /** 
     *结果:Array 
            ( 
                [0] => fXXK 
                [1] => 90 
                [2] => tank 
                [3] => 89 
                [4] => ying 
                [5] => 70 
                [6] => zhang 
                [7] => 40 
            )) 
     */ 
       
    /** 
     * 按score从小到大排序,取得id，name，score 
     */ 
GET 有一个额外的参数规则，那就是 可以用 # 获取被排序键的值。
    $sort=array('BY'=>'score_*',  
                'SORT'=>'DESC',  
                'GET'=>array('#','name_*','score_*')  
                );  
    print_r($redis->sort('id',$sort));  
    /** 
     * 结果:Array 
            ( 
                [0] => 3 
                [1] => fXXK 
                [2] => 90 
                [3] => 1 
                [4] => tank 
                [5] => 89 
                [6] => 4 
                [7] => ying 
                [8] => 70 
                [9] => 2 
                [10] => zhang 
                [11] => 40 
            ) 
     */ 
?>

 demo

<?php

header("Content-type: text/html; charset=utf-8"); 
$arr = [
    ['1','张三',98,'http://www.img.com/3.jpg'],
    ['2','李四',79,'http://www.img.com/4.jpg'],
    ['3','王五',48,'http://www.img.com/5.jpg'],
    ['4','赵六',85,'http://www.img.com/6.jpg'],
    ['5','钱八',19,'http://www.img.com/8.jpg'],
    ['6','孙吉',38,'http://www.img.com/9.jpg'],
    ['7','张飞',46,'http://www.img.com/f.jpg'],
    ['8','关羽',65,'http://www.img.com/g.jpg'],
    ['9','德玛',73,'http://www.img.com/dm.jpg'],
    ['10','盖伦',73,'http://www.img.com/gl.jpg']
];


$redis = new Redis();
$redis->connect('127.0.0.1', 6379);
$redis->del('uid');


foreach($arr as $k=>$v){
   
   $redis->lpush('uid',$v[0]);
   $redis->set('name_'.$v[0], $v[1]);  
   $redis->set('score_'.$v[0], $v[2]);  
   $redis->set('user_img_'.$v[0], $v[3]);  

}

$sort = [
    'BY'=>'score_*',
    'SORT'=>'DESC' ,
    //'LIMIT'=>array(0,3),
    'GET'=>array('name_*','score_*','user_img_*')  
];  

echo '<pre>';

$res = array_chunk($redis->sort('uid',$sort), 3);

foreach($res as $k=>$v){
    $res[$k]['sort'] = $k+1;
}

print_r($res);

foreach($res as $k=>$v){
    $tr.="<tr>
            <td>{$v['sort']}</td>
            <td>{$v[0]}</td>
            <td>{$v[2]}</td>
            <td>{$v[1]}</td>
         </tr>";
}


echo '<h1>排行榜</h1>';

$html = "<table>
            <tr>
                <th>排名</th>
                <th>用户名</th>
                <th>头像</th>
                <th>分数 </th>> 
            </tr>
            {$tr}
        </table>";


echo $html;


?>