Le flocon de neige de Twitter est largement utilisé dans la génération distribuée d'UUID uniques. Il existe également de nombreux algorithmes basés sur certaines variantes du flocon de neige sur Internet. De nombreux UUID générés à l'aide de Snowflake sont utilisés dans des scénarios distribués. J'ai lu plusieurs implémentations PHP sur Internet qui ne prenaient pas en compte la sécurité des threads. Maintenant que PHP prend en charge les verrous et les coroutines de Swoole, il est très pratique pour nous de développer des simulations thread-safe et à haute concurrence. Ici, nous utilisons PHP combiné avec Swoole pour apprendre à implémenter le flocon de neige le plus simple (je n'ai pas écrit). PHP depuis longtemps, et j'ai l'impression de ne pas avoir d'EDI. Je ne peux plus écrire PHP).
Regardez d'abord la structure de flocon de neige suivante :
La valeur générée est de 64 bits, divisée en 4 parties :
Publiez d'abord le code :
<?php class Snowflake { const EPOCH = 1543223810238; // 起始时间戳,毫秒 const SEQUENCE_BITS = 12; //序号部分12位 const SEQUENCE_MAX = -1 ^ (-1 << self::SEQUENCE_BITS); // 序号最大值 const WORKER_BITS = 10; // 节点部分10位 const WORKER_MAX = -1 ^ (-1 << self::WORKER_BITS); // 节点最大数值 const TIME_SHIFT = self::WORKER_BITS + self::SEQUENCE_BITS; // 时间戳部分左偏移量 const WORKER_SHIFT = self::SEQUENCE_BITS; // 节点部分左偏移量 protected $timestamp; // 上次ID生成时间戳 protected $workerId; // 节点ID protected $sequence; // 序号 protected $lock; // Swoole 互斥锁 public function __construct($workerId) { if ($workerId < 0 || $workerId > self::WORKER_MAX) { trigger_error("Worker ID 超出范围"); exit(0); } $this->timestamp = 0; $this->workerId = $workerId; $this->sequence = 0; $this->lock = new swoole_lock(SWOOLE_MUTEX); } /** * 生成ID * @return int */ public function getId() { $this->lock->lock(); // 这里一定要记得加锁 $now = $this->now(); if ($this->timestamp == $now) { $this->sequence++; if ($this->sequence > self::SEQUENCE_MAX) { // 当前毫秒内生成的序号已经超出最大范围,等待下一毫秒重新生成 while ($now timestamp) { $now = $this->now(); } } } else { $this->sequence = 0; } $this->timestamp = $now; // 更新ID生时间戳 $id = (($now - self::EPOCH) workerId sequence; $this->lock->unlock(); //解锁 return $id; } /** * 获取当前毫秒 * @return string */ public function now() { return sprintf("%.0f", microtime(true) * 1000); } }
En fait, la logique n'est pas compliquée. Expliquez les opérations sur les bits dans le code :
-1 ^ (-1 <.>La dernière partie est décalée à gauche puis ORée : <p></p> <pre class="brush:php;toolbar:false">(($now - self::EPOCH) workerId sequence;
0000 0000 0010 --左移0位--> 0000 0000 0010 0000 0000 0100 --左移4位--> 0000 0100 0000 --或操作-->1000 0100 0010 0000 0000 1000 --左移8位--> 1000 0000 0000
$snowflake = new Snowflake(1); $chan = new chan(100000); $n = 100000; for ($i = 0; $i getId(); $chan->push($id); }); } go(function () use ($chan, $n) { $arr = []; for ($i = 0; $i pop(); // PHP Swoole的channel一定要写在go(func)的协程里面!? if (in_array($id, $arr)) { exit("ID 已存在"); } array_push($arr, $id); } }); $chan->close(); echo "ok";
Ce qui précède est le contenu détaillé de. pour plus d'informations, suivez d'autres articles connexes sur le site Web de PHP en chinois!