简体中文(ZH-CN) English(EN) 繁体中文(ZH-TW) 日本語(JA) 한국어(KO) Melayu(MS) Français(FR) Deutsch(DE)
집 > php教程 > PHP源码 > 본문

PHPhash一致性

PHP中文网
풀어 주다： 2016-05-22 17:22:20
원래의
940명이 탐색했습니다.

        跳至                   

_hasher = $hasher?$hasher: new 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 exist\n");
		}
		
		foreach($this->_targetToPositions[$target] as $position){
			unset($this->_positionToTarget[$position]);
		}
		
		unset($this->_targetToPositions[$target]);
		
		$this->_targetCount--;
		
		return $this;
	}
	
	/**
	 * 获取所有节点
	 * 
	 */
	public function getAllTargets(){
		return array_keys($this->_targetToPositions);
	}
	
	
	/**
	 * 根据key查找hash到的真实节点
	 * 
	 */
	public function lookup($resource){
		$targets = $this->lookupList($resource, 1);
		
		if (empty($targets)){
			throw new FlexiHash_Exception("no targets exist");
		}
		
		return $targets[0];
	}
	
	/**
	 * 查找资源存在的节点
	 * 
	 * 描述:根据要求的数量，返回与$resource哈希后数值相等或比其大并且是最小的数值对应的节点，若不存在或数量不够，则从虚拟节点排序后的前一个或多个
	 */
	public function lookupList($resource, $requestedCount){
		
		if (!$requestedCount) {
			throw new FlexiHash_Exception(&#39;Invalid count requested&#39;);
		}
		
		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 class

/**
 * hash方式
 */
interface 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[&#39;BEGIN_TIME&#39;] = microtime(true);

for($i=0;$iaddTargets($targetsArray);
	  $key = md5(mt_rand());
	 $targets = $flexiHashObj->lookup($key);
//	var_dump($targets);
	 
	 

}
	echo "一致性hash:";
var_dump(number_format(microtime(true) - $runData[&#39;BEGIN_TIME&#39;],6));




$runData[&#39;BEGIN_TIME&#39;] = microtime(true); 
$m= new Memcache;
$m->connect(&#39;127.0.0.1&#39;, 11211); 
for($i=0;$iset($key, time(), 0, 10);
}
echo "单台机器:";
var_dump(number_format(microtime(true) - $runData[&#39;BEGIN_TIME&#39;],6));
?>
로그인 후 복사

2. [代码]虚拟节点的hash一致性 

$value){  
              
            for ($i = 0; $i < $this->_virtualNodeNum; $i++){  
                $this->_node[sprintf("%u", crc32($value."#".$i))] = $value."#".$i;  
            }  
        }  
          
        // 排序  
        ksort($this->_node);  
          
//      print_r($this->_node);  
    }  
      
    // 单例模式  
    static public function getInstance(){  
        static $memcacheObj = null;  
        if (!is_object($memcacheObj)) {  
            $memcacheObj = new self();  
        }  
        return $memcacheObj;  
    }  
      
    private function _connectMemcache($key){  
        $this->_nodeData = array_keys($this->_node);  
//      echo "all node:\n";  
//      print_r($this->_nodeData);  
        $this->_keyNode = sprintf("%u", crc32($key));  
//      $this->_keyNode = 1803717635;  
//      var_dump($this->_keyNode);  
          
        // 获取key值对应的最近的节点  
        $nodeKey = $this->_findServerNode(0, count($this->_nodeData)-1);  
//      var_dump($nodeKey);  
//      echo "$this->_keyNode :search node:$nodeKey  IP:{$this->_node[$nodeKey]}\n";  
          
        //获取对应的真实ip  
        list($config, $num) = explode("#", $this->_node[$nodeKey]);  
          
        if (empty($config)){  
            throw new Exception("serach ip config error");  
        }  
          
        if (!isset($this->_memcache[$config])){  
            $this->_memcache[$config] = new Memcache;  
            list($host, $port) = explode(":", $config);  
            $this->_memcache[$config]->connect($host, $port);  
        }  
          
        return $this->_memcache[$config];  
          
          
          
    }  
    /** 
     * 采用二分法从虚拟memcache节点中查找最近的节点 
     * @param int $low 开始位置 
     * @param int $high 结束位置 
     *  
     */  
    private function _findServerNode($low, $high){  
          
        // 开始下标小于结束下标  
        if ($low < $high){  
              
            $avg = intval(($low+$high)/2);  
              
            if ($this->_nodeData[$avg] == $this->_keyNode){  
                return $this->_nodeData[$avg];  
            }elseif ($this->_keyNode < $this->_nodeData[$avg]){  
                return $this->_findServerNode($low, $avg-1);  
            }else{  
                return $this->_findServerNode($avg+1, $high);  
            }  
        }else if(($low == $high)){  
            // 大于平均值  
            if ($low ==0 || $low == count($this->_nodeData)-1){  
                return $this->_nodeData[$low];  
            }  
//          var_dump($low);  
            if ($this->_nodeData[$low] < $this->_keyNode){  
                  
                if (abs($this->_nodeData[$low] - $this->_keyNode) < abs($this->_nodeData[$low+1]-$this->_keyNode)){  
                    return $this->_nodeData[$low];  
                }else{  
                    return $this->_nodeData[$low+1];  
                }  
          
            }else {  
                if (abs($this->_nodeData[$low] - $this->_keyNode) < abs($this->_nodeData[$low-1]-$this->_keyNode)){  
                    return $this->_nodeData[$low];  
                }else{  
                    return $this->_nodeData[$low-1];  
                }  
            }  
        }else{  
            if ( ($low == 0)&&($high < 0) ){  
                return $this->_nodeData[$low];  
            }  
          
            if (abs($this->_nodeData[$low] - $this->_keyNode) < abs($this->_nodeData[$high]-$this->_keyNode)){  
                return $this->_nodeData[$low];  
            }else{  
                return $this->_nodeData[$high];  
            }  
        }  
    }  
      
    public function set($key, $value, $expire=0){  
//  var_dump($key);  
        return $this->_connectMemcache($key)->set($key, json_encode($value), 0, $expire);  
    }  
      
      
    public function add($key, $vakue, $expire=0){  
        return $this->_connectMemcache($key)->add($key, json_encode($value), 0, $expire);  
    }  
      
    public function get($key){  
        return $this->_connectMemcache($key)->get($key, true);  
    }  
      
    public function delete($key){  
        return $this->_connectMemcache($key)->delete($key);  
    }  
      
          
      
}  
  
  
$runData[&#39;BEGIN_TIME&#39;] = microtime(true);  
//测试一万次set加get  
for($i=0;$iset($key, time(), 10);  
}  
echo "一致性hash:";  
var_dump(number_format(microtime(true) - $runData[&#39;BEGIN_TIME&#39;],6));  
$runData[&#39;BEGIN_TIME&#39;] = microtime(true);   
$m= new Memcache;  
$m->connect(&#39;127.0.0.1&#39;, 11211);   
for($i=0;$iset($key, time(), 0, 10);  
}  
echo "单台机器:";  
var_dump(number_format(microtime(true) - $runData[&#39;BEGIN_TIME&#39;],6));
로그인 후 복사

           

       

관련 라벨：
PHPhash一致性
원천：php.cn
이전 기사：使用mysqli方式进行数据库查询 다음 기사：实现简单的按天数，按星期按月份搜索的框框
본 웹사이트의 성명
본 글의 내용은 네티즌들의 자발적인 기여로 작성되었으며, 저작권은 원저작자에게 있습니다. 본 사이트는 이에 상응하는 법적 책임을 지지 않습니다. 표절이나 침해가 의심되는 콘텐츠를 발견한 경우 admin@php.cn으로 문의하세요.
저자별 최신 기사
최신 이슈
Laravel 9 및 Livewire 유효성 검사: 업데이트되지 않는 한 고유성 유효성 검사 다음 유효성 검사는 새 레코드를 생성할 때 작동하지만, 레코드를 업데이트할 때 Partner_code 및 Seed_code가 고유한 유효성 검사에서 중단됩니다. ...
에서 2023-11-09 17:41:05
0
2
204
Vue 개발 도구의 구성 요소 옆에 있는 성능 수치는 무엇입니까? Vue 개발 도구의 특정 기능에 대한 통찰력이나 리소스를 갖고 있는 사람이 있나요? 구성 요소 창에는 구성 요소가 표시되고 작은 빨간색과 노란색 사각형이 표시되며...
에서 2023-11-09 14:46:48
0
1
305
잡히지 않은 TypeError: 정의되지 않은 속성을 설정할 수 없습니다('innerHTML' 설정). "Continuous TextBox"(내 클래스에 의해 정의됨) 클래스의 요소에서 PHP를 사용하여 웹 페이지를 만들려고 합니다. 클릭하면 다른...
에서 2023-11-08 21:06:09
0
1
278
Vue js: 문제 해결 - 정의되지 않은 '$refs' 속성 읽기 템플릿에 참조가 있어도 정의되지 않은 속성('$refs' 읽기)을 읽을 수 없다는 오류가 발생합니다. 이는 Vue 마운트 후크를 사용해야 한다는 뜻인가요? <...
에서 2023-11-07 23:34:12
0
1
305
Vue I18n을 사용하여 구성 요소 속성/속성을 변환하는 방법 구성 요소의 들어오는 속성/속성을 변환하는 방법은 무엇입니까? 예를 들어 제목 및 설명 속성이 정의된 카드 구성 요소가 있습니다. <!--내 카드 구성요소-...
에서 2023-11-07 12:47:10
0
2
163
관련 주제
더>
인기 추천
인기 튜토리얼
더>
관련 튜토리얼
인기 추천
최신 강좌
최신 다운로드
더>
웹 효과
웹사이트 소스 코드
웹사이트 자료
프론트엔드 템플릿
회사 소개 부인 성명 Sitemap
PHP 중국어 웹사이트：공공복지 온라인 PHP 교육，PHP 학습자의 빠른 성장을 도와주세요！