基于發(fā)布訂閱模式的中間件設(shè)計(jì)與實(shí)現(xiàn).pdf

1、隨著互聯(lián)網(wǎng)技術(shù)的飛速發(fā)展，云計(jì)算成為主流，后臺演變?yōu)樵絹碓綇?fù)雜的分布式系統(tǒng)，并且應(yīng)用范圍和規(guī)模不斷的擴(kuò)大。為了讓這些數(shù)量龐大的機(jī)器通信和協(xié)作來完成現(xiàn)代社會(huì)的計(jì)算任務(wù)，迫切需要一種異步的，多點(diǎn)通信的基礎(chǔ)架構(gòu)，滿足互聯(lián)網(wǎng)大型應(yīng)用系統(tǒng)松散通信的需求，從而為構(gòu)建大規(guī)模分布式應(yīng)用系統(tǒng)打下良好的基礎(chǔ)。發(fā)布/訂閱的通信方式很好的解決了這種問題，它使得消息的生產(chǎn)者和消費(fèi)者在時(shí)間，空間上充分地解耦，具有異步，松散耦合和多對多通信的特點(diǎn)。本文在此背景下，對

2、發(fā)布/訂閱系統(tǒng)做了深入研究，設(shè)計(jì)了一個(gè)發(fā)布/訂閱模式的中間件，并且對核心模塊事件過濾器，設(shè)計(jì)了高效的匹配算法，采用多級索引，位運(yùn)算，對訂閱做聚類，減少了多余的匹配，有效地提高了系統(tǒng)的吞吐量。整個(gè)系統(tǒng)由三部分組成，發(fā)布者，訂閱者，發(fā)布訂閱中間件。發(fā)布者即信息的生產(chǎn)者，把產(chǎn)生的數(shù)據(jù)源源不斷地輸入到系統(tǒng)當(dāng)中。信息的訂閱者則向中間件定義一個(gè)訂閱條件，表示對系統(tǒng)中的哪些信息感興趣。這樣的話，信息消費(fèi)者便能夠通過中間件，及時(shí)，可靠地得到發(fā)布過的感興

3、趣消息。中間件是整個(gè)系統(tǒng)的核心部分，有發(fā)布代理服務(wù)器，訂閱代理服務(wù)器，事件代理服務(wù)器。事件代理服務(wù)器負(fù)責(zé)整個(gè)事件的過濾和路由，將事件表示成一系列謂詞組成的集合，通過匹配合適的謂詞，選擇性的分發(fā)來自發(fā)布者的數(shù)據(jù)，通知感興趣的訂閱者，達(dá)到了基于內(nèi)容的匹配目標(biāo)，區(qū)別于傳統(tǒng)的基于主題的匹配方式，給系統(tǒng)帶來了很大的靈活性。發(fā)布代理服務(wù)器負(fù)責(zé)接受生產(chǎn)者的事件消息，過濾掉垃圾內(nèi)容，發(fā)送給發(fā)布訂閱的中間件，做匹配和路由。訂閱代理服務(wù)器，則接受訂閱者的訂

4、閱信息，發(fā)送給事件代理器，發(fā)布訂閱模式的中間件則對訂閱條件做處理，便于更快的做事件匹配。事件過濾器是中間件的最核心模塊，效率高低關(guān)乎著整個(gè)系統(tǒng)的響應(yīng)速度。本文通過事先做預(yù)處理，把對興趣具有一定共性的訂閱放到一組，并且提取其中的謂詞做多級索引，按照屬性類別如類型，名字，操作符分為三級，對等號操作符構(gòu)造哈希表，對于大于，小于符號按照約束關(guān)系做排序，所以對于小于號索引的某個(gè)謂詞符合要求，則該值后面的謂詞也符合要求，可以大幅度的減少匹配次數(shù)。并