redis_cache.php

См. документацию.

<?php
 
use Bitrix\Main\Loader;
use Bitrix\Main\Config\Configuration;
 
class CPHPCacheRedisCluster extends \Bitrix\Main\Data\CacheEngineRedis
{
    private bool $bQueue = false;
    private static null|array $servers = null;
    private static array $otherCroups = [];
 
    public function __construct()
    {
        $sid = 'bxcluster';
        require_once Bitrix\Main\Loader::getLocal('modules/cluster/lib/clustercacheconfig.php');
 
        if (static::$servers === null)
        {
            static::$servers = Bitrix\Cluster\ClusterCacheConfig::getInstance('redis')->getConfig(true, static::$otherCroups);
        }
 
        if (defined('BX_REDIS_CLUSTER'))
        {
            $sid = BX_REDIS_CLUSTER;
        }
 
        if (!empty(static::$servers))
        {
            parent::__construct([
                'servers' => static::$servers,
                'sid' => $sid
            ]);
        }
 
        if (defined('BX_CLUSTER_GROUP'))
        {
            $this->bQueue = true;
        }
    }
 
    protected function configure($options = []): array
    {
        $config = parent::configure($options);
 
        $cacheConfig = Configuration::getValue('cache');
 
        $config['failover'] = $cacheConfig['failover'] ?? RedisCluster::FAILOVER_NONE;
 
        return $config;
    }
 
    public function QueueRun($param1, $param2, $param3): void
    {
        $this->bQueue = false;
        $this->clean($param1, $param2, $param3);
    }
 
    public function clean($baseDir, $initDir = false, $filename = false)
    {
        if ($this->isAvailable())
        {
            if ($this->bQueue && Loader::includeModule('cluster'))
            {
                foreach (self::$otherCroups as $group_id => $_)
                {
                    CClusterQueue::Add($group_id, 'CPHPCacheRedisCluster', $baseDir, $initDir, $filename);
                }
            }
 
            parent::clean($baseDir, $initDir, $filename);
        }
    }
}