memcachedclustercache.php

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

<?php
 
namespace Bitrix\Cluster;
 
use Bitrix\Main\Loader;
 
class MemcachedClusterCache extends \Bitrix\Main\Data\CacheEngineMemcached
{
    private bool $bQueue = false;
    private static null|array $servers = null;
    private static array $otherGroups = [];
 
    public function __construct($options = [])
    {
        $sid = 'bxcluster';
        require_once \Bitrix\Main\Loader::getLocal('modules/cluster/lib/clustercacheconfig.php');
 
        if (static::$servers === null)
        {
            static::$servers = ClusterCacheConfig::getInstance('memcached')->getConfig(true, self::$otherGroups);
        }
 
        if (defined('BX_MEMCACHED_CLUSTER'))
        {
            $sid = BX_MEMCACHED_CLUSTER;
        }
 
        if (!empty(static::$servers))
        {
            parent::__construct([
                'servers' => static::$servers,
                'type' => 'memcached',
                'sid' => $sid
            ]);
        }
 
        if (defined('BX_CLUSTER_GROUP'))
        {
            $this->bQueue = true;
        }
    }
 
    public function QueueRun($param1, $param2, $param3)
    {
        $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::$otherGroups as $group_id => $_)
                {
                    \CClusterQueue::Add($group_id, 'MemcachedClusterCache', $baseDir, $initDir, $filename);
                }
            }
 
            parent::clean($baseDir, $initDir, $filename);
        }
    }
}