實(shí)現(xiàn)A+ES的幾個(gè)常見問題

????????在上一篇文章中颜屠,介紹了A+ES的基本概念及適合解決的一些問題辰妙,我們看到分布式最終一致性的解決方案的巧妙。如果您想實(shí)踐一下A+ES汽纤,先別急上岗,今天我們看看實(shí)踐過程中的常見問題福荸,實(shí)踐者可以更好的理解A+ES蕴坪,也為選型提供一些參考。

1. 并發(fā)控制

????????當(dāng)多個(gè)線程或多個(gè)實(shí)例同時(shí)訪問聚合的事件流,這將導(dǎo)制一些潛在的并發(fā)沖突背传,從而使聚合處于不正確的狀態(tài)呆瞻。如圖所示:

? ? ? ? 最簡單的方法就是在線程2處理事件4時(shí)拋出一個(gè)EventStoreConcurrency Exception供最終用戶處理,需要時(shí)也可以捕獲這個(gè)異常進(jìn)行重試径玖。

????????如果重新執(zhí)行聚合的成本過高痴脾,或者不方便重新執(zhí)行,那么我可以使用事件沖突決議(Event conflict resolution),它可以減少并發(fā)所致的異常梳星。這種方法的基本思想是在追加到事件流之前對事件進(jìn)行比對校驗(yàn)赞赖。

2. 性能

????????如果一個(gè)事件流由成百上千個(gè)事件組成,那么我們在回放一個(gè)聚合時(shí)可能會(huì)有性能問題冤灾。解決方法有兩種:

????????a. 版本號前域,為事件指定版本號,在內(nèi)存中緩存加載過的事件韵吨,在聚合進(jìn)行操作時(shí)匿垄,基于最后一個(gè)版本號獲取該事件之后的那些事件進(jìn)行播放。這種方法是以內(nèi)存換取性能归粉。

????????b. 聚合快照椿疗,在加載聚合實(shí)例時(shí),我們只需要加載最近的一次快照糠悼,然后對發(fā)生在其后的事件進(jìn)行重放届榄。也可以使用資源庫來訪問快照。

3. 如何實(shí)現(xiàn)事件存儲

????????事件可以存儲在SQL绢掰,NoSQL或基于文件的BLOB存儲痒蓬。存儲的實(shí)現(xiàn)都比較簡單,我們看一下基于關(guān)系支持版本號的存儲表結(jié)構(gòu)如何設(shè)計(jì):

? ? ? ? 如果使用基于文件的BLOB存儲的滴劲,一般策略是:每個(gè)聚合實(shí)例對應(yīng)一個(gè)文件攻晒,每個(gè)事件對應(yīng)一條記錄:

4. 讀模型投射

????????上一篇我們提到在基于A+ES的實(shí)踐中,如何實(shí)現(xiàn)不同維度的聚合查詢是常見問題班挖,例:最近一個(gè)月所有客戶的訂單總量鲁捏。對于A+ES的實(shí)踐中,并沒有像關(guān)系型數(shù)據(jù)庫那樣靈活的連接查詢操作萧芙。差勁的方法是先構(gòu)建聚合给梅,然后重播所有事件,讓當(dāng)前聚合進(jìn)入正確的狀態(tài)双揪,然后匹配我們的查詢條件动羽,One by one最終得到我們想要的結(jié)果。想想就很復(fù)雜渔期,實(shí)踐中我們一般不會(huì)這樣去做运吓,這里我們推薦一種被稱為讀模型投射(Read Model Projection)可供查詢使用的模式渴邦。

????????讀模型投射中,使用一組簡單的領(lǐng)域事件訂閱方來生成和更新讀模型拘哨,當(dāng)訂閱方接收到新的事件時(shí)谋梭,它們將計(jì)算一些查詢結(jié)果,然后將這些結(jié)果保存了到讀模型中以供后續(xù)使用倦青。

5. 事件變更的支持

????????在敏捷實(shí)踐中瓮床,我們提倡小步快跑,快速開發(fā)产镐,在應(yīng)對新需求的加入時(shí)隘庄,可以讓現(xiàn)在模型演化達(dá)到支持新需求的目的,那么如果我們的新需求需要修改領(lǐng)域事件該如何處理呢癣亚?

????????如果我們只是簡單的變更了字段峭沦,那么必然會(huì)對訂閱方產(chǎn)生影響,這時(shí)選擇一個(gè)有利于版本控制和事件重命名的序列器是不錯(cuò)的選擇逃糟,對于不同版本的屬性變更可以通過標(biāo)簽而不是名字來跟蹤各個(gè)契約成員吼鱼。Google 開源了一個(gè)Protocol Buffer可供選擇。

總結(jié)

????????A+ES不同于我們原來的基于數(shù)據(jù)庫的應(yīng)用绰咽,它在某種程度上簡化了一類問題的解決方法菇肃,同時(shí)也讓另一類問題變得復(fù)雜,今天的內(nèi)容希望能夠幫助我們的實(shí)踐者在做架構(gòu)決策提提供更多的支持取募。

最后編輯于
?著作權(quán)歸作者所有,轉(zhuǎn)載或內(nèi)容合作請聯(lián)系作者
  • 序言:七十年代末琐谤,一起剝皮案震驚了整個(gè)濱河市,隨后出現(xiàn)的幾起案子玩敏,更是在濱河造成了極大的恐慌斗忌,老刑警劉巖,帶你破解...
    沈念sama閱讀 216,744評論 6 502
  • 序言:濱河連續(xù)發(fā)生了三起死亡事件旺聚,死亡現(xiàn)場離奇詭異织阳,居然都是意外死亡,警方通過查閱死者的電腦和手機(jī)砰粹,發(fā)現(xiàn)死者居然都...
    沈念sama閱讀 92,505評論 3 392
  • 文/潘曉璐 我一進(jìn)店門唧躲,熙熙樓的掌柜王于貴愁眉苦臉地迎上來,“玉大人碱璃,你說我怎么就攤上這事弄痹。” “怎么了嵌器?”我有些...
    開封第一講書人閱讀 163,105評論 0 353
  • 文/不壞的土叔 我叫張陵肛真,是天一觀的道長。 經(jīng)常有香客問我爽航,道長蚓让,這世上最難降的妖魔是什么庇谆? 我笑而不...
    開封第一講書人閱讀 58,242評論 1 292
  • 正文 為了忘掉前任,我火速辦了婚禮凭疮,結(jié)果婚禮上,老公的妹妹穿的比我還像新娘串述。我一直安慰自己执解,他們只是感情好,可當(dāng)我...
    茶點(diǎn)故事閱讀 67,269評論 6 389
  • 文/花漫 我一把揭開白布纲酗。 她就那樣靜靜地躺著衰腌,像睡著了一般。 火紅的嫁衣襯著肌膚如雪觅赊。 梳的紋絲不亂的頭發(fā)上右蕊,一...
    開封第一講書人閱讀 51,215評論 1 299
  • 那天,我揣著相機(jī)與錄音吮螺,去河邊找鬼饶囚。 笑死,一個(gè)胖子當(dāng)著我的面吹牛鸠补,可吹牛的內(nèi)容都是我干的萝风。 我是一名探鬼主播,決...
    沈念sama閱讀 40,096評論 3 418
  • 文/蒼蘭香墨 我猛地睜開眼紫岩,長吁一口氣:“原來是場噩夢啊……” “哼规惰!你這毒婦竟也來了?” 一聲冷哼從身側(cè)響起泉蝌,我...
    開封第一講書人閱讀 38,939評論 0 274
  • 序言:老撾萬榮一對情侶失蹤歇万,失蹤者是張志新(化名)和其女友劉穎,沒想到半個(gè)月后勋陪,有當(dāng)?shù)厝嗽跇淞掷锇l(fā)現(xiàn)了一具尸體贪磺,經(jīng)...
    沈念sama閱讀 45,354評論 1 311
  • 正文 獨(dú)居荒郊野嶺守林人離奇死亡,尸身上長有42處帶血的膿包…… 初始之章·張勛 以下內(nèi)容為張勛視角 年9月15日...
    茶點(diǎn)故事閱讀 37,573評論 2 333
  • 正文 我和宋清朗相戀三年诅愚,在試婚紗的時(shí)候發(fā)現(xiàn)自己被綠了缘挽。 大學(xué)時(shí)的朋友給我發(fā)了我未婚夫和他白月光在一起吃飯的照片。...
    茶點(diǎn)故事閱讀 39,745評論 1 348
  • 序言:一個(gè)原本活蹦亂跳的男人離奇死亡呻粹,死狀恐怖壕曼,靈堂內(nèi)的尸體忽然破棺而出,到底是詐尸還是另有隱情等浊,我是刑警寧澤腮郊,帶...
    沈念sama閱讀 35,448評論 5 344
  • 正文 年R本政府宣布,位于F島的核電站筹燕,受9級特大地震影響轧飞,放射性物質(zhì)發(fā)生泄漏衅鹿。R本人自食惡果不足惜,卻給世界環(huán)境...
    茶點(diǎn)故事閱讀 41,048評論 3 327
  • 文/蒙蒙 一过咬、第九天 我趴在偏房一處隱蔽的房頂上張望大渤。 院中可真熱鬧,春花似錦掸绞、人聲如沸泵三。這莊子的主人今日做“春日...
    開封第一講書人閱讀 31,683評論 0 22
  • 文/蒼蘭香墨 我抬頭看了看天上的太陽烫幕。三九已至,卻和暖如春敞映,著一層夾襖步出監(jiān)牢的瞬間较曼,已是汗流浹背。 一陣腳步聲響...
    開封第一講書人閱讀 32,838評論 1 269
  • 我被黑心中介騙來泰國打工振愿, 沒想到剛下飛機(jī)就差點(diǎn)兒被人妖公主榨干…… 1. 我叫王不留捷犹,地道東北人。 一個(gè)月前我還...
    沈念sama閱讀 47,776評論 2 369
  • 正文 我出身青樓冕末,卻偏偏與公主長得像伏恐,于是被迫代替她去往敵國和親。 傳聞我的和親對象是個(gè)殘疾皇子栓霜,可洞房花燭夜當(dāng)晚...
    茶點(diǎn)故事閱讀 44,652評論 2 354

推薦閱讀更多精彩內(nèi)容