Memcache 일관성 hash_php 팁의 PHP 구현 방법

이 기사의 예에서는 Memcache 일관성 해싱의 PHP 구현 방법을 설명합니다. 참고할 수 있도록 모든 사람과 공유하세요. 세부 내용은 다음과 같습니다.

최근 배포에 관한 기사를 읽다가 PHP를 사용하여 일관된 해싱을 구현해 보았습니다. 예전에는 제작 과정에서 Memcache를 추가하거나 삭제할 때 가장 원시적인 해시 모듈러스를 사용하는 것이 일반적이었습니다. 모든 데이터는 유효하지 않습니다. 일관된 해싱은 이 문제를 해결하고 유효하지 않은 데이터를 최소화하는 것입니다.

PHP 구현에는 효율성이 부족한 부분이 있습니다. 높은 효율성을 원한다면 확장 기능을 작성하는 것이 좋습니다

테스트 결과, 5개의 Memcache, 각 Memcache는 100개의 가상 노드를 생성하고 1000회 설정 및 가져옵니다. 이는 단일 Memcache의 직접 설정 및 가져오기보다 5배 느리므로 효율성은 평균이며 최적화가 필요합니다!

이 글을 읽기 전에 이진 검색 방법을 알아두는 것이 가장 좋습니다.

구현 과정:

해싱을 위한 Memcache 구성 IP 포트 가상 노드 일련 번호, crc32를 사용하여 폐쇄 루프를 형성합니다.
조작할 키에 crc32를 수행합니다
가상 노드 링에서 가장 가까운 가상 노드를 찾는 이분법
가상 노드에서 실제 Memcache IP와 포트를 추출하여 단일 연결을 만듭니다

코드 복사 코드는 다음과 같습니다.

클래스 memcacheHashMap {
         비공개 $_node = array();
         비공개 $_nodeData = array();
         비공개 $_keyNode = 0;
        비공개 $_memcache = null;
//각 물리적 서버에서 생성된 가상 노드 수 [참고: 노드가 많을수록 캐시 배포의 균일성이 좋아집니다. 동시에 set get 작업은 더 많은 리소스를 소비합니다. 물리적 서버가 10개인 경우 200개는 더 많습니다. 합리적]
         비공개 $_virtualNodeNum = 200;
         비공개 함수 __construct() {
                    $config = array(//5개의 Memcache 서버
'127.0.0.1:11211',
'127.0.0.1:11212',
'127.0.0.1:11213',
'127.0.0.1:11214',
'127.0.0.1:11215'
                                                  ​ (!$config)가 새로운 Exception('Cache config NULL')을 발생시키는 경우;
foreach ($config를 $key => $value로) {
for ($i = 0; $i < $this->_virtualNodeNum; $i ) {
$this->_node[sprintf("%u", crc32($value . '_' . $i))] = $value . '_' . $i;//Loop는 각 Memcache 서버 가상 노드에 대해 200을 생성합니다.
|                 }
KSORT ($ this-& gt; _Node) // 키 이름으로 생성된 가상 노드 1,000개를 작은 것부터 큰 것 순으로 정렬
}
​​​​ //이 클래스를 인스턴스화
           정적 공개 함수 getInstance() {
                    static $memcacheObj = null;
If (!is_object($memcacheObj)) {
$memcacheObj = 새로운 자기();
                }
                    $memcacheObj 반환;
}
//전달된 키를 기반으로 해당 가상 노드의 위치를 ​​찾습니다
         비공개 함수 _connectMemcache($key) {
$this->_nodeData = array_keys($this->_node);//모든 가상 노드의 키 배열
                   $this->_keyNode = sprintf("%u", crc32($key));//키의 해시 값 계산
                   $nodeKey = $this->_findServerNode();//해당 가상 노드 찾기
| If ($this->_keyNode > end($this->_nodeData)) {
$this->_keyNode -= end($this->_nodeData);
$nodeKey2 = $this->_findServerNode();
If (abs($nodeKey2 - $this->_keyNode) < abs($nodeKey - $this->_keyNode)) $nodeKey = $nodeKey2;
                }
                var_dump($this->_node[$nodeKey]);
list($config, $num) = 폭발('_', $this->_node[$nodeKey]);
(!$config)가 새로운 예외를 발생시키는 경우('캐시 구성 오류');
If (!isset($this->_memcache[$config])) {
$this->_memcache[$config] = 새로운 Memcache;
list($host, $port) = 폭발(':', $config);
$this->_memcache[$config]->connect($host, $port);
                }
                    $this->_memcache[$config];
반환 }
//생체인식 방식은 주어진 값을 기반으로 가장 가까운 가상 노드 위치를 찾는다
          비공개 함수 _findServerNode($m = 0, $b = 0) {
                 $total = count($this->_nodeData);
If ($total != 0 && $b == 0) $b = $total - 1;
($m                     $avg = intval(($m $b) / 2);
($this->_nodeData[$avg] == $this->_keyNode)가 $this->_nodeData[$avg];
를 반환하는 경우 elseif ($this->_keyNode < $this->_nodeData[$avg] && ($avg-1 >= 0)) return $this->_findServerNode($m, $avg-1);
                         그렇지 않으면 $this->_findServerNode($avg 1, $b)를 반환합니다.
            }
if (abs($this->_nodeData[$b] - $this->_keyNode) < abs($this->_nodeData[$m] - $this->_keyNode)) return $this-> ;_nodeData[$b];
                그렇지 않으면 $this->_nodeData[$m];
를 반환합니다.         }
        공개 함수 세트($key, $value, $expire = 0) {
                return $this->_connectMemcache($key)->set($key, json_encode($value), 0, $expire);
        }
        공개 함수 추가($key, $value, $expire = 0) {
                return $this->_connectMemcache($key)->add($key, json_encode($value), 0, $expire);
        }
        공개 함수 get($key) {
                return json_decode($this->_connectMemcache($key)->get($key), true);
        }
        공개 함수 삭제($key) {
                return $this->_connectMemcache($key)->delete($key);
        }
}
$runData['BEGIN_TIME'] = 마이크로타임(true);
//测试一万次set加get
for($i=0;$i<10000;$i ) {
        $key = md5(mt_rand());
        $b = memcacheHashMap::getInstance()->set($key, time(), 10);
}
var_dump(number_format(microtime(true) - $runData['BEGIN_TIME'],6));
$runData['BEGIN_TIME'] = 마이크로타임(true); $m= 새로운 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);
}
var_dump(number_format(microtime(true) - $runData['BEGIN_TIME'],6));
?>

希望本文所述对大家程序设计有所帮助。