Redis-篇

public static class RedisIdWork
{
    private readonly static long BEGIN_TIMSTAMP = 1678966413L;
    private readonly static int COUNT_BITS = 32;
    public static long nextId(string keyPrefix)
    {
        //1、生成時間戳
        long nowTimeSeconds = new DateTimeOffset(DateTime.UtcNow).ToUnixTimeSeconds();
        long timesamp = nowTimeSeconds - BEGIN_TIMSTAMP;
        //2、生成序列號
        string date = DateTime.Now.ToString("yyyyMMdd");
        var redis = new RedisHelper();
        long count = redis.database().StringIncrement("icr:" + keyPrefix + ":" + date, 1);
        //3、拼接返回
        return timesamp << COUNT_BITS | count;
    }

}

       public bool LockByRedis(string key, double expireTimeSeconds = 600)
        {
            try
            {
                while (true)
                {
                    //Console.WriteLine($"生成的GUID ：{ID_PREFIX}");
                    //expireTimeSeconds = expireTimeSeconds > 20 ? 10 : expireTimeSeconds;
                    bool lockflag = database().LockTake(key, ID_PREFIX + Thread.CurrentThread.ManagedThreadId, TimeSpan.FromSeconds(expireTimeSeconds));
                    if (lockflag) //如果鎖定成功，則為 true，否則為 false，否則為 false。 
                    {
                        return true;
                        //break;
                    }
                    return false;
                }
                //return database().LockTake(key, ID_PREFIX + Thread.CurrentThread.ManagedThreadId, TimeSpan.FromSeconds(expireTimeSeconds));
            }
            catch (Exception ex)
            {
                throw new Exception($"Redis加鎖異常:原因{ex.Message}");
            }
        }

        /// <summary>
        /// 釋放鎖
        /// </summary>
        /// <param name="name"></param>
        public void UnLockByRedis(string key)
        {
            try
            {
                //判讀線程標識是否一致 鎖是否一致
                //1、查詢redis 鎖
                string threadid = ID_PREFIX + Thread.CurrentThread.ManagedThreadId;
                string id = database().StringGet(key).ToString();
                if (threadid.Equals(id)) //防止鎖被誤刪
                    database().LockRelease(key, ID_PREFIX + Thread.CurrentThread.ManagedThreadId);
            }
            catch (Exception ex)
            {
                throw new Exception($"Redis加鎖異常:原因{ex.Message}");
            }
        }