This commit is contained in:
2021-01-04 16:21:31 +08:00
parent 0bd6441927
commit 31263b425d
2 changed files with 19 additions and 19 deletions
+5 -11
View File
@@ -47,20 +47,14 @@ class Redis extends Component
*/
public function createPool()
{
try {
$connections = Snowflake::app()->pool->redis;
$connections = Snowflake::app()->pool->redis;
$config = $this->get_config();
$name = $config['host'] . ':' . $config['prefix'] . ':' . $config['databases'];
$config = $this->get_config();
$name = $config['host'] . ':' . $config['prefix'] . ':' . $config['databases'];
$length = env('REDIS.POOL_LENGTH', 100);
$length = env('REDIS.POOL_LENGTH', 100);
$connections->initConnections('redis:' . $name, true, $length);
} catch (\Throwable $exception) {
var_dump($exception->getMessage());
var_dump($exception->getFile());
var_dump($exception->getLine());
}
$connections->initConnections('redis:' . $name, true, $length);
}
+14 -8
View File
@@ -36,14 +36,20 @@ class Connection extends Pool
*/
public function Heartbeat_detection($timer)
{
$this->creates = $timer;
if ($this->lastTime == 0) {
return;
}
if ($this->lastTime + 600 < time()) {
$this->flush(0);
} else if ($this->lastTime + 300 < time()) {
$this->flush(2);
try {
$this->creates = $timer;
if ($this->lastTime == 0) {
return;
}
if ($this->lastTime + 600 < time()) {
$this->flush(0);
} else if ($this->lastTime + 300 < time()) {
$this->flush(2);
}
} catch (\Throwable $exception) {
var_dump($exception->getMessage());
var_dump($exception->getFile());
var_dump($exception->getLine());
}
}