anxinliao/application/index/controller/Test.php

<?php

namespace app\index\controller;

use think\Db;
use Redis;
class Test
{
    //显示所有人，匹配状态
    public function showredis(){
        $list = Db::name('user')->order('id desc')->column('id');
        foreach($list as $key => $id){
            dump($id.':'.redis_matching_get($id));
            echo '<br/>';
        }
        exit;
    }
    //清除所有人，匹配状态
    public function clearredis(){
        $list = Db::name('user')->order('id desc')->column('id');
        foreach($list as $key => $id){
            $a = redis_matching_set($id,0);
        }
        exit;
    }


    public function test1(){
        // 文本加一个回车
        $buffer1 = 'abcdefghijklmn';
// 在php中双引号中的\n代表一个换行符，例如"\n"
        $buffer2 = '{"type":"say", "content":"hello", "content":"hello", "content":"hello", "content":"hello", "content":"hello", "content":"hello", "content":"hello", "content":"hello", "content":"hello", "content":"hello", "content":"hello", "content":"hello", "content":"hello", "content":"hello", "content":"hello", "content":"hello", "content":"hello", "content":"hello", "content":"hello", "content":"hello", "content":"hello", "content":"hello", "content":"hello", "content":"hello", "content":"hello", "content":"hello", "content":"hello", "content":"hello", "content":"hello", "content":"hello", "content":"hello", "content":"hello", "content":"hello", "content":"hello", "content":"hello"}'."";

        $buffer2 = 'abcdefghijklmn'."\n";

// 与服务端建立socket连接
        $client = stream_socket_client('tcp://1.14.197.70:2349');
// 以text协议发送buffer1数据
        //fwrite($client, $buffer1);
// 以text协议发送buffer2数据
        fwrite($client, $buffer2);

    }

    //直播间详情
    public function show_livebc(){
        $party_id = input('party_id');
        if(empty($party_id)){
            $this->error();
        }

        $redis = new Redis();
        $redisconfig = config("redis");
        $redis->connect($redisconfig["host"], $redisconfig["port"]);

        $a = $redis->get("livebc_".$party_id);
        dump($a);
    }
    //直播间贡献值
    public function show_livebc_jewel(){
        $party_id = input('party_id');
        if(empty($party_id)){
            $this->error();
        }

        $redis = new Redis();
        $redisconfig = config("redis");
        $redis->connect($redisconfig["host"], $redisconfig["port"]);

        $userModel = new \app\common\model\User();
        // 获取条数
        $num = 3;
        // 获取3条财富排行周记录
        $getweek = $redis->zRevRange("livebc_jewel_to_".$party_id,0,-1,true);
        $getweek2 = $redis->zRevRange("livebc_jewel_get_".$party_id,0,0,true);
        $userList = $userModel->rankList($getweek);
        $userList2 = $userModel->rankList($getweek2);
        dump($getweek);
        dump($getweek2);
        dump($userList);
        dump($userList2);

        $avatarArr = [];
        if($userList) {
            foreach($userList as $k => $v) {
                $v["jewel"] > 0 && $avatarArr[] = $v["avatar"];
            }
            // 加入缓存做备份
            $redis->hSet("user_jewel_top3",$party_id,json_encode($avatarArr));
            //$redis->hSet("livebc_jewel_top3",$party_id,json_encode($avatarArr));
        }
        dump($avatarArr);

    }

    //清空直播间贡献值
    public function clear(){
        $party_id = input('party_id');
        if(empty($party_id)){
            $this->error();
        }
        //清空房间排行榜
        $redis = new Redis();
        $redisconfig = config("redis");
        $redis->connect($redisconfig["host"], $redisconfig["port"]);
        $redis->del('livebc_jewel_to_' . $party_id);
        $redis->del('livebc_jewel_get_' . $party_id);
        $redis->hDel("user_jewel_top3",$party_id);
    }



}