IIS多進程模式下 雪花算法(Snowflake)C#版本 壓測Id重復嚴重

僅僅就目前的C#版本測試做說明

在IIS多進程模式下使用Snowflake生成數據ID重復很厲害，需要加入進程id解決此問題(暫未解決，后續更新)

壓測工具 :Jmeter

測試出現問題NET版本：4.6.1

測試機器: WIN7 X64 I7-6700  16G內存

大名鼎鼎的 雪花算法 Twitter's Snowflake我就不多介紹了，直接上代碼吧

目前能搜索(百度，github，Google)到的C#版的代碼基本上都一致 和java版本並無區別

 

 public class SnowflakeNet
    {
        //基准時間
        private  static long StartStmp = 1288834974657L;
        //private const long START_STMP = 1480166465631L;
        /*每一部分占用的位數*/
        //機器標識位數
        const int MachineIdBits = 5;
        //數據標志位數
        const int DatacenterIdBits = 5;
        //序列號識位數
        const int SequenceBits = 12;

        /* 每一部分的最大值*/
        //機器ID最大值
        const long MaxMachineNum = -1L ^ (-1L << MachineIdBits);
        //數據標志ID最大值
        const long MaxDatacenterNum = -1L ^ (-1L << DatacenterIdBits);
        //序列號ID最大值
        private const long MaxSequenceNum = -1L ^ (-1L << SequenceBits);

        /*每一部分向左的位移*/
        //機器ID偏左移12位
        private const int MachineShift = SequenceBits;
        //數據ID偏左移17位
        private const int DatacenterIdShift = SequenceBits + MachineIdBits;
        //時間毫秒左移22位
        public const int TimestampLeftShift = SequenceBits + MachineIdBits + DatacenterIdBits;


        private long _sequence = 0L;//序列號
        private long _lastTimestamp = -1L;//上一次時間戳
        public long MachineId { get; protected set; }//機器標識
        public long DatacenterId { get; protected set; }//數據中心
        //public long Sequence = 0L;//序列號
        //{
        //    get { return _sequence; }
        //    internal set { _sequence = value; }
        //}

        private readonly DateTime Jan1st1970 = new DateTime(1970, 1, 1, 0, 0, 0, DateTimeKind.Utc);
        private readonly object _lock = new Object();
        public SnowflakeNet(long machineId, long datacenterId)
        {
            // 如果超出范圍就拋出異常
            if (machineId > MaxMachineNum || machineId < 0)
            {
                throw new ArgumentException(string.Format("machineId 必須大於0，MaxMachineNum： {0}", MaxMachineNum));
            }

            if (datacenterId > MaxDatacenterNum || datacenterId < 0)
            {
                throw new ArgumentException(string.Format("datacenterId必須大於0，且不能大於MaxDatacenterNum： {0}", MaxDatacenterNum));
            }

            //先檢驗再賦值
            MachineId = machineId;
            DatacenterId = datacenterId;
            //_sequence = sequence;
        }

        //public static Init(long machineId, long datacenterId)
        //{

        //}
        public long NextId()
        {
            lock (_lock)
            {
                var timestamp = TimeGen();
                if (timestamp < _lastTimestamp)
                {
                    throw new Exception(string.Format("時間戳必須大於上一次生成ID的時間戳.  拒絕為{0}毫秒生成id", _lastTimestamp - timestamp));
                }

                //如果上次生成時間和當前時間相同,在同一毫秒內
                if (_lastTimestamp == timestamp)
                {
                    //sequence自增，和sequenceMask相與一下，去掉高位
                    _sequence = (_sequence + 1) & MaxSequenceNum;
                    //判斷是否溢出,也就是每毫秒內超過1024，當為1024時，與sequenceMask相與，sequence就等於0
                    if (_sequence == 0L)
                    {
                        //等待到下一毫秒
                        timestamp = TilNextMillis(_lastTimestamp);
                    }
                }
                else
                {
                    //如果和上次生成時間不同,重置sequence，就是下一毫秒開始，sequence計數重新從0開始累加,
                    //為了保證尾數隨機性更大一些,最后一位可以設置一個隨機數
                    _sequence = 0L;//new Random().Next(10);
                }

                _lastTimestamp = timestamp;
                return ((timestamp - StartStmp) << TimestampLeftShift) | (DatacenterId << DatacenterIdShift) | (MachineId << MachineShift) | _sequence;
            }
        }

        // 防止產生的時間比之前的時間還要小（由於NTP回撥等問題）,保持增量的趨勢.
        protected virtual long TilNextMillis(long lastTimestamp)
        {
            var timestamp = TimeGen();
            while (timestamp <= lastTimestamp)
            {
                timestamp = TimeGen();
            }
            return timestamp;
        }

        // 獲取當前的時間戳
        protected virtual long TimeGen()
        {
            //return TimeExtensions.CurrentTimeMillis();
            return (long)(DateTime.UtcNow - Jan1st1970).TotalMilliseconds;
        }
    }

 

　　

 下面是封裝為靜態類調用

public class IdWorkerHelper{
             private static SnowflakeNet_idWorker= null;
        private IdWorkerHelper()
        {

        }

        static IdWorkerHelper()
        {
            _idWorker=new SnowflakeNet(1,1);
        }
          public static long GenId64()
        {
            return _idWorker.nextId();

        }
  }


調用 IdWorkerHelper.GenId64();

 

　然后就是壓測了 壓測很簡單 就是一個接口 直接往測試表里寫數據

        public void IdTest()
        {
            IdTest model = new IdTest();
            model .DataId = IdWorkerHelper.GenId64();
            model .InsertTime=DateTime.Now;
            Sqldb.Insertable(img).ExecuteCommand();
        }

IdTest 表的主鍵Id用來自增
控制器代碼

public ActionResult IdTest()
        {
            var result = new ResultJson();
            _platApp.IdTest();
            return Content(result.ToJson());
        }

然后通過Jmeter壓測

線程組分別設置100，,200，500,1000,2000

實際結果重復DataId十分嚴重

一下結果是線程組1000的情況下的重復情況 

sql語句：select DataId from IdTest GROUP BY DataId HAVING COUNT(DataId)>1;