redisconnection.php

<?php
 
namespace Bitrix\Main\Data;
 
class RedisConnection extends NosqlConnection
{
    protected $configurator;
 
    public function __construct(array $configuration)
    {
        parent::__construct($configuration);
 
        $this->configurator = new Configurator\RedisConnectionConfigurator($this->getConfiguration());
    }
 
    protected function connectInternal()
    {
        $this->resource = $this->configurator->createConnection();
        $this->isConnected = (bool)$this->resource;
    }
 
    protected function disconnectInternal()
    {
        if ($this->isConnected())
        {
            $this->resource->close();
            $this->resource = null;
            $this->isConnected = false;
        }
    }
 
    public function get($key)
    {
        if (!$this->isConnected())
        {
            $this->connect();
        }
 
        return $this->resource->get($key);
    }
 
    public function set($key, $value)
    {
        if (!$this->isConnected())
        {
            $this->connect();
        }
 
        return $this->resource->set($key, $value);
    }
}