我有話說(shuō)

本來(lái)這一篇我打算放到后面再說(shuō)，可是之前泄漏了一點(diǎn)關(guān)于緩存決策的代碼后被好多人催更了。

在此感謝大家的支持，讓我更有動(dòng)力的寫(xiě)這個(gè)系列。你們的關(guān)注讓我覺(jué)得我的決定是對(duì)的，我會(huì)堅(jiān)持下去把這個(gè)項(xiàng)目做完。

另外非常感謝老虎，在百忙之中給我們趕出需求文檔，當(dāng)我們?cè)谙硎苤苣┑臅r(shí)候他還在公司加班，即便這樣，他依然為我們的開(kāi)源項(xiàng)目奉獻(xiàn)著。

此時(shí)我不知道該說(shuō)些什么，只能以我的行動(dòng)來(lái)回報(bào)大家，廢話不多說(shuō)了，入正題。

緩存決策

先澄清下，這個(gè)名字是我杜撰的，因?yàn)槲矣X(jué)得在我的項(xiàng)目中它起到了這樣的作用。

緩存：在我做的這個(gè)功能中涉及到內(nèi)存和redis兩部分的緩存。

決策：我從百度找的翻譯，指做出決定或選擇,是一種“在各種替代方案中考慮各項(xiàng)因素作出選擇”的認(rèn)知、思考過(guò)程。

那么緩存決策到底是干什么的？

說(shuō)白了就是選擇使用數(shù)據(jù)庫(kù)還是緩存。

如何適合緩存決策

緩存決策的由來(lái) - 我是懶人

因?yàn)槲覒校晕乙朕k法偷懶。

我希望有一個(gè)類(lèi)庫(kù)可以幫助我來(lái)判斷當(dāng)前的數(shù)據(jù)是到緩存里取，還是數(shù)據(jù)庫(kù)里取。

而為了實(shí)現(xiàn)這樣的一個(gè)功能，我覺(jué)得我應(yīng)該建立一個(gè)規(guī)則，這個(gè)規(guī)則來(lái)幫助我判斷當(dāng)前數(shù)據(jù)在緩存里是不是有一份拷貝。

我對(duì)緩存的判斷規(guī)則有什么要求？

就以目前項(xiàng)目來(lái)說(shuō)，我緩存是整表緩存的，所以我需要判斷的是當(dāng)前數(shù)據(jù)是屬于哪個(gè)表。

既然如此，那我判斷的依據(jù)應(yīng)該是這樣： 緩存決策規(guī)則.表名列表.包含(數(shù)據(jù).表名) == true

只要滿足上面的條件，說(shuō)明當(dāng)前數(shù)據(jù)在緩存里是有拷貝的。

如何管理這些判斷規(guī)則？

繼續(xù)上面提到的包含，我們?cè)俜治鲆幌?，包含的判斷依?jù)其實(shí)是逐一比對(duì)相等，所以我想了個(gè)類(lèi)名：EqualsMonitorManager，這里的Monitor是監(jiān)視器的意思，后面的類(lèi)都會(huì)跟這個(gè)詞有關(guān)。

這個(gè)類(lèi)有4個(gè)基本的方法：Add、Remove、Get、IsMonitoring ，看起來(lái)其實(shí)是很像字典的對(duì)吧？其實(shí)內(nèi)部實(shí)現(xiàn)確實(shí)依賴了字典，對(duì)字典做了一些封裝。

為了方面以后擴(kuò)展支持到更多場(chǎng)景而不局限于緩存，我定義的時(shí)候使用到了泛型。

public static partial class EqualsMonitorManager<TKey, TValue>  
        where TValue : IEquatable<TValue>  
    {  
        private static class MonitorCaller<TCallerKey>  
        {  
            public static Action<TCallerKey, TValue> Add;  
 
            public static Action<TCallerKey> Remove;  
 
            public static Func<TCallerKey, Func<TValue, bool>, TValue> Get;  
 
            public static Func<TCallerKey, TValue, bool> IsMonitoring;  
        }  
 
        #region Members  
 
        private static Dictionary<string, List<TValue>> _dicStringMonitor = new Dictionary<string, List<TValue>>();  
 
        #endregion  
 
        static EqualsMonitorManager()  
        {  
            StringMonitorCallerInit();  
        }  
 
        private static void StringMonitorCallerInit()  
        {  
            MonitorCaller<string>.Add = (string key, TValue value) =>  
            {  
                if (!_dicStringMonitor.ContainsKey(key))  
                {  
                    _dicStringMonitor.Add(key, new List<TValue>());  
                }  
 
                _dicStringMonitor[key].Add(value);  
            };  
 
            MonitorCaller<string>.Remove = (string key) =>  
            {  
                if (_dicStringMonitor.ContainsKey(key))  
                    _dicStringMonitor.Remove(key);  
            };  
 
            MonitorCaller<string>.Get = (string key, Func<TValue, bool> predicate) =>  
            {  
                if (_dicStringMonitor.ContainsKey(key))  
                    return _dicStringMonitor[key].FirstOrDefault(predicate);  
                else 
                    return default(TValue);  
            };  
 
            MonitorCaller<string>.IsMonitoring = (string key, TValue value) =>  
            {  
                if (!_dicStringMonitor.ContainsKey(key))  
                {  
                    return false;  
                }  
 
                return _dicStringMonitor[key].Exists(x => x.Equals(value));  
            };  
        }  
    } 

public static partial class EqualsMonitorManager<TKey, TValue>  
    {  
        public static void Add(TKey key, TValue value)  
        {  
            if (key == null)  
            {  
                throw new ArgumentNullException();  
            }  
            MonitorCaller<TKey>.Add(key, value);  
        }  
 
        public static void Remove(TKey key)  
        {  
            if (key == null)  
            {  
                throw new ArgumentNullException();  
            }  
            MonitorCaller<TKey>.Remove(key);  
        }  
 
        public static TValue Get(TKey key, Func<TValue, bool> predicate)  
        {  
            if (key == null)  
            {  
                throw new ArgumentNullException();  
            }  
            return MonitorCaller<TKey>.Get(key, predicate);  
        }  
 
        public static bool IsMonitoring(TKey key, TValue value)  
        {  
            if (key == null)  
            {  
                throw new ArgumentNullException();  
            }  
 
            return MonitorCaller<TKey>.IsMonitoring(key, value);  
        }  
    } 

這里的代碼用到了老趙博客中的一篇關(guān)于“逆泛型”的代碼，這里是未經(jīng)優(yōu)化的，寫(xiě)的倉(cāng)促。

這里我就不多解釋為什么會(huì)這么寫(xiě)這個(gè)類(lèi)了，有興趣可以去翻老趙的博客，寫(xiě)的很詳細(xì)，對(duì)于初學(xué)者來(lái)說(shuō)這里有點(diǎn)繞，建議可以去看看。

這里只是創(chuàng)建了一個(gè)最基礎(chǔ)的封裝過(guò)的“字典”，用于管理判斷規(guī)則。

初始化判斷規(guī)則

有了管理規(guī)則的類(lèi)，那么我們的項(xiàng)目中首先要做的就是初始化這些規(guī)則，否則沒(méi)有規(guī)則后面的寫(xiě)下去也用不了。

細(xì)心的朋友可能會(huì)發(fā)現(xiàn)，EqualsMonitorManager的TValue需要繼承自IEquatable接口，因?yàn)閮?nèi)部判斷相等是用了這個(gè)接口的Equals方法。

那么，我們第一個(gè)緩存決策類(lèi)出現(xiàn)了，它就是RedisCacheMonitor。

public class RedisCacheMonitor : IEquatable<RedisCacheMonitor>  
    {  
        public string Key { get { return MonitorConstant.REDIS_KEY; } }  
 
        public string TableName { get; set; }  
 
        public string[] Fields { get; set; }  
 
        #region IEquatable<RedisCacheMonitor> 成員  
 
        public bool Equals(RedisCacheMonitor other)  
        {  
            if (other == null)  
            {  
                return false;  
            }  
 
            return this.TableName == other.TableName;  
        }  
 
        #endregion  
    } 

我們可以發(fā)現(xiàn)，這個(gè)類(lèi)的自由度很大，唯一的約束就是要實(shí)現(xiàn)IEquatable接口，這樣EqualMonitorManager的可擴(kuò)展性就充分被利用了起來(lái)。
而RedisCacheMonitor就可以任由我們來(lái)發(fā)揮，我們只需要告訴EqualMonitorManager如何去判斷相等即可。

TableName表示緩存的表名，F(xiàn)ields是使用了Redis HGet命令的一個(gè)參數(shù)名，表示哪些字段可以作為關(guān)鍵字來(lái)查詢數(shù)據(jù)或者說(shuō)需要緩存哪些字段為關(guān)鍵字。

接下來(lái)就是如何把一個(gè)RedisCacheMonitor加入到EqualMonitorManager

var monitor = new RedisCacheMonitor() { TableName = "User", Fields = new string[] { "Id", "UserName" } };  
EqualsMonitorManager<string, RedisCacheMonitor>.Add(monitor.Key, monitor); 

是的，就這么簡(jiǎn)單，我們的緩存規(guī)則就加完了。剩下就是操作Redis，把User表緩存起來(lái)我就不多說(shuō)了。

#p#

自動(dòng)緩存決策與手動(dòng)緩存決策

為什么會(huì)有自動(dòng)和手動(dòng)兩種？

因?yàn)槲也僮鲾?shù)據(jù)庫(kù)用的EF，查詢條件是表達(dá)式樹(shù)，為了降低解析表達(dá)式樹(shù)的工作量暫時(shí)選擇了自動(dòng)和手動(dòng)。

如何實(shí)現(xiàn)手動(dòng)緩存決策？

var monitor = EqualsMonitorManager<string, RedisCacheMonitor>.Get(MonitorConstant.REDIS_KEY, x => x.TableName == tableName);  
 
if (monitor != null)  
{  
    //todo something  
}  

手動(dòng)決策很簡(jiǎn)單，只要嘗試獲取一下即可，獲取到monitor就說(shuō)明被緩存了，下面就可以直接取緩存了。

如何實(shí)現(xiàn)自動(dòng)緩存決策？

看到第一篇的應(yīng)該對(duì)下面的代碼有印象，我把之前寫(xiě)的內(nèi)容直接copy過(guò)來(lái)一份：

SaveChangesAsync是EF的異步保存方法，我們要做的事情其實(shí)很簡(jiǎn)單，就是攔截保存方法，代碼中是SaveAsync，這個(gè)是我們自己針對(duì)EF封裝后的方法。

大概思路是這樣的：

想要讓 SaveAsync 聽(tīng)我們的話， override 就派上了用場(chǎng)，重寫(xiě) SaveAsync。

調(diào)用基類(lèi)的 SaveAsync 后，再加上保存到Redis的代碼。

這樣一個(gè)SaveAsync就變成了做2件事，先保存到數(shù)據(jù)庫(kù)再保存到Redis，從而杜絕了代碼中到處寫(xiě)保存到Redis的重復(fù)代碼。

public class DataWrapper<T> : EFWrapperBase<T>  
        where T : class,new()  
    {  
        public DataWrapper()  
        {  
            base.Context.EventRegistModel += ModelRegister.Regist;  
        }  
 
        public override async Task<int> SaveAsync()  
        {  
            var result = await base.SaveAsync();  
 
            SaveToRedis();  
 
            return result;  
        }  
 
        private void SaveToRedis()  
        {  
            try 
            {  
                var type = typeof(T);  
                var monitor = EqualsMonitorManager<string, RedisCacheMonitor>.Get(MonitorConstant.REDIS_KEY, x => x.TableName == type.Name);  
                if (monitor != null)  
                {  
                    foreach (var entity in base.DbSet.Local)  
                    {  
                        foreach (var field in monitor.Fields)  
                        {  
                            var pi = type.GetProperty(field);  
                            RedisSingleton.GetInstance.Client.HSet(type.Name, string.Format("{0}:{1}", pi.Name, pi.GetValue(entity, null).ToString()), entity);  
                        }  
                    }  
                }  
            }  
            catch (Exception ex)  
            {  
                Logger.Error(ex.ToString());  
            }  
        }  
 
    } 

源碼

源碼地址：http://git.oschina.net/doddgu/PaPaPa

PS：其實(shí)想想真的不難，主要是一種思路，用到的都是基本的C#語(yǔ)法，關(guān)鍵在于你敢不敢想，而我敢想了，你還在猶豫嗎？后面我們會(huì)有更多敢想敢做的事，歡迎你的加入。

原文出自：http://www.cnblogs.com/doddgu/p/papapa_huancunjuece.html