在Thinkphp項目中封裝一個Redis多庫單例操作類
1、操作前的準備
如果沒有安裝phpredis模塊那么先執行
composer require predis/predis
2、配置Redis連接信息
在app\config\cache.php中配置
'redis' => [
// 驅動方式
'type' => 'redis',
// 連接地址
'host' => Env::get('redis.host'),
// 端口
'port' => Env::get('redis.port'),
],更多配置參考
/** * 配置參數 * @var array */ protected $options = [ 'host' => '127.0.0.1', 'port' => 6379, 'password' => '', 'select' => 0, 'timeout' => 0, 'expire' => 0, 'persistent' => false, 'prefix' => '', 'tag_prefix' => 'tag:', 'serialize' => [], ];
在.env中配置連接信息
[REDIS]host = 127.0.0.1 port = 6379
3、編寫代碼
在app\common下創建文件Redis.php
<?php
namespace app\common;
use think\facade\Config;
use think\cache\driver\redis as ThinkRedis;
class Redis extends ThinkRedis
{
/**
* @var int
*/
protected $hash;
/**
* @var array
*/
protected static $instance = [];
/**
* Redis constructor.
* @param $db
*/
private function __construct($db)
{
$options = Config::get('cache.stores.redis');
$options['select'] = $db;
$this->hash = $db;
$this->options = array_merge($this->options, $options);
parent::__construct();
}
private function __clone()
{
}
/**
* @param int $db
* @return \Predis\Client|\Redis
*/
public static function instance($db = 0)
{
if (! isset(self::$instance[$db])) {
self::$instance[$db] = new self($db);
}
return self::$instance[$db];
}
public function __destruct()
{
self::$instance[$this->hash]->close();
unset(self::$instance[$this->hash]);
}
}4、使用方式
use app\common\Redis;
$redis = Redis::instance(4);
$redis->hSet('user:1', 'userName', 'admin');
Redis::instance(1)->hSet('user', 'name', 'admin1');
Redis::instance(2)->hSet('user', 'name', 'admin2');
Redis::instance(3)->hSet('user', 'name', 'admin3');
