Predis Alias ​​Sharding

Question

Я пытаюсь использовать Predis sharding по псевдониму, как described here. Мой код в основном идентичен, но я возвращаю только пустые массивы. Могут ли мои хэш-ключи {} вокруг них? (EDIT: Нет, просто попытался его)

$api->get("/test", function() { 

    $servers = [ 
     ["alias" => "metadata", "port" => 6380], 
     ["alias" => "relations", "port" => 6381], 
     ["alias" => "dim_provider", "port" => 6382], 
     ["alias" => "dim_revctrcode", "port" => 6383], 
     ["alias" => "dim_enccode", "port" => 6384], 
     ["alias" => "dim_pos", "port" => 6385] 
    ]; 

    $options = [ 

     "nodehash" => function ($connection) { return $connection->getParameters()->alias; }, 

     "cluster" => function ($options) { 
     $replicas = Predis\Cluster\Distribution\HashRing::DEFAULT_REPLICAS; 
     $hashring = new Predis\Cluster\Distribution\HashRing($replicas, $options->nodehash); 
     $cluster = new Predis\Connection\PredisCluster($hashring); 

     return $cluster; 
     } 
    ]; 

    $redis = new Predis\Client($servers, $options); 

    try { 
     $test = $redis->scard("dim_provider"); 
     print_r($test); // Prints 0 for scard or empty Array for hgetall 
    } catch (Exception $e) { 
     print $e->getMessage(); 
    } 

    $redis = new Predis\Client(["port" => 6382]); 
    $test = $redis->scard("dim_provider"); 
    print_r($test); // Works. 
    }); 

EDIT: Это также работает, если я только положить один сервер в $servers массиве. Поэтому кажется, что хеширование работает неправильно. Когда я бросаю некоторые эхо-сигналы перед возвращаемым значением в nodehash, я вижу, что он возвращает псевдоним.

Answer 1

Назначение dim_providerпсевдоним к соединению Redis и пытается получить ключ имени dim_provider от сервера это две разные вещи.

В вашем скрипте вы пытаетесь настроить кластер экземпляров Redis с использованием псевдонимов соединений (вместо обычных пар ip:port), чтобы рассчитать распределение вашего пространства ключей между несколькими серверами Redis, действующими как ваш data shards. Используя эту настройку, ключ dim_provider оканчивается соответствующим алгоритму распределения и может быть сохранен на любом из 6 серверов, составляющих ваш кластер, и определен в массиве $servers.

Answer 2

Я хотел добавить, насколько просто было легко реализовать мою стратегию кластеризации, когда nrk достал меня на правильном пути. Это действительно хорошо написанная библиотека.

$api->get("/test", function() { 

    Class KeyCluster extends Predis\Connection\PredisCluster { 

     public function __construct() { 
     $this->pool = Array(); 
     } 

     public function add (Predis\Connection\SingleConnectionInterface $connection) { 
     $parameters = $connection->getParameters(); 
     if (isset($parameters->table)) { 
      $this->pool[$parameters->table] = $connection; 
     } else { 
      $this->pool[] = $connection; 
     } 
     } 

     public function getConnection (Command\CommandInterface $command) { 
     $key = $command->getArgument(0); 
     $table = explode(":", $key)[0]; 
     return isset($this->pool[$table]) ? $this->pool[$table] : null; 
     } 
    } 

    $redis = new Predis\Client([ 
     "tcp://127.0.0.1:6382?table=dim_provider", 
     "tcp://127.0.0.1:6383?table=dim_pos" 
    ],[ 
     "cluster" => new KeyCluster 
    ]); 

    $result = $redis->scard("dim_provider"); 
    print_r($result); 
    });