\cn\gz53\framework\sdk\redisRedisPoolSdk

<?php
/**
 * // +----------------------------------------------------------------------
 * // | phpMore [ WE CAN DO IT MORE ]
 * // +----------------------------------------------------------------------
 * // | Copyright (c) 20011~2019 广州务商网络科技有限公司 All rights reserved.
 * // +----------------------------------------------------------------------
 * // | Licensed ( http://www.apache.org/licenses/LICENSE-2.0 )
 * // +----------------------------------------------------------------------
 * // | Author: sujunli <4297088@qq.com>
 * // +----------------------------------------------------------------------
 */

namespace cn\gz53\framework\sdk\redis;

use cn\gz53\framework\sdk\Sdk;
use Exception;
use Redis;

class RedisPoolSdk extends Sdk
{
    private $_pool = [];
    private $configList;

    public function setConfig(RedisPoolConfigSetSdkI $po){
        $this->configList = $po->getConfig();
        return true;
    }

    public function init(RedisPoolInitSdkI $po){
        //printf("\n[%s]Redis init...", date("Y-m-d H:i:s"));
        $list = $this->configList;
        if(!is_array($list)){
            $this->sysLog(1, '', null);
            return false;
        }
        //print_r($this->configList);
        foreach ($list as $key => $val){
            try {
                $redis = new Redis();
                $redis->pconnect($val['host'], $val['port']);
                if(!empty($val['password'])){
                    $redis->auth($val['password']);
                }
                $redis->select($val['db']);
                //printf("\n[%s]Redis new, key:%s...", date("Y-m-d H:i:s"), $key);
                $this->_pool[$key] = $redis;
            } catch (Exception $e) {
                printf("\n[%s]Redis init, key:%s,code:%d, msg:%s...",
                    date("Y-m-d H:i:s"), $key, $e->getCode(), $e->getMessage());
                print_r($e->getTraceAsString());
                $this->sysLog($e->getCode(), $e->getMessage(), $e->getTraceAsString());
                return false;
            }
        }
        return true;
    }

    public function getRedis(RedisPoolRedisGetSdkI $po){
        $key = $po->getRedisKey();
        if(!isset($this->_pool[$key])){
            //printf("\n[%s]RedisPoolSdk, redis not exist , key:%s..\n",date("Y-m-d H:i:s"), $key);
            $this->sysLog(1, 'redis not exist', [$key]);
            return false;
        }
        $po->setRedis($this->_pool[$key]);
        return true;
    }
}