legongju.com
我们一直在努力
2025-01-13 09:28 | 星期一

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

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 关键字来实现同步。

未经允许不得转载 » 本文链接:https://www.legongju.com/article/104210.html

相关推荐

  • 在c++中cbegin适用于哪些场景

    在c++中cbegin适用于哪些场景

    cbegin() 是 C++11 标准库中的一个函数,它返回一个指向容器开始位置的常量迭代器(const_iterator)。这意味着你不能通过这个迭代器修改容器中的元素。cbegin()...

  • c++ cbegin能提高程序性能吗

    c++ cbegin能提高程序性能吗

    cbegin() 是 C++11 标准中引入的一个成员函数,用于返回容器的常量迭代器,指向容器的第一个元素。使用 cbegin() 本身并不会直接提高程序性能,但它可以帮助你编...

  • c++中使用cbegin有哪些注意事项

    c++中使用cbegin有哪些注意事项

    在C++中,cbegin()和cend()是C++11引入的函数,用于获取容器的常量迭代器(const_iterator),这意味着你不能通过这些迭代器修改容器的内容 确保容器支持cbegin(...

  • c++ cbegin与普通迭代器有何区别

    c++ cbegin与普通迭代器有何区别

    cbegin() 和普通迭代器(例如 begin())之间的主要区别在于它们返回的迭代器类型 cbegin():此成员函数返回一个常量迭代器(const_iterator),表示容器的开始位...

  • C# OsgEarth的扩展功能探索

    C# OsgEarth的扩展功能探索

    OsgEarth 是一个开源的地理信息系统(GIS)工具库,基于 OpenSceneGraph(OSG) 3D 建模和可视化:OsgEarth 支持多种 3D 数据格式,如 3D Tiles、BIM、Cesium 等...

  • 如何结合C#与OsgEarth进行地图开发

    如何结合C#与OsgEarth进行地图开发

    要结合C#与OsgEarth进行地图开发,首先需要了解OsgEarth的基本概念和功能 安装OsgEarth:从OsgEarth官网下载并安装适用于Windows的OsgEarth库。确保将其添加到系...

  • OsgEarth在C#中的三维可视化展示

    OsgEarth在C#中的三维可视化展示

    OsgEarth 是一个开源的地理信息系统(GIS)工具库,它提供了丰富的三维地球和地图功能
    以下是一个简单的示例,展示如何在 C# 中使用 OsgEarth 进行三维可视...

  • OsgEarth与C#的跨平台兼容性

    OsgEarth与C#的跨平台兼容性

    OsgEarth 是一个开源的地理信息系统(GIS)工具库,用于创建和操作三维地球模型
    在 .NET 中使用 OsgEarth 的一种方法是通过 P/Invoke 调用原生 C++ 代码。这...