分布式memcached-虚拟节点

时间:2024-10-22 22:03:26

1.通过memcached服务器下的不同端口来达到模拟多台服务器的效果

2.假设现在有三台memcached服务器,本地分别使用11211,11212,11213三个端口来模拟

①打开端口

分布式memcached-虚拟节点

②连接端口

分布式memcached-虚拟节点

③以同样的方式别打开三台,不要关闭cmd窗口,记得ctrl+】回显

3.上代码

 <?php
//一致性哈希算法
class Memcached1{
protected $server=['11211','11212','11213'];
protected $node=[];
protected $memcache;
//memcached服务器连接
public function __construct()
{ } protected function MemcachedConnect($port){
$this->memcache=new Memcache();
$a=$this->memcache->connect('localhost',$port);
}
//产生虚拟节点
public function GetServer(){
foreach ($this->server as $k=>$v){
for ($i=1;$i<=100;$i++){
$m=sprintf("%u", crc32($v.'_'.$i));
$this->node[$m]=$v;
}
}
ksort($this->node);
return $this->node;
}
//获取缓存存放节点
protected function GetPort($key){
$key=sprintf("%u",crc32($key));
$nodelist=array_keys($this->node);//返回一个包含数组所有键名的数组(从小到大)
foreach ($this->node as $k=>$v){
if ($key>max($nodelist)){
$port=$this->node[$nodelist[0]];
break;
}
if ($key<=$k){
$port=$v;
break;
}
}
return $port;
}
//生成缓存
public function SetMemcached($key,$value){
//生成虚拟节点
$this->GetServer();
//获得数据存放端口
$p=$this->GetPort($key);
//链接memcached服务器
$this->MemcachedConnect($p);
$this->memcache->set($key,$value);
echo "ok";
}
public function get($key){
//生成虚拟节点
$this->GetServer();
//获得数据存放端口
$p=$this->GetPort($key);
//链接memcached服务器
$this->MemcachedConnect($p);
return $this->memcache->get($key); }
}
$m=new Memcached1;
//$list=$m->GetServer();
echo "<pre>";
//print_r($m->node);
$m->SetMemcached('aaa','aaa');
//echo $m->get('aaa');

4.总结

  虚拟节t点的思想是基于一体哈希算法,相比较于传统的一体哈希算法,在服务器挂掉其中一台或者几台时,不会造成仅存的服务器因压力骤大而停机,也比传统的取余计算方式合理

在某台服务器停机时,会将压力合理的分摊到其他的服务器