From 175b3155262ad871577727466ae8c0474f42c716 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?Mr=C2=B7x?= <as2252258@163.com>
Date: Tue, 7 Sep 2021 14:11:34 +0800
Subject: [PATCH] =?UTF-8?q?=E6=94=B9=E5=90=8D?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 core/Cache/Base/Redis.php | 7 ++++---
 1 file changed, 4 insertions(+), 3 deletions(-)

diff --git a/core/Cache/Base/Redis.php b/core/Cache/Base/Redis.php
index 5c28296f..60f4a175 100644
--- a/core/Cache/Base/Redis.php
+++ b/core/Cache/Base/Redis.php
@@ -8,6 +8,7 @@ use Kiri\Events\EventProvider;
 use Kiri\Exception\RedisConnectException;
 use Kiri\Kiri;
 use Kiri\Pool\StopHeartbeatCheck;
+use RedisException;
 use Server\Events\OnWorkerExit;
 use Swoole\Timer;
 
@@ -45,7 +46,6 @@ class Redis implements StopHeartbeatCheck
 	 * @param string $prefix
 	 * @param int $timeout
 	 * @param int $read_timeout
-	 * @throws \ReflectionException
 	 */
 	public function __construct(public string $host, public int $port, public int $database = 0,
 	                            public string $auth = '', public string $prefix = '', public int $timeout = 30,
@@ -105,7 +105,7 @@ class Redis implements StopHeartbeatCheck
 	 * @param string $name
 	 * @param array $arguments
 	 * @return mixed
-	 * @throws RedisConnectException
+	 * @throws RedisConnectException|RedisException
 	 */
 	public function __call(string $name, array $arguments)
 	{
@@ -119,13 +119,14 @@ class Redis implements StopHeartbeatCheck
 	/**
 	 * @return \Redis
 	 * @throws RedisConnectException
+	 * @throws RedisException
 	 */
 	public function _pdo(): \Redis
 	{
 		if ($this->_timer === -1) {
 			$this->heartbeat_check();
 		}
-		if (!($this->pdo instanceof \Redis)) {
+		if (!($this->pdo instanceof \Redis) || !$this->pdo->ping('isOk')) {
 			$this->pdo = $this->newClient();
 		}
 		return $this->pdo;