隨著智慧城市的到來(lái),智慧水務(wù)也成為了一個(gè)很重要的命題。而對(duì)于自來(lái)水供水企業(yè),如何高效便捷的管理供水、智能收費(fèi)也就成為了當(dāng)前水務(wù)信息化建設(shè)的重要組成部分,在此需求下,智能水表系統(tǒng)作為一種高效的解決方案應(yīng)運(yùn)而生。智能水表系統(tǒng)在設(shè)計(jì)上就被拆分成Web管理模塊、數(shù)據(jù)采集模塊、數(shù)據(jù)存儲(chǔ)服務(wù)、數(shù)據(jù)傳輸服務(wù),模塊之間均是相互獨(dú)立,互不影響,該設(shè)計(jì)能大幅降低系統(tǒng)內(nèi)部的內(nèi)部耦合�，F(xiàn)有的數(shù)據(jù)傳輸服務(wù)方案是建立在數(shù)據(jù)共享的方式上,由于Web管理模塊與數(shù)據(jù)采集模塊之間的消息命令傳輸存在一些特異性,此方案并不能有效地解決以下問(wèn)題:1)數(shù)據(jù)傳輸?shù)母咝浴⒖煽啃?并且數(shù)據(jù)可以被實(shí)時(shí)處理或離線處理。2)數(shù)據(jù)庫(kù)的讀寫(xiě)壓力大,會(huì)影響其它數(shù)據(jù)的存儲(chǔ)和其他功能的運(yùn)轉(zhuǎn)。為解決上述問(wèn)題,本文開(kāi)展的主要研究工作如下:1)通過(guò)分析、測(cè)試對(duì)比主流的消息隊(duì)列,最終確定Kafka消息系統(tǒng)作為智能水表系統(tǒng)內(nèi)部數(shù)據(jù)通信服務(wù)的解決方案。2)結(jié)合智能水表系統(tǒng)設(shè)計(jì)基于Kafka消息系統(tǒng)的生產(chǎn)者、消費(fèi)者實(shí)現(xiàn)方案,數(shù)據(jù)傳輸格式方案,消息分類(lèi)處理的方案。3)在智能水表系統(tǒng)中應(yīng)用Kafka消息系統(tǒng)后,本文針對(duì)Kafka生產(chǎn)者、消費(fèi)者的性能進(jìn)行相關(guān)參數(shù)的壓力... 

【文章來(lái)源】：華中科技大學(xué)湖北省 211工程院校 985工程院校 教育部直屬院校

【文章頁(yè)數(shù)】：56 頁(yè)

【學(xué)位級(jí)別】：碩士

【部分圖文】：

性能對(duì)比結(jié)果

圖 4-7 消費(fèi)者線程運(yùn)行流程圖費(fèi)者線程啟動(dòng)后將一直監(jiān)聽(tīng)消息隊(duì)消費(fèi)者線程將從消息代理中拉取數(shù)據(jù)礎(chǔ)上，分析了智能水表系統(tǒng)的子模塊需求之后，給出了一個(gè)基于 Kafka 消式以及通信方式的設(shè)計(jì)方案。

華 中 科 技 大 學(xué) 碩 士 學(xué) 位 論 文是該接口的一個(gè)實(shí)現(xiàn)者，業(yè)務(wù)類(lèi)實(shí)際上是封裝了一個(gè) Kafka 的生產(chǎn)者對(duì)象來(lái)實(shí)現(xiàn)基本消息發(fā)送方法 sendMessage()，由于異步模式下的生產(chǎn)者不需要確認(rèn)消息是否送達(dá)，在消息 send() 之后，生產(chǎn)者線程當(dāng)即閑置下來(lái)，為了實(shí)現(xiàn)該生產(chǎn)者的復(fù)用，業(yè)務(wù)類(lèi)提供了一個(gè)可復(fù)用的單例生產(chǎn)者，生產(chǎn)者端的類(lèi)圖如下所示：

【參考文獻(xiàn)】：
期刊論文
[1]基于擴(kuò)頻通信的無(wú)線抄表系統(tǒng)設(shè)計(jì)與實(shí)現(xiàn)[J]. 龔陽(yáng),崔琛,王津,余劍.  計(jì)算機(jī)測(cè)量與控制. 2016(12)
[2]一種優(yōu)化的Kafka消費(fèi)者/客戶端負(fù)載均衡算法[J]. 王鄭合,王鋒,鄧輝,柳翠寅,張曉麗.  計(jì)算機(jī)應(yīng)用研究. 2017(08)
[3]一種基于Kafka的可靠的Consumer的設(shè)計(jì)方案[J]. 王巖,王純.  軟件. 2016(01)
[4]基于JSON的數(shù)據(jù)交換模型[J]. 張滬寅,屈乾松,胡瑞蕓.  計(jì)算機(jī)工程與設(shè)計(jì). 2015(12)
[5]中間件技術(shù)在數(shù)據(jù)交換中的應(yīng)用研究[J]. 王永才,宋才華.  自動(dòng)化與儀器儀表. 2015(11)
[6]基于Kafka消息隊(duì)列的電網(wǎng)設(shè)備準(zhǔn)實(shí)時(shí)數(shù)據(jù)接入方法研究[J]. 王震,陳亮.  山東電力技術(shù). 2015(06)
[7]Redis在訂閱推送系統(tǒng)中的應(yīng)用[J]. 吳霖,劉振宇,李佳.  電腦知識(shí)與技術(shù). 2015(07)
[8]基于NS3的分布式消息系統(tǒng)Kafka的仿真實(shí)現(xiàn)[J]. 馬浩然.  軟件. 2015(01)
[9]分布式架構(gòu)和消息隊(duì)列技術(shù)在抄表系統(tǒng)的應(yīng)用[J]. 李朋.  電力與能源. 2014(01)
[10]異構(gòu)網(wǎng)絡(luò)視頻監(jiān)控系統(tǒng)中間件技術(shù)的應(yīng)用研究[J]. 胡忠毅.  計(jì)算機(jī)光盤(pán)軟件與應(yīng)用. 2012(01)

碩士論文
[1]基于Kafka的消息隊(duì)列在射天文數(shù)據(jù)處理中應(yīng)用的研究[D]. 王鄭合.昆明理工大學(xué) 2017
[2]基于Kafka的大規(guī)模流數(shù)據(jù)分布式緩存與分析平臺(tái)[D]. 牛牧.吉林大學(xué) 2016
[3]基于ZigBee和GPRS的智能抄表系統(tǒng)的設(shè)計(jì)[D]. 張潔.湖南大學(xué) 2016
[4]基于ZooKeeper的分布式處理框架的研究與實(shí)現(xiàn)[D]. 譚玉靖.北京郵電大學(xué) 2014
[5]自來(lái)水企業(yè)IC卡水表業(yè)務(wù)運(yùn)營(yíng)管理的設(shè)計(jì)與實(shí)現(xiàn)[D]. 張鳳濤.山東大學(xué) 2012
[6]居民電表自動(dòng)抄表系統(tǒng)的開(kāi)發(fā)[D]. 賀鋒.中南大學(xué) 2006
[7]一種基于GSM的小區(qū)水、電、氣遠(yuǎn)程抄表及其管理信息系統(tǒng)的設(shè)計(jì)[D]. 張棟.山東大學(xué) 2005
[8]智能抄表系統(tǒng)的研發(fā)[D]. 李立新.浙江大學(xué) 2003
[9]基于消息的中間件設(shè)計(jì)模式和系統(tǒng)結(jié)構(gòu)[D]. 何華海.中國(guó)科學(xué)院研究生院（軟件研究所） 2002



本文編號(hào)：3577708