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