redis消息隊列 拉取數據

const MAX_LIST_LEN = 50;//每次從隊列獲取的條數
const REDIS_LIST = "mytest";

//獲取 redis 隊列 數據
private function getListArr(){
    //避免裁剪過多的數據
    $redis_len = $this->redis->llen(REDIS_KEY::REDIS_LIST);
    if($redis_len<1) return [];
    $max_len = $redis_len > self::MAX_LIST_LEN ? self::MAX_LIST_LEN : $redis_len;
    //讀取數據 && 裁剪數據
    $list = $this->redis->lrange(REDIS_KEY::REDIS_LIST,0,$max_len-1);

    $this->redis->ltrim(REDIS_KEY::REDIS_LIST,$max_len,-1);

 return $list;
}

//重推
private function reBack($list){
    foreach($list as $item){
        $this->redis->rpush(REDIS_KEY::REDIS_LIST,$item);

    }
}