一致性哈希算法的php实现与分析-算法
<?php
/*
* 一致性哈希算法
* 过程:
* 1,抽象一个圆,然后把服务器节点按一定算法得到整数有序顺时针放到圆上,圆环用2^32 个点来进行均匀切割。
* hash函数的结果应该均匀分布在[0,2^32-1]区间
* 2,由于服务器少,在圆上分布不均匀会造成数据倾斜,所以我们使用虚拟节点代替服务器的节点,一个服务器生成32个虚拟节点,或者更多。
* 3,数据要存到服务器上,通过同样的算法得到整数,在圆上顺时针跟节点对比,如果刚好大于或者等于,那么就保存在这台服务器上,
* 如果走完一圈也没找到,就落入第一个节点。
* 参数是:服务器IP,数据。
* 需要的操作是:添加服务器,删除服务器,添加数据(服务器在这)
class A{
public $server;
public $node;
/我们需要得到的散列值是一个正整数,所以我们可以使用times33或者crc32来获得/
public function hashing($str){
return sprintf('%u',crc32($str));
}
/添加服务器/
public function addServer($server){
if(!isset($this->server[$server])){
$this->addNode($server);
}
}
/添加虚拟节点/
public function addNode($server){
/每个添加32个虚拟节点,服务器少你可以添加更多,分布相对均匀以防数据倾斜/
for($i=0;$i<32;$i++){
$key_node=$this->hashing($server.$i);
$this->server[$server][]=$key_node;
$this->node[$key_node]=$server;
}
/变成有序的整数数组/
ksort($this->node,SORT_NUMERIC);
}
/删除服务器/
public function dropServer($server){
foreach($this->server[$server] as $v){
unset($this->node[$v]);
}
unset($this->server[$server]);
}
/调度服务器/
public function getServer($str){
$key_str=$this->hashing($str);
/第一个节点/
$server=current($this->node);
foreach($this->node as $k=>$v){
if($k>=$key_str){
$server=$v;
break;
}
}
reset($this->node);
return $server;
}
}
$s=new A();
$s->addServer('192.168.1.2:12341');
$s->addServer('192.168.1.3:12342');
$s->addServer('192.168.1.4:12343');
$s->addServer('192.168.1.5:12344');
$s->addServer('192.168.1.6:12345');
echo $s->getServer('我存在哪里呢');
/结果192.168.1.3:12342/
/删除这台服务器/
$s->dropServer('192.168.1.3:12342');
echo $s->getServer('我存在哪里呢');
/结果192.168.1.3:12344/
低调大师中文资讯倾力打造互联网数据资讯、行业资源、电子商务、移动互联网、网络营销平台。
持续更新报道IT业界、互联网、市场资讯、驱动更新,是最及时权威的产业资讯及硬件资讯报道平台。
转载内容版权归作者及来源网站所有,本站原创内容转载请注明来源。
- 上一篇
我花10个小时,写出了小白也能看懂的阿里数据中台分析
数据中台被誉为大数据的下一站,由阿里兴起,核心思想是数据共享,2015年阿里提出“大中台,小前台”的策略。2018 年因为“腾讯数据中台论”,中台再度成为了人们谈论的焦点。 2019年,似乎人人都在提数据中台,但却不是所有人都清楚数据中台到底意味着什么。数据中台是只有大厂才需要考虑的高大上的概念吗?普通企业该不该做数据中台?数据中台的出现会给现有数据从业者们带来颠覆式的挑战吗? 数据中台不是大数据平台!首先它不是一个平台,也不是一个系统,如果有厂商说他们有个数据中台卖给你,对不起,它是个骗子。 要回答数据中台是什么,首先要探讨一下中台到底是什么。虽然没有明确的定义,但是作为理工直男,我们可以先把中台看作是一种中间层。既然是一种中间层,那么中台确实是一种十足技术用语,我们可以完全从技术角度来探讨了。 我们可以应用 Gartner 的 Pace Layer 来理解为什么要有中间层,这样可以更好地理解中台的定位和价值。Pace Layer 里提到,可以按照事物变化的速度来分层,这样可以逐层分析并设计合理的边界与服务。 在数据开发中,核心数据模型的变化是相对缓慢的,同时,对数据进行维护的工作...
- 下一篇
物联网平台RRpc请求调用说明
一、简介 什么是RRpc? MQTT协议是基于PUB/SUB的异步通信模式,不适用于服务端同步控制设备端返回结果的场景。物联网平台基于MQTT协议制定了一套请求和响应的同步机制,无需改动MQTT协议即可实现同步通信。物联网平台提供API给服务端,设备端只需要按照固定的格式回复PUB消息,服务端使用API,即可同步获取设备端的响应结果。 二、RRpc原理 1、物联网平台收到来自用户服务器的RRPC调用,下发一条RRPC请求消息给设备。消息体为用户传入的数据,Topic为物联网平台定义的Topic,其中含有唯一的RRPC消息ID。2、设备收到下行消息后,按照指定Topic格式(包含之前云端下发的唯一的RRPC消息ID)回复一条RRPC响应消息给云端,云端提取出Topic中的消息ID,和之前的RRPC请求消息匹配上,然后回复给用户服务器。3、如果调用时设备不在线,云端会给用户服务器返回设备离线的错误;如果设备没有在超时时间内(8秒内)回复RRPC响应消息,云端会给用户服务器返回超时错误。 三、Topic格式 系统Topic:RRPC请求消息Topic:/sys/${YourProductKe...
相关文章
文章评论
共有0条评论来说两句吧...
文章二维码
点击排行
推荐阅读
最新文章
- CentOS6,CentOS7官方镜像安装Oracle11G
- Red5直播服务器,属于Java语言的直播服务器
- Hadoop3单机部署,实现最简伪集群
- CentOS7,CentOS8安装Elasticsearch6.8.6
- CentOS7安装Docker,走上虚拟化容器引擎之路
- CentOS7编译安装Gcc9.2.0,解决mysql等软件编译问题
- Windows10,CentOS7,CentOS8安装MongoDB4.0.16
- CentOS7编译安装Cmake3.16.3,解决mysql等软件编译问题
- SpringBoot2整合Redis,开启缓存,提高访问速度
- CentOS6,7,8上安装Nginx,支持https2.0的开启