php實現 · php

[TOC] # 接口 ~~~ <?php /** * 一致性hash實現接口 */ Interface ConsistentHash { //將字符串轉為hash值 public function cHash($str); //添加一臺服務器到服務器列表中 public function addServer($server); //從服務器刪除一臺服務器 public function removeServer($key); //在當前的服務器列表中找到合適的服務器存放數據 public function lookup($key); } ~~~ 這個接口分別定義了4個方法，cHash（將字符串處理為hash值）、addServer（增加一臺服務器）、removeServer（移除一臺服務器）、lookup（找到一臺服務器來存儲數據）下面給出一個該接口的具體實現 # 實現類 ~~~ <?php /** * 具體一致性hash實現 */ class MyConsistentHash implements ConsistentHash { public $serverList = []; //服務器列表 public $virtualPos = []; //虛擬節點的位置 public $virtualPosNum = 5; //每個節點對應5個虛節點 //將字符串轉換為32位無符號整數hash值 public function cHash($str) { $str = md5($str); return sprintf('%u', crc32($str)); } /** * 在當前的服務器列表中找到合適的服務器存放數據 * @param $key 鍵名 * @return mixed 返回服務器IP地址 */ public function lookup($key) { //落點的hash值 $point = $this->cHash($key); //先取圓環上最小的一個節點當成結果 $finalServer = current($this->virtualPos); foreach ($this->virtualPos as $pos => $server) { if ($point <= $pos) { $finalServer = $server; break; } } //重置圓環的指針為第一個 reset($this->virtualPos); return $finalServer; } /** * 添加一臺服務器到服務器列表中 * @param $server 服務器IP地址 * @return bool */ public function addServer($server) { if (!isset($this->serverList[$server])) { for($i=0; $i<$this->virtualPosNum; ++$i) { $pos = $this->cHash($server.'-'.$i); $this->virtualPos[$pos] = $server; $this->serverList[$server][] = $pos; } ksort($this->virtualPos,SORT_NUMERIC); } return true; } /** * 移除一臺服務器（循環所有的虛節點，刪除值為該服務器地址的虛節點） * @param $key * @return bool */ public function removeServer($key) { if(isset($this->serverList[$key])) { //刪除對應虛節點 foreach($this->serverList[$key] as $pos) { unset($this->virtualPos[$pos]); } //刪除對應服務器 unset($this->serverList[$key]); } return TRUE; } } ~~~ # 測試下 ~~~ $hashServer = new MyConsistentHash(); $hashServer->addServer('192.168.1.1'); $hashServer->addServer('192.168.1.2'); $hashServer->addServer('192.168.1.3'); $hashServer->addServer('192.168.1.4'); $hashServer->addServer('192.168.1.5'); $hashServer->addServer('192.168.1.6'); $hashServer->addServer('192.168.1.7'); $hashServer->addServer('192.168.1.8'); $hashServer->addServer('192.168.1.9'); $hashServer->addServer('192.168.1.10'); echo "增加十臺服務器192.168.1.1~192.168.1.10 "; echo "保存 key1 到 server :".$hashServer->lookup('key1') . ' '; echo "保存 key2 到 server :".$hashServer->lookup('key2') . ' '; echo "保存 key3 到 server :".$hashServer->lookup('key3') . ' '; echo "保存 key4 到 server :".$hashServer->lookup('key4') . ' '; echo "保存 key5 到 server :".$hashServer->lookup('key5') . ' '; echo "保存 key6 到 server :".$hashServer->lookup('key6') . ' '; echo "保存 key7 到 server :".$hashServer->lookup('key7') . ' '; echo "保存 key8 到 server :".$hashServer->lookup('key8') . ' '; echo "保存 key9 到 server :".$hashServer->lookup('key9') . ' '; echo "保存 key10 到 server :".$hashServer->lookup('key10') . ' '; echo '<hr />'; echo "移除一臺服務器192.168.1.2 "; $hashServer->removeServer('192.168.1.2'); echo "保存 key1 到 server :".$hashServer->lookup('key1') . ' '; echo "保存 key2 到 server :".$hashServer->lookup('key2') . ' '; echo "保存 key3 到 server :".$hashServer->lookup('key3') . ' '; echo "保存 key4 到 server :".$hashServer->lookup('key4') . ' '; echo "保存 key5 到 server :".$hashServer->lookup('key5') . ' '; echo "保存 key6 到 server :".$hashServer->lookup('key6') . ' '; echo "保存 key7 到 server :".$hashServer->lookup('key7') . ' '; echo "保存 key8 到 server :".$hashServer->lookup('key8') . ' '; echo "保存 key9 到 server :".$hashServer->lookup('key9') . ' '; echo "保存 key10 到 server :".$hashServer->lookup('key10') . ' '; echo '<hr />'; echo "移除一臺服務器192.168.1.6 "; $hashServer->removeServer('192.168.1.6'); echo "保存 key1 到 server :".$hashServer->lookup('key1') . ' '; echo "保存 key2 到 server :".$hashServer->lookup('key2') . ' '; echo "保存 key3 到 server :".$hashServer->lookup('key3') . ' '; echo "保存 key4 到 server :".$hashServer->lookup('key4') . ' '; echo "保存 key5 到 server :".$hashServer->lookup('key5') . ' '; echo "保存 key6 到 server :".$hashServer->lookup('key6') . ' '; echo "保存 key7 到 server :".$hashServer->lookup('key7') . ' '; echo "保存 key8 到 server :".$hashServer->lookup('key8') . ' '; echo "保存 key9 到 server :".$hashServer->lookup('key9') . ' '; echo "保存 key10 到 server :".$hashServer->lookup('key10') . ' '; echo '<hr />'; echo "移除一臺服務器192.168.1.8 "; $hashServer->removeServer('192.168.1.8'); echo "保存 key1 到 server :".$hashServer->lookup('key1') . ' '; echo "保存 key2 到 server :".$hashServer->lookup('key2') . ' '; echo "保存 key3 到 server :".$hashServer->lookup('key3') . ' '; echo "保存 key4 到 server :".$hashServer->lookup('key4') . ' '; echo "保存 key5 到 server :".$hashServer->lookup('key5') . ' '; echo "保存 key6 到 server :".$hashServer->lookup('key6') . ' '; echo "保存 key7 到 server :".$hashServer->lookup('key7') . ' '; echo "保存 key8 到 server :".$hashServer->lookup('key8') . ' '; echo "保存 key9 到 server :".$hashServer->lookup('key9') . ' '; echo "保存 key10 到 server :".$hashServer->lookup('key10') . ' '; echo '<hr />'; echo "移除一臺服務器192.168.1.2 "; $hashServer->removeServer('192.168.1.2'); echo "保存 key1 到 server :".$hashServer->lookup('key1') . ' '; echo "保存 key2 到 server :".$hashServer->lookup('key2') . ' '; echo "保存 key3 到 server :".$hashServer->lookup('key3') . ' '; echo "保存 key4 到 server :".$hashServer->lookup('key4') . ' '; echo "保存 key5 到 server :".$hashServer->lookup('key5') . ' '; echo "保存 key6 到 server :".$hashServer->lookup('key6') . ' '; echo "保存 key7 到 server :".$hashServer->lookup('key7') . ' '; echo "保存 key8 到 server :".$hashServer->lookup('key8') . ' '; echo "保存 key9 到 server :".$hashServer->lookup('key9') . ' '; echo "保存 key10 到 server :".$hashServer->lookup('key10') . ' '; echo '<hr />'; echo "增加一臺服務器192.168.1.11 "; $hashServer->addServer('192.168.1.11'); echo "保存 key1 到 server :".$hashServer->lookup('key1') . ' '; echo "保存 key2 到 server :".$hashServer->lookup('key2') . ' '; echo "保存 key3 到 server :".$hashServer->lookup('key3') . ' '; echo "保存 key4 到 server :".$hashServer->lookup('key4') . ' '; echo "保存 key5 到 server :".$hashServer->lookup('key5') . ' '; echo "保存 key6 到 server :".$hashServer->lookup('key6') . ' '; echo "保存 key7 到 server :".$hashServer->lookup('key7') . ' '; echo "保存 key8 到 server :".$hashServer->lookup('key8') . ' '; echo "保存 key9 到 server :".$hashServer->lookup('key9') . ' '; echo "保存 key10 到 server :".$hashServer->lookup('key10') . ' '; echo '<hr />'; ~~~ 可以，看到，使用一致性哈希后，無認是增加服務器還是減少服務器都最大程度的保證了數據的完整性、均勻性.