This commit is contained in:
2021-12-06 15:54:31 +08:00
parent 81e55ecdf1
commit 7004c5c0f8
+17 -5
View File
@@ -9,9 +9,7 @@ declare(strict_types=1);
namespace Kiri\Cache; namespace Kiri\Cache;
use Note\Inject;
use Exception; use Exception;
use Server\Events\OnWorkerExit;
use Kiri\Abstracts\Component; use Kiri\Abstracts\Component;
use Kiri\Abstracts\Config; use Kiri\Abstracts\Config;
use Kiri\Core\Json; use Kiri\Core\Json;
@@ -19,6 +17,8 @@ use Kiri\Events\EventProvider;
use Kiri\Exception\ConfigException; use Kiri\Exception\ConfigException;
use Kiri\Kiri; use Kiri\Kiri;
use Kiri\Pool\Redis as PoolRedis; use Kiri\Pool\Redis as PoolRedis;
use Note\Inject;
use Server\Events\OnWorkerExit;
/** /**
* Class Redis * Class Redis
@@ -35,13 +35,25 @@ class Redis extends Component
public EventProvider $eventProvider; public EventProvider $eventProvider;
const REDIS_OPTION_HOST = 'host';
const REDIS_OPTION_PORT = 'port';
const REDIS_OPTION_PREFIX = 'prefix';
const REDIS_OPTION_AUTH = 'auth';
const REDIS_OPTION_DATABASES = 'databases';
const REDIS_OPTION_TIMEOUT = 'timeout';
const REDIS_OPTION_POOL = 'pool';
const REDIS_OPTION_POOL_TICK = 'tick';
const REDIS_OPTION_POOL_MIN = 'min';
const REDIS_OPTION_POOL_MAX = 'max';
/** /**
* @throws ConfigException * @throws ConfigException
* @throws Exception * @throws Exception
*/ */
public function init() public function init()
{ {
$connections = Kiri::getDi()->get(PoolRedis::class); $connections = Kiri::getDi()->get(PoolRedis::class);
$config = $this->get_config(); $config = $this->get_config();
@@ -111,7 +123,7 @@ SCRIPT;
*/ */
public function release() public function release()
{ {
$connections = Kiri::getDi()->get(PoolRedis::class); $connections = Kiri::getDi()->get(PoolRedis::class);
$connections->release($this->get_config(), true); $connections->release($this->get_config(), true);
} }
@@ -135,7 +147,7 @@ SCRIPT;
*/ */
public function proxy($name, $arguments): mixed public function proxy($name, $arguments): mixed
{ {
$connections = Kiri::getDi()->get(PoolRedis::class); $connections = Kiri::getDi()->get(PoolRedis::class);
$config = $this->get_config(); $config = $this->get_config();