基于Senparc.CO2NET 缓存策略扩展的缓存使用方法

//-----------------------------------------------------------------------// <copyright file="CacheFactory.cs" company="FenSiShengHuo, Ltd.">// ????Copyright (c) 2018 , All rights reserved.// </copyright>//-----------------------------------------------------------------------using Senparc.CO2NET.Cache;using Senparc.Weixin.Cache;using System;namespace DotNet.WeChat.CommonService.Utilities{ ???using DotNet.MVC.Infrastructure.Models; ???/// <summary> ???/// ?CacheFactory 基于 ???/// ???/// 修改记录 ???/// ???/// ???????2018-04-20 版本：1.0 JiShiYu 创建文件。 ???/// ???/// <author> ???/// ????<name>JiShiYu</name> ???/// ????<date>2018-04-20</date> ???/// </author> ???/// </summary> ???public class CacheFactory ???{ ???????/// <summary> ???????/// 缓存处理 Redis ???????/// </summary> ???????/// <param name="cacheKey">缓存的Key</param> ???????/// <param name="proc">处理函数</param> ???????/// <param name="isCache">是否从缓存取</param> ???????/// <param name="refreshCache">是否强制刷新缓存</param> ???????/// <param name="expireAt">什么时候过期</param> ???????/// <returns></returns> ???????public static HashSetCacheModel<T> Cache<T>(string cacheKey, Func<HashSetCacheModel<T>> proc,bool isCache = false, bool refreshCache = false) ???????{ ???????????HashSetCacheModel<T> result; ???????????if (!isCache) ???????????{ ???????????????result = proc(); ???????????} ???????????else ???????????{ ???????????????IContainerCacheStrategy containerCache = LocalContainerCacheStrategy.Instance; ???????????????IBaseObjectCacheStrategy baseCache = containerCache.BaseCacheStrategy(); ???????????????// 缓存 ???????????????if (baseCache.CheckExisted(cacheKey)) //判断是否有缓存 ???????????????{ ???????????????????//已经缓存 ???????????????????if (refreshCache)//是否强制刷新缓存 ???????????????????{ ???????????????????????//强制刷新 ???????????????????????result = proc(); ???????????????????????baseCache.Update(cacheKey, result); ???????????????????} ???????????????????else ???????????????????{ ???????????????????????//不强制刷新 ???????????????????????result = baseCache.Get<HashSetCacheModel<T>>(cacheKey); ???????????????????????// 判断是否过期了 ???????????????????????if (result.ExpireAt < DateTime.Now) ???????????????????????{ ???????????????????????????result = proc(); ???????????????????????????baseCache.Update(cacheKey, result); ???????????????????????} ???????????????????} ???????????????} ???????????????else ???????????????{ ???????????????????// 缓存中没有数据 获取一次存入缓存 ???????????????????result = proc(); ???????????????????baseCache.Set(cacheKey, result); ???????????????} ???????????} ???????????return result; ???????} ???}}

 ???????/// <summary> ???????/// 获取微信用户 ???????/// </summary> ???????/// <param name="weixinAppId"></param> ???????/// <param name="openId"></param> ???????/// <param name="refresh"></param> ???????/// <returns></returns> ???????protected WechatUserEntity GetWechatUser(string weixinAppId, string openId, bool refresh = false) ???????{ ???????????WechatUserEntity wechatUserEntity = null; ???????????// 进行缓存 ???????????try ???????????{ ???????????????string cacheKey = "WechatUser:" + weixinAppId + ":" + openId; ???????????????HashSetCacheModel<WechatUserEntity> hashCacheModel= CacheFactory.Cache<WechatUserEntity>(cacheKey, () => ???????????????{ ???????????????????WechatUserManager wechatUserManager = new WechatUserManager(); ???????????????????wechatUserEntity = wechatUserManager.GetObjectByWechatAppIdByOpenId(weixinAppId, openId); ???????????????????var cacheModel = new HashSetCacheModel<WechatUserEntity>(); ???????????????????cacheModel.CreateOn = DateTime.Now; ???????????????????cacheModel.ExpireAt = DateTime.Now.AddMinutes(10); ???????????????????cacheModel.Value = wechatUserEntity; ???????????????????return cacheModel; ???????????????}); ???????????????return hashCacheModel.Value; ???????????????//IContainerCacheStrategy containerCache = LocalContainerCacheStrategy.Instance; ???????????????//IBaseObjectCacheStrategy baseCache = containerCache.BaseCacheStrategy(); ???????????????//HashSetCacheModel<WechatUserEntity> cacheModel = null; ???????????????//// 强制刷新缓存 ???????????????//if (refresh) ???????????????//{ ???????????????// ???if (baseCache.CheckExisted(key)) ???????????????// ???{ ???????????????// ???????baseCache.RemoveFromCache(key); ???????????????// ???} ???????????????//} ???????????????//if (baseCache.CheckExisted(key)) ???????????????//{ ???????????????// ???cacheModel = baseCache.Get<HashSetCacheModel<WechatUserEntity>>(key); ???????????????// ???if (cacheModel.ExpireAt < DateTime.Now) ???????????????// ???{ ???????????????// ???????// 过期了，要更新一次 ???????????????// ???????WechatUserManager wechatUserManager = new WechatUserManager(); ???????????????// ???????wechatUserEntity = wechatUserManager.GetObjectByWechatAppIdByOpenId(weixinAppId, openId); ???????????????// ???????cacheModel = new HashSetCacheModel<WechatUserEntity>(); ???????????????// ???????cacheModel.CreateOn = DateTime.Now; ???????????????// ???????cacheModel.ExpireAt = DateTime.Now.AddMinutes(10); ???????????????// ???????cacheModel.Value = wechatUserEntity; ???????????????// ???????baseCache.Update(key, cacheModel); ???????????????// ???} ???????????????// ???wechatUserEntity = cacheModel.Value; ???????????????//} ???????????????//else ???????????????//{ ???????????????// ???WechatUserManager wechatUserManager = new WechatUserManager(); ???????????????// ???wechatUserEntity = wechatUserManager.GetObjectByWechatAppIdByOpenId(weixinAppId, openId); ???????????????// ???cacheModel = new HashSetCacheModel<WechatUserEntity>(); ???????????????// ???cacheModel.CreateOn = DateTime.Now; ???????????????// ???cacheModel.ExpireAt = DateTime.Now.AddMinutes(10); ???????????????// ???cacheModel.Value = wechatUserEntity; ???????????????// ???baseCache.Set(key, cacheModel); ???????????????//} ???????????} ???????????catch (Exception ex) ???????????{ ???????????????NLogHelper.Warn(ex, "GetCurrentAutoreplyInfo,weixinAppId=" + weixinAppId); ???????????} ???????????return wechatUserEntity; ???????}