BeiJinSettleAccount/code/Shared/Win.Abp.Snowflakes/Win/Abp/Snowflakes/SnowflakeIdGenerator.cs

using System;
using System.Text;
using Microsoft.Extensions.Options;
using Volo.Abp.DependencyInjection;

namespace Win.Abp.Snowflakes
{
    public class SnowflakeIdGenerator : ISnowflakeIdGenerator, ITransientDependency
    {
        // 开始时间截((new DateTime(2020, 1, 1, 0, 0, 0, DateTimeKind.Utc)-Jan1st1970).TotalMilliseconds)
        private static readonly DateTime Jan1st1970 = new DateTime(1970, 1, 1, 0, 0, 0, DateTimeKind.Utc);

        private const long Twepoch = 1577836800000L;

        // 机器id所占的位数
        private const int WorkerIdBits = 5;

        // 数据标识id所占的位数
        private const int DatacenterIdBits = 5;

        // 支持的最大机器id，结果是31 (这个移位算法可以很快的计算出几位二进制数所能表示的最大十进制数) 
        private const long MaxWorkerId = -1L ^ (-1L << WorkerIdBits);

        // 支持的最大数据标识id，结果是31 
        private const long MaxDatacenterId = -1L ^ (-1L << DatacenterIdBits);

        // 序列在id中占的位数 
        private const int SequenceBits = 12;

        // 数据标识id向左移17位(12+5) 
        private const int DatacenterIdShift = SequenceBits + WorkerIdBits;

        // 机器ID向左移12位 
        private const int WorkerIdShift = SequenceBits;


        // 时间截向左移22位(5+5+12) 
        private const int TimestampLeftShift = SequenceBits + WorkerIdBits + DatacenterIdBits;

        // 生成序列的掩码，这里为4095 (0b111111111111=0xfff=4095) 
        private const long SequenceMask = -1L ^ (-1L << SequenceBits);

        // 数据中心ID(0~31) 
        private long DatacenterId { get; set; }

        // 工作机器ID(0~31) 
        private long WorkerId { get; set; }

        // 毫秒内序列(0~4095) 
        private long Sequence { get; set; }

        // 上次生成ID的时间截 
        private long LastTimestamp { get; set; }


        public AbpSnowflakeIdGeneratorOptions Options { get; }
    
        protected SnowflakeIdGenerator(){}

        public SnowflakeIdGenerator(IOptions<AbpSnowflakeIdGeneratorOptions> options)
        {
            Options = options.Value;
            this.DatacenterId = options.Value.GetDefaultDatacenterId();
            this.WorkerId = options.Value.GetDefaultWorkerId();

        }

        /// <summary>
        /// 获得下一个ID
        /// </summary>

        /// <returns></returns>
        public long Create()
        {
            return Create(Options.GetDefaultDatacenterId(), Options.GetDefaultWorkerId());
        }

        public long Create(long datacenterId, long workerId)
        {
            
            if (datacenterId > MaxDatacenterId || datacenterId < 0)
            {
                throw new Exception($"datacenter Id can't be greater than {MaxDatacenterId} or less than 0");
            }
            if (workerId > MaxWorkerId || workerId < 0)
            {
                throw new Exception($"worker Id can't be greater than {MaxWorkerId} or less than 0");
            }

            this.DatacenterId = datacenterId;
            this.WorkerId = workerId;

            lock (this)
            {
                var timestamp = GetCurrentTimestamp();
                if (timestamp > LastTimestamp) //时间戳改变，毫秒内序列重置
                {
                    Sequence = 0L;
                }
                else if (timestamp == LastTimestamp) //如果是同一时间生成的，则进行毫秒内序列
                {
                    Sequence = (Sequence + 1) & SequenceMask;
                    if (Sequence == 0) //毫秒内序列溢出
                    {
                        timestamp = GetNextTimestamp(LastTimestamp); //阻塞到下一个毫秒,获得新的时间戳
                    }
                }
                else   //当前时间小于上一次ID生成的时间戳，证明系统时钟被回拨，此时需要做回拨处理
                {
                    Sequence = (Sequence + 1) & SequenceMask;
                    if (Sequence > 0)
                    {
                        timestamp = LastTimestamp;     //停留在最后一次时间戳上，等待系统时间追上后即完全度过了时钟回拨问题。
                    }
                    else   //毫秒内序列溢出
                    {
                        timestamp = LastTimestamp + 1;   //直接进位到下一个毫秒                          
                    }
                    //throw new Exception(string.Format("Clock moved backwards.  Refusing to generate id for {0} milliseconds", lastTimestamp - timestamp));
                }

                LastTimestamp = timestamp;       //上次生成ID的时间截

                //移位并通过或运算拼到一起组成64位的ID
                var id = ((timestamp - Twepoch) << TimestampLeftShift)
                         | (this.DatacenterId << DatacenterIdShift)
                         | (this.WorkerId << WorkerIdShift)
                         | Sequence;
                return id;
            }
        }

        /// <summary>
        /// 解析雪花ID
        /// </summary>
        /// <returns></returns>
        public string AnalyzeId(long id)
        {
            var sb = new StringBuilder();

            var timestamp = (id >> TimestampLeftShift);
            var time = Jan1st1970.AddMilliseconds(timestamp + Twepoch);
            sb.Append(time.ToLocalTime().ToString("yyyy-MM-dd HH:mm:ss:fff"));

            var datacenterId = (id ^ (timestamp << TimestampLeftShift)) >> DatacenterIdShift;
            sb.Append("_" + datacenterId);

            var workerId = (id ^ ((timestamp << TimestampLeftShift) | (datacenterId << DatacenterIdShift))) >> WorkerIdShift;
            sb.Append("_" + workerId);

            var sequence = id & SequenceMask;
            sb.Append("_" + sequence);

            return sb.ToString();
        }

        /// <summary>
        /// 阻塞到下一个毫秒，直到获得新的时间戳
        /// </summary>
        /// <param name="lastTimestamp">上次生成ID的时间截</param>
        /// <returns>当前时间戳</returns>
        private static long GetNextTimestamp(long lastTimestamp)
        {
            long timestamp = GetCurrentTimestamp();
            while (timestamp <= lastTimestamp)
            {
                timestamp = GetCurrentTimestamp();
            }
            return timestamp;
        }

        /// <summary>
        /// 获取当前时间戳
        /// </summary>
        /// <returns></returns>
        private static long GetCurrentTimestamp()
        {
            return (long)(DateTime.UtcNow - Jan1st1970).TotalMilliseconds;
        }
    }
}