栏目分类:
子分类:
返回
名师互学网用户登录
快速导航关闭
当前搜索
当前分类
子分类
实用工具
热门搜索
名师互学网 > IT > 软件开发 > 后端开发 > PHP

php memcached 一致性hash

PHP 更新时间: 发布时间: IT归档 最新发布 模块sitemap 名妆网 法律咨询 聚返吧 英语巴士网 伯小乐 网商动力

php memcached 一致性hash


class FlexiHash{private $_replicas = 200;private $_hasher = null;private $_targetCount = 0;private $_positionToTarget array();private $_targetToPositions array();private $_positionToTargetSorted = false;public function __construct(FlexiHash_Hasher $hasher=null, $replicas = null){// hash方法$this->_hasher = $hasher?$hashernew FlexiHash_Crc32Hasher();// 虚拟节点的个数if (!empty($replicas)){$this->_replicas = $replicas;}}public function addTarget($target){if (isset($this->_targetToPositions[$target])) {throw new FlexiHash_Exception("Target $target already exists.");}$this->_targetToPositions[$target] = array();for ($i = 0; $i $this->_replicas; $i++) {// 根据规定的方法hash$position $this->_hasher->hash($target.$i);// 虚拟节点对应的真实的节点$this->_positionToTarget[$position] = $target;// 真实节点包含的虚拟节点$this->_targetToPositions[$target][] = $position;}$this->_positionToTargetSorted = false;// 真实节点个数$this->_targetCount++;return $this;}public function addTargets($targets){foreach ($targets as $target){$this->addTarget($target);}return $this;}public function removeTarget($target){if (!isset($this->_targetToPositions[$target])){throw new FlexiHash_Exception("target $target does not existn");}foreach($this->_targetToPositions[$targetas $position){unset($this->_positionToTarget[$position]);}unset($this->_targetToPositions[$target]);$this->_targetCount--;return $this;}public function getAllTargets(){return array_keys($this->_targetToPositions);}public function lookup($resource){$targets $this->lookupList($resource, 1);if (empty($targets)){throw new FlexiHash_Exception("no targets exist");}return $targets[0];}public function lookupList($resource$requestedCount){if (!$requestedCount) {throw new FlexiHash_Exception('Invalid count requested');}if (empty($this->_positionToTarget)) {return array();}// 直接节点只有一个的时候if ($this->_targetCount == 1 ){return array_unique(array_values($this->_positionToTarget));}// 获取当前key进行hash后的值$resourcePosition $this->_hasher->hash($resource);$results array();$collect = false;$this->_sortPositionTargets();// 查找与$resourcePosition 相等或比其大并且是最小的数foreach($this->_positionToTarget as $key => $value){if (!$collect && $key $resourcePosition){$collect = true;}if ($collect && !in_array($value$results)){$results[] = $value;}// 找到$requestedCount 或个数与真实节点数量相同if (count($results) == $requestedCount || count($results) == $this->_targetCount){return $results;}}// 如数量不够或者未查到,则从第一个开始,将$results中不存在前$requestedCount-count($results),设置为需要的节点foreach ($this->_positionToTarget as $key => $value){if (!in_array($value$results)){$results[] = $value;}if (count($results) == $requestedCount || count($results) == $this->_targetCount){return $results;}}return $results;}private function _sortPositionTargets(){if (!$this->_positionToTargetSorted){ksort($this->_positionToTarget, SORT_REGULAR);$this->_positionToTargetSorted = true;}}}// end classinterface FlexiHash_Hasher{public function hash($string);}class FlexiHash_Crc32Hasher implements FlexiHash_Hasher{public function hash($string){return sprintf("%u",crc32($string));}}class FlexiHash_Md5Hasher implements FlexiHash_Hasher{public function hash($string){return substr(md5($string), 0, 8);}}class FlexiHash_Exception extends Exception{}$runData['BEGIN_TIME'] = microtime(true);$key="lihuibin";for($i=0;$i<10;$i++) {$targetsArray array("127.0.0.1:11211","127.0.0.1:11212","127.0.0.1:11213","127.0.0.1:11214",#"127.0.0.1:11218");$flexiHashObj new FlexiHash(new FlexiHash_Crc32Hasher(),1);$result $flexiHashObj->addTargets($targetsArray);$key=$key."$i";$targets $flexiHashObj->lookup($key);var_dump($targets);#$key = md5(mt_rand());#$targets $flexiHashObj->lookup($key);#var_dump($targets);}echo "一致性hash:";var_dump(number_format(microtime(true) - $runData['BEGIN_TIME'],6));exit;$runData['BEGIN_TIME'] = microtime(true); $mnew Memcache;$m->connect('127.0.0.1', 11211); for($i=0;$i<10000;$i++) {$key = md5(mt_rand());$b $m->set($key, time(), 0, 10);}echo "单台机器:";var_dump(number_format(microtime(true) - $runData['BEGIN_TIME'],6));?>

转载请注明:文章转载自 www.mshxw.com
本文地址:https://www.mshxw.com/it/229330.html
我们一直用心在做
关于我们 文章归档 网站地图 联系我们

版权所有 (c)2021-2022 MSHXW.COM

ICP备案号:晋ICP备2021003244-6号