中文字幕av专区_日韩电影在线播放_精品国产精品久久一区免费式_av在线免费观看网站

溫馨提示×

如何用C#生成唯一的Snowflake ID

c#
小樊
105
2024-09-02 12:36:32
欄目: 編程語言

Snowflake ID 是一種分布式系統中生成唯一 ID 的算法,由 Twitter 開源。它可以在不依賴數據庫或其他存儲設備的情況下生成全局唯一的 ID。Snowflake ID 通常是一個 64 位的整數,由以下部分組成:

  1. 前 1 位未使用,任意填充。
  2. 41 位表示時間戳。
  3. 10 位表示工作機器 ID,可通過部署多個 Snowflake 服務。
  4. 12 位序列號,單節點每毫秒內可以生成 4096 個 ID。

以下是一個簡單的 C# 實現:

using System;
using System.Threading;

public class SnowflakeIdWorker
{
    private const long Twepoch = 1288834974657L;
    private const int WorkerIdBits = 10;
    private const int SequenceBits = 12;
    private const long MaxWorkerId = -1L ^ (-1L<< WorkerIdBits);
    private const long SequenceMask = -1L ^ (-1L << SequenceBits);

    private static readonly object SyncRoot = new object();
    private readonly long _workerId;
    private long _sequence;
    private long _lastTimestamp;

    public SnowflakeIdWorker(long workerId)
    {
        if (workerId > MaxWorkerId || workerId < 0)
            throw new ArgumentException($"Worker Id can't be greater than {MaxWorkerId} or less than 0");

        _workerId = workerId;
    }

    public long NextId()
    {
        lock (SyncRoot)
        {
            var timestamp = TimeGen();

            if (timestamp < _lastTimestamp)
                throw new Exception($"Invalid system clock! Refusing to generate id for {_lastTimestamp - timestamp} milliseconds");

            if (_lastTimestamp == timestamp)
            {
                _sequence = (_sequence + 1) & SequenceMask;
                if (_sequence == 0) timestamp = TilNextMillis(_lastTimestamp);
            }
            else
            {
                _sequence = 0;
            }

            _lastTimestamp = timestamp;
            var id = ((timestamp - Twepoch) << (WorkerIdBits + SequenceBits)) | (_workerId << SequenceBits) | _sequence;

            return id;
        }
    }

    protected virtual long TilNextMillis(long lastTimestamp)
    {
        var timestamp = TimeGen();
        while (timestamp <= lastTimestamp) timestamp = TimeGen();
        return timestamp;
    }

    protected virtual long TimeGen()
    {
        return DateTimeOffset.UtcNow.ToUnixTimeMilliseconds();
    }
}

要使用此類生成 Snowflake ID,請創建一個 SnowflakeIdWorker 實例并調用 NextId() 方法。例如:

var worker = new SnowflakeIdWorker(1); // Use worker ID 1
var id = worker.NextId();
Console.WriteLine("Generated Snowflake ID: " + id);

注意:這個實現不是線程安全的,如果需要在多線程環境中使用,請確保對 NextId() 方法進行適當的同步。在上面的代碼中,我們使用了 lock 關鍵字來實現同步。

0
花莲市| 武宁县| 砀山县| 宁南县| 新郑市| 兴安盟| 赤峰市| 南部县| 阆中市| 开化县| 清镇市| 临朐县| 阿巴嘎旗| 马尔康县| 满洲里市| 连州市| 嘉义县| 江都市| 千阳县| 海兴县| 嵊州市| 兴和县| 肥西县| 莱阳市| 长沙县| 柘城县| 泗洪县| 卓资县| 榆中县| 喜德县| 惠州市| 池州市| 阿巴嘎旗| 安平县| 岳池县| 平武县| 秭归县| 明水县| 尖扎县| 当涂县| 南部县|