Predis Alias Sharding

Question

我试图使用Predis sharding别名，因为described here。我的代码基本相同，但我只返回空数组。我的哈希键需要在他们周围吗？ （编辑：不，就试了一下）

$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. 
    }); 

编辑：它也可以，如果我只放了一台服务器$servers阵列英寸所以看起来哈希算法并不正确。当我在nodehash的返回值前面抛出一些回声时，我可以看到它正在返回别名。

Answer 1

分配一个dim_provider别名到Redis的连接，并试图从服务器获取一个关键命名dim_provider是两回事。

在您的脚本中，您尝试使用连接别名（而不是通常的ip:port对）设置Redis实例的群集来计算您的密钥空间在作为data shards的多个Redis服务器之间的分布情况。使用此设置，密钥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); 
    });