Memcached.php

Go to the documentation of this file.

<?php

declare(strict_types=1);

namespace ILIAS\Cache\Adaptor;

use ILIAS\Cache\Config;

class Memcached extends BaseAdaptor implements Adaptor
{
    private const PERSISTENT_ID = 'ilias_cache';
    private ?\Memcached $server = null;

    public function __construct(Config $config)
    {
        parent::__construct($config);
        if (!class_exists(\Memcached::class)) {
            return;
        }
        if ($config->getNodes() === []) {
            return;
        }
        $this->initServer($config);
    }


    public function isAvailable(): bool
    {
        return class_exists(\Memcached::class) && $this->server !== null && $this->server->getVersion() !== false;
    }

    public function has(string $container, string $key): bool
    {
        return $this->server->get($this->buildKey($container, $key)) !== false;
    }

    public function get(string $container, string $key): ?string
    {
        return $this->server->get($this->buildKey($container, $key)) ?: null;
    }

    public function set(string $container, string $key, string $value, int $ttl): void
    {
        $this->server->set($this->buildKey($container, $key), $value, $ttl);
    }

    public function delete(string $container, string $key): void
    {
        $this->server->delete($this->buildKey($container, $key), 0);
    }

    public function flushContainer(string $container): void
    {
        $prefix = $this->buildContainerPrefix($container);
        foreach ($this->server->getAllKeys() as $key) {
            if (str_starts_with((string) $key, $prefix)) {
                $this->server->set($key, false, 0);
            }
        }
        foreach ($this->server->getAllKeys() as $key) {
            if (str_starts_with((string) $key, $prefix)) {
                $this->server->get(
                    $key
                ); // invalidates the key, see https://www.php.net/manual/en/memcached.expiration.php
            }
        }
        $this->server->flushBuffers();
        // $this->lock(1);// see https://github.com/memcached/memcached/issues/307
    }

    public function flush(): void
    {
        $this->server->flush();
    }

    protected function initServer(Config $config): void
    {
        $this->server = new \Memcached(self::PERSISTENT_ID);
        $nodes = $config->getNodes();
        foreach ($nodes as $node) {
            $this->server->addServer(
                $node->getHost(),
                $node->getPort(),
                $node->getWeight() ?? 100 / count($nodes)
            );
        }
    }
}