雪花算法 workerid生成算法

雪花算法是一种用于生成分布式系统中唯一ID的算法，其中workerid是其中的一个组成部分。workerid是一个标识符，用于标识每个分布式系统中的节点或进程。下面是一个简单的雪花算法workerid生成算法的实现：

import socket
import threading

class SnowflakeWorker(object):
    def __init__(self):
        self.worker_id = self.get_worker_id()
        self.last_timestamp = -1
        self.sequence = 0

    def get_worker_id(self):
        hostname = socket.gethostname()
        return abs(hash(hostname)) % (2 ** 10)

    def get_timestamp(self):
        return int(round(time.time() * 1000))

    def get_id(self):
        timestamp = self.get_timestamp()

        if self.last_timestamp > timestamp:
            raise Exception("Clock moved backwards. Refusing to generate id for %d milliseconds" % (self.last_timestamp - timestamp))

        if self.last_timestamp == timestamp:
            self.sequence = (self.sequence + 1) % 4096
            if self.sequence == 0:
                timestamp = self.wait_next_millis(timestamp)
        else:
            self.sequence = 0

        self.last_timestamp = timestamp

        return ((timestamp - 1609459200000) << 22) | (self.worker_id << 12) | self.sequence

    def wait_next_millis(self, last_timestamp):
        timestamp = self.get_timestamp()
        while timestamp <= last_timestamp:
            timestamp = self.get_timestamp()
        return timestamp

worker = SnowflakeWorker()
print(worker.get_id())

该算法使用了当前时间戳、节点的worker_id和一个自增的序列号来产生唯一ID。其中，worker_id是通过对当前机器的主机名进行哈希后取模得到的，保证了不同节点之间的worker_id不同。同时，序列号用于解决同一毫秒内并发生成ID可能会发生冲突的问题。在生成ID时，如果当前时间戳小于上一次生成ID的时间戳，则说明时钟回拨了，需要等待时钟同步后再生成ID。