—————————————————————————————————————————————————————————————————————————————————————————————————————————————————
1 public static class CustomCache
2 {
3 private static List<ConcurrentDictionary<string, DataModel>> cacheContainer = null;//缓存容器
4
5 private static readonly int cpuCount = Environment.ProcessorCount;//获取CPU个数
6
7 private static readonly int intervalTime = 900;//间隔时间 秒
8
9 private static readonly int expirationTime = 15;//过期时间 分
10
11
12 /// <summary>
13 /// 构造初始化
14 /// </summary>
15 static CustomCache()
16 {
17 cacheContainer = new List<ConcurrentDictionary<string, DataModel>>();
18 for (int i = 0; i < cpuCount; i++)
19 {
20 cacheContainer.Add(new ConcurrentDictionary<string, DataModel>());
21 }
22 AutoClaerCache();
23 }
24
25 /// <summary>
26 /// 自动清理缓存
27 /// </summary>
28 private static void AutoClaerCache()
29 {
30 Task.Factory.StartNew(() =>
31 {
32 while (true)
33 {
34 Thread.Sleep(intervalTime);
35 for (int i = 0; i < cacheContainer.Count; i++)
36 {
37 var cache = cacheContainer[i].Where(w => w.Value.LifeCycleType == LifeCycle.Temp);
38 foreach (var item in cache)
39 {
40 if (DateTime.Now > item.Value.CacheDateTime)
41 {
42 cacheContainer[i].TryRemove(item.Key, out DataModel dataModel);
43 }
44 }
45 }
46 }
47 });
48 }
49
50 /// <summary>
51 /// 添加或更新缓存
52 /// </summary>
53 /// <param name="key">键</param>
54 /// <param name="keyValue">键值</param>
55 /// <param name="lifeCycle">生命周期</param>
56 /// <returns></returns>
57 public static DataModel AddOrUpdate(string key, object keyValue, LifeCycle lifeCycle)
58 {
59 var model = new DataModel { LifeCycleType = lifeCycle, CacheData = keyValue, CacheDateTime = lifeCycle == LifeCycle.Lasting ? DateTime.Now : DateTime.Now.AddMinutes(expirationTime) };
60 return cacheContainer[Math.Abs(key.GetHashCode() % cpuCount)].AddOrUpdate(key, model, (k, v) => { return model; });
61 }
62
63 /// <summary>
64 /// 删除缓存
65 /// </summary>
66 /// <param name="key">键</param>
67 /// <returns></returns>
68 public static bool Remove(string key)
69 {
70 return cacheContainer[Math.Abs(key.GetHashCode() % cpuCount)].TryRemove(key, out DataModel dataModel);
71 }
72
73 /// <summary>
74 /// 获取缓存数据
75 /// </summary>
76 /// <typeparam name="T"></typeparam>
77 /// <param name="key">键</param>
78 /// <returns></returns>
79 public static T GetCacheData<T>(string key)
80 {
81 if (IsExistsCacheData(key, out int i))
82 {
83 var temp = cacheContainer[i][key];
84 if (temp.CacheData == null)//如果缓存为Null值返回类型默认值
85 {
86 return default(T);
87 }
88 if (typeof(T) != temp.CacheData.GetType())//判断类型是否一致，不一致将抛出异常
89 {
90 throw new Exception("This key value specifies that the type does not match the container cache type.");
91 }
92 return (T)temp.CacheData;
93 }
94 return default(T);//键值不存在也将返回类型默认值
95 }
96
97 /// <summary>
98 /// 获取缓存数据
99 /// </summary>
100 /// <typeparam name="T"></typeparam>
101 /// <param name="key">键值</param>
102 /// <param name="func">委托</param>
103 /// <param name="lifeCycle">生命周期</param>
104 /// <returns></returns>
105 public static T GetCacheData<T>(string key, Func<T> func, LifeCycle lifeCycle)
106 {
107 if (IsExistsCacheData(key, out int i))
108 {
109 var temp = cacheContainer[i][key];
110 if (temp.CacheData == null)//如果缓存为Null值返回类型默认值
111 {
112 return default(T);
113 }
114 if (typeof(T) != temp.CacheData.GetType())//判断类型是否一致，不一致将抛出异常
115 {
116 throw new Exception("This key value specifies that the type does not match the container cache type.");
117 }
118 return (T)temp.CacheData;
119 }
120 T data = default(T);
121 try
122 {
123 data = func.Invoke();
124 }
125 catch
126 {
127 throw new Exception("Func Invoke Exception."); ;
128 }
129 AddOrUpdate(key, data, lifeCycle);
130 return data;
131 }
132
133 /// <summary>
134 /// 是否存在缓存数据
135 /// </summary>
136 /// <param name="key">键</param>
137 /// <param name="containerIndex">容器索引</param>
138 /// <returns>返回 Bool</returns>
139 public static bool IsExistsCacheData(string key, out int containerIndex)
140 {
141 containerIndex = Math.Abs(key.GetHashCode() % cpuCount);
142 if (cacheContainer[containerIndex].ContainsKey(key))
143 {
144 var cache = cacheContainer[containerIndex][key];
145 if (cache.LifeCycleType == LifeCycle.Temp && DateTime.Now > cache.CacheDateTime)
146 {
147 cacheContainer[containerIndex].TryRemove(key, out DataModel dataModel);
148 return false;
149 }
150 return true;
151 }
152 return false;
153 }
154 }
1 public class DataModel
2 {
3 /// <summary>
4 /// 生命周期类型
5 /// </summary>
6 public LifeCycle LifeCycleType { get; set; }
7
8 /// <summary>
9 /// 缓存时间
10 /// </summary>
11 public DateTime CacheDateTime { get; set; }
12
13 /// <summary>
14 /// 缓存数据
15 /// </summary>
16 public object CacheData { get; set; }
17 }
1 public enum LifeCycle
2 {
3 Lasting = 0,//持久
4 Temp = 1//临时
5 }
—————————————————————————————————————————————————————————————————————————————————————————————————————————————————
原文地址：https://www.cnblogs.com/JingYeChong/p/11106134.html
时间： 2024-10-30 16:33:45