文档章节

修改自Twitter的Snowflake算法

思_无_邪
 思_无_邪
发布于 2015/10/20 15:51
字数 545
阅读 74
收藏 1
<?php
/**
 * 得到唯一识别码
 * 修改自Twitter的Snowflake算法
 * 此算法支持分布式自增ID
 * @author cwsky@163.com
 */

abstract class Uniq
{
	//初始时间码,开站设定一次,可用以下语句得到
	//floor(microtime(true) * 1000);
	private static $twepoch = 1380553425155;

	//数据中心,8表示可以有255个数据中心,最大取值为8
	private static $dataCenterIDBits = 8;

	//数据中心ID最大值
	//private static $maxDatacenterID = -1 ^ (-1 << $datacenterIDBits);

	//机器标识符,13表示可以有8191台机器,最大取值为13
	//当dataCenterIDBits与workerIDBits变大时,会产生负数,就不好玩了
	private static $workerIDBits = 13;

	//机器ID最大值
	//private static $maxWorkerId = -1 ^ (-1 << $workerIDBits);

	//毫秒内自增位
	private static $sequenceBits = 12;

	//机器ID偏左移12位
	//private static $workerIDShift = self::$sequenceBits;
	private static $workerIDShift = 12;

	//数据中心ID左移17位
	//private $dataCenterIDShift = $sequenceBits + $workerIDBits;

	//时间毫秒左移22位
	//private $timestampLeftShift = $sequenceBits + $workerIDBits + $datacenterIDBits;
	//private $sequenceMask = -1 ^ (-1 << $sequenceBits);

	private static $lastTimestamp = -1;

	private static $sequence = 0;

	public static function id($dataCenterID, $workerID)
	{
		//数据中心ID最大值
		$maxDataCenterID = -1 ^ (-1 << self::$dataCenterIDBits);

		//机器ID最大值
		$maxWorkerID = -1 ^ (-1 << self::$workerIDBits);

		//数据中心ID左移17位
		$dataCenterIDShift = self::$sequenceBits + self::$workerIDBits;

		//时间毫秒左移22位
		$timestampLeftShift = self::$sequenceBits + self::$workerIDBits + self::$dataCenterIDBits;
		$sequenceMask = -1 ^ (-1 << self::$sequenceBits);

		//检查workerID完整性
		if($workerID > $maxWorkerID || $workerID < 0)
		{
			return 0;
		}

		//检查数据中心完整性
		if($dataCenterID > $maxDataCenterID || $dataCenterID < 0)
		{
			return 0;
		}

		//echo sprintf("worker starting. timestamp left shift %d, datacenter id bits %d, maxDatacenterID:%d, worker id bits %d, maxWorkerID:%d, sequence bits %d, workerid %d", $timestampLeftShift, self::$dataCenterIDBits, $maxDataCenterID, self::$workerIDBits, $maxWorkerID, self::$sequenceBits, $workerID);

		$timestamp = self::timeGen();

		if($timestamp < self::$lastTimestamp)
		{
			return 0;
		}

		if (self::$lastTimestamp == $timestamp)
		{
			//当前毫秒内,则+1
			self::$sequence = (self::$sequence + 1) & $sequenceMask;
			if(self::$sequence == 0)
			{
				//当前毫秒内计数满了,则等待下一秒
				$timestamp = self::tilNextMillis(self::$lastTimestamp);
			}
		}
		else
		{
			self::$sequence = 0;
		}

		self::$lastTimestamp = $timestamp;

		$id = (($timestamp - self::$twepoch << $timestampLeftShift)) | ($dataCenterID << $dataCenterIDShift) | ($workerID << self::$workerIDShift) | (self::$sequence);

		return $id;
	}

	public static function timeGen()
	{
		return floor(microtime(true) * 1000);
	}

	public static function tilNextMillis($lastTimestamp)
	{
		$timestamp = self::timeGen();

		while($timestamp <= $lastTimestamp)
		{
			$timestamp = self::timeGen();
		}

		return $timestamp;
	}

	public static function getUUID()
	{
		return strtoupper(sprintf( '%04x%04x-%04x-%04x-%04x-%04x%04x%04x',
	        // 32 bits for "time_low"
	        mt_rand( 0, 0xffff ), mt_rand( 0, 0xffff ),

	        // 16 bits for "time_mid"
	        mt_rand( 0, 0xffff ),

	        // 16 bits for "time_hi_and_version",
	        // four most significant bits holds version number 4
	        mt_rand( 0, 0x0fff ) | 0x4000,

	        // 16 bits, 8 bits for "clk_seq_hi_res",
	        // 8 bits for "clk_seq_low",
	        // two most significant bits holds zero and one for variant DCE1.1
	        mt_rand( 0, 0x3fff ) | 0x8000,

	        // 48 bits for "node"
	        mt_rand( 0, 0xffff ), mt_rand( 0, 0xffff ), mt_rand( 0, 0xffff )
	    ));
	}
}
?>


© 著作权归作者所有

共有 人打赏支持
思_无_邪

思_无_邪

粉丝 2
博文 3
码字总数 4338
作品 1
海淀
CTO(技术副总裁)
私信 提问
一个实现 Twitter SnowFlake 算法 的 Go 分布式 UID 生成器

goSnowFlake According to the Twitter SnowFlake Theory, A ThreadSafe Unique ID Generator written by Golang 根据 Twitter SnowFlake 算法, 实现的分布式线程安全 UID 生成器 Feature 线......

ethantonylam
2016/04/07
48
0
PHP唯一ID生成扩展--Atom

使用Twitter的 Snowflake算法,有兴趣可以了解一下这个算法: https://github.com/twitter/snowflake php.ini的配置项: [ukey]ukey.datacenter = integerukey.worker = integerukey.twepoch ......

liexusong
2013/08/27
3.7K
1
扯扯ID

🙂🙂🙂关注微信公众号:【芋艿的后端小屋】有福利: RocketMQ / MyCAT / Sharding-JDBC 所有源码分析文章列表 RocketMQ / MyCAT / Sharding-JDBC 中文注释源码 GitHub 地址 您对于源码...

芋道源码掘金Java群217878901
2017/06/11
0
0
关于全局ID,雪花(snowflake)算法的说明

上次简单的说一下:http://www.cnblogs.com/dunitian/p/6041745.html#uid C#版本的国外朋友已经封装了,大家可以去看看:https://github.com/ccollie/snowflake-net 强大的网友出来个简化版本...

毒逆天
2016/12/04
0
0
golang 实现的 id 发号器--gosnowflake

gosnowflake 是一个golang 实现的 id 发号器,使用的是twitter的snowflake的算法,对twitter的snowflake项目进行了一些改造和优化,变的更可靠,现在主要是采用golang的gob编码rpc方式调用。...

LoveSai
2014/05/04
1K
0

没有更多内容

加载失败,请刷新页面

加载更多

mysql导入较大的数据文件

mysql一次导入较大的sql文件的时候会出现导入的瓶颈,用工具例如sqlyog之类的执行几十M都不行了,直接报内存不足,看来去服务器上执行sql命令才是王道。 服务器上执行有两种思路: 以Linux命...

sensy
3分钟前
0
0
Redis 基础入门

为什么需要Redis 传统的关系数据库MySQL,ORacle等的数据主要还是存储在磁盘上,虽然数据库各自都带有缓存功能,但随着业务量的增大,数据库自身的缓存终将成为瓶颈,次数如果要提供应用的效...

PeakFang-BOK
4分钟前
0
0
VS2017设置“编辑并继续”无效的问题

设置“编辑并继续” 在“工具”菜单上,单击“选项”。 在“选项”对话框中,打开“调试”节点,然后选择“编辑并继续”类别。 若要启用它,请选中“启用‘编辑并继续’”复选框。 若要禁用它...

随你疯
16分钟前
0
0
(5)添加svg支持

(5)添加svg支持 1 安装svg-sprite-loader cnpm install svg-sprite-loader --save svg-sprite-loader是一个webpack loader,可以将多个svg打包成svg-sprite。 2 配置svg-sprite-loader 我们......

neumeng
17分钟前
0
0
17-《深度拆解JVM》之即时编译(上)

一、问题引入 在第一篇中,我们简单了解过即时编译。这是一项用来提升应用程序运行效率的技术。通常而言,代码会先被 Java 虚拟机解释执行,之后反复执行的热点代码则会被即时编译成为机器码...

飞鱼说编程
34分钟前
1
0

没有更多内容

加载失败,请刷新页面

加载更多

返回顶部
顶部