WEP_V2.1.3/SourceCode/We.Zero/IwbYue.Zero/ToolCommon/CacheHelpers/InfoCache.cs

using System;
using System.Collections.Generic;
using System.Timers;

namespace IwbZero.ToolCommon.CacheHelpers
{
    /// <summary>
    /// 缓存
    /// </summary>
    public abstract class InfoCache<T> where T : class, new()
    {
        //public static InfoCache<T> Instance = new InfoCache<T>();
        protected InfoCache()
        {
            Timer = new Timer();
            ExpireInterval = 60 * 2;
            ClearInterval = 30;
            StartClear();
        }
        /// <summary>
        /// 
        /// </summary>
        /// <param name="expireInterval">缓存过期时间（分钟）默认120分钟</param>
        /// <param name="clearInterval">缓存清理间隔（分钟）默认30分钟</param>
        protected InfoCache(int? expireInterval, int? clearInterval)
        {
            Timer = new Timer();
            ExpireInterval = expireInterval ?? 60 * 2;
            ClearInterval = clearInterval ?? 30;
            StartClear();
        }

        protected void StartClear()
        {

            StopClear();
            if (!HasStarted)
            {
                Timer.Enabled = true;
                Timer.Interval = 1000 * 60 * ClearInterval;
                Timer.Start();
                Timer.Elapsed += CheckOverTime;
                HasStarted = true;
            }

        }
        protected void StopClear()
        {
            if (HasStarted)
            {
                Timer.Stop();
                Timer.Elapsed -= CheckOverTime;
                HasStarted = false;
            }

        }

        public bool HasStarted;
        /// <summary>
        /// 缓存清理间隔（分钟）
        /// </summary>
        protected int ClearInterval { get; set; }
        /// <summary>
        /// 缓存过期时间（分钟）
        /// </summary>
        protected int ExpireInterval { get; set; }

        /// <summary>
        /// 尝试获取缓存
        /// </summary>
        /// <param name="key"></param>
        /// <param name="value"></param>
        /// <returns></returns>
        public virtual bool TryGetCache(string key, out T value)
        {
            value = default(T);
            if (Caches.ContainsKey(key))
            {
                var valueWithDate = Caches[key];
                value = valueWithDate.GroupInfo;
                valueWithDate.ActiveTime = DateTime.Now;
                return true;
            }
            return false;
        }
        /// <summary>
        /// 添加缓存
        /// </summary>
        /// <param name="key"></param>
        /// <param name="value"></param>
        public virtual void AddCache(string key, T value)
        {
            if (Caches.ContainsKey(key))
            {
                Caches[key] = new InfoWithDate(value);
            }
            else
            {
                Caches.Add(key, new InfoWithDate(value));
            }
        }
        /// <summary>
        /// 移除缓存
        /// </summary>
        /// <param name="key"></param>
        public virtual void RemoveCache(string key)
        {
            if (Caches.ContainsKey(key))
            {
                Caches.Remove(key);
            }
        }
        /// <summary>
        /// 清除所有缓存信息
        /// </summary>
        public virtual void ClearCache()
        {
            Caches.Clear();
        }
        private Timer Timer { get; }
        private void CheckOverTime(object source, ElapsedEventArgs e)
        {
            var temp = new Dictionary<string, InfoWithDate>();
            foreach (var cache in Caches)
            {
                if (cache.Value.ActiveTime.CompareTo(DateTime.Now.AddMinutes(-ExpireInterval)) >= 0)
                {
                    temp.Add(cache.Key, cache.Value);
                }
            }
            lock (Caches)
            {
                Caches = temp;
            }
        }
        private static Dictionary<string, InfoWithDate> Caches { get; set; } = new Dictionary<string, InfoWithDate>();
        private class InfoWithDate
        {
            public InfoWithDate(T value)
            {
                ActiveTime = DateTime.Now;
                GroupInfo = value;
            }
            public DateTime ActiveTime { get; set; }
            public T GroupInfo { get; }
        }
    }
}