PHPフラッシュセールシステムにおける分散タスクスケジューリングと分散ユニークID生成手法

connect('127.0.0.1', 6379); $taskData = [ 'task_id' => uniqid(), // 任务ID 'task_data' => 'some data' // 任务数据 ]; $redis->lPush('task_queue', json_encode($taskData)); // 消费者代码 $redis = new Redis(); $redis->connect('127.0.0.1', 6379); while (true) { $taskDataJson = $redis->rPop('task_queue'); if ($taskDataJson) { $taskData = json_decode($taskDataJson, true); // 执行任务代码 echo "Task ID: {$taskData['task_id']} "; echo "Task Data: {$taskData['task_data']} "; } }

 31 || $dataCenterId < 0) { throw new InvalidArgumentException("Data Center ID can't be greater than 31 or less than 0"); } if ($workerId > 31 || $workerId < 0) { throw new InvalidArgumentException("Worker ID can't be greater than 31 or less than 0"); } $this->dataCenterId = $dataCenterId; $this->workerId = $workerId; } public function nextId() { $timestamp = $this->getTimestamp(); if ($timestamp < self::EPOCH) { throw new Exception("Clock moved backwards. Refusing to generate ID"); } if ($timestamp === $this->lastTimestamp) { $this->sequence = ($this->sequence + 1) & 4095; // 4095是12位二进制 if ($this->sequence === 0) { $timestamp = $this->tilNextMillis(); } } else { $this->sequence = 0; } $this->lastTimestamp = $timestamp; return (($timestamp - self::EPOCH) << 22) | ($this->dataCenterId << 17) | ($this->workerId << 12) | $this->sequence; } public function tilNextMillis() { $timestamp = $this->getTimestamp(); while ($timestamp <= $this->lastTimestamp) { $timestamp = $this->getTimestamp(); } return $timestamp; } public function getTimestamp() { return floor(microtime(true) * 1000); } } // 测试代码 $snowflake = new Snowflake(1, 1); // 数据中心ID为1，工作节点ID为1 for ($i = 0; $i < 10; $i++) { echo $snowflake->nextId() . PHP_EOL; }