[發(fā)明專利]分布式話單查詢管理系統(tǒng)及方法

有效

• 申請(qǐng)?zhí)枺?/td>: 201110093934.0
• 申請(qǐng)日: 2011-04-14
• 公開（公告）號(hào): CN102737061A
• 公開（公告）日: 2012-10-17
• 發(fā)明（設(shè)計(jì)）人: 張紀(jì)偉
• 申請(qǐng)（專利權(quán)）人: 中興通訊股份有限公司
• 主分類號(hào): G06F17/30
• 分類號(hào): G06F17/30;H04W4/24
• 代理公司: 北京康信知識(shí)產(chǎn)權(quán)代理有限責(zé)任公司 11240
• 代理人: 余剛;梁麗超

技術(shù)領(lǐng)域

本發(fā)明涉及通訊行業(yè)的業(yè)務(wù)產(chǎn)品領(lǐng)域，尤其涉及一種分布式話單查詢管理系統(tǒng)及方法。

背景技術(shù)

通訊行業(yè)的業(yè)務(wù)產(chǎn)品中，特別是WAP(Wireless?Application?Protocol，無線應(yīng)用協(xié)議)業(yè)務(wù)，產(chǎn)生的用戶計(jì)費(fèi)話單數(shù)據(jù)量很大，拿一個(gè)普通省份來說，每天產(chǎn)生的話單文件約幾十G，通話記錄約幾億條，當(dāng)話單量隨著業(yè)務(wù)增長(zhǎng)持續(xù)增加時(shí)，對(duì)數(shù)據(jù)查詢管理系統(tǒng)的性能考驗(yàn)越來越高，目前的話單查詢管理系統(tǒng)以傳統(tǒng)的關(guān)系數(shù)據(jù)庫為基礎(chǔ)，對(duì)話單數(shù)據(jù)進(jìn)行管理和查詢等，其性能會(huì)隨著數(shù)據(jù)量的增加而逐漸降低，且系統(tǒng)擴(kuò)充涉及到的修改量和擴(kuò)容費(fèi)用龐大。

發(fā)明內(nèi)容

本發(fā)明的目的是提供一種分布式話單查詢管理系統(tǒng)及方法，以解決現(xiàn)有技術(shù)數(shù)據(jù)量增長(zhǎng)與查詢效率之間的瓶頸問題。

本發(fā)明提供了一種分布式話單查詢管理系統(tǒng)，包括內(nèi)存文件數(shù)據(jù)庫單元，網(wǎng)絡(luò)文件管理單元以及2個(gè)或2個(gè)以上彼此相連的數(shù)據(jù)獲取單元，

上述內(nèi)存文件數(shù)據(jù)庫單元，用于存儲(chǔ)話單文件中的通話記錄的索引，以及在收到查詢請(qǐng)求時(shí)，查找符合查詢條件的索引記錄，并將查詢結(jié)果返回給發(fā)送上述查詢請(qǐng)求的數(shù)據(jù)獲取單元；

上述網(wǎng)絡(luò)文件管理單元，用于存儲(chǔ)話單文件，以及為各數(shù)據(jù)獲取單元分配目錄文件；

上述數(shù)據(jù)獲取單元，用于將收到的用戶查詢請(qǐng)求轉(zhuǎn)發(fā)給上述內(nèi)存文件數(shù)據(jù)庫單元，并將上述內(nèi)存文件數(shù)據(jù)庫單元返回的查詢結(jié)果作為一批次任務(wù)，分配給自身和上述系統(tǒng)中其他正常工作的數(shù)據(jù)獲取單元，以及執(zhí)行分配給自身的任務(wù)，收集自身及上述其他正常工作的數(shù)據(jù)獲取單元的執(zhí)行結(jié)果，并對(duì)上述執(zhí)行結(jié)果進(jìn)行匯總處理后返回給用戶。

優(yōu)選地，上述內(nèi)存文件數(shù)據(jù)庫單元，用于逐條讀取查找到的符合查詢條件的索引記錄中的偏移量字段和文件名字段，生成查詢結(jié)果。

優(yōu)選地，上述數(shù)據(jù)獲取單元包括查詢模塊，任務(wù)分配模塊、任務(wù)執(zhí)行模塊以及匯總模塊，

上述查詢模塊，用于接收用戶查詢請(qǐng)求，并將接收到的用戶查詢請(qǐng)求轉(zhuǎn)發(fā)給上述內(nèi)存文件數(shù)據(jù)庫單元，以及將上述內(nèi)存數(shù)據(jù)庫模塊返回的查詢結(jié)果作為一批次任務(wù)發(fā)送給本地任務(wù)分配模塊，或者將上述匯總模塊發(fā)送來的匯總結(jié)果返回給用戶；

上述任務(wù)分配模塊，用于按照預(yù)設(shè)的分配規(guī)則，分配收到的任務(wù)并分發(fā)給本地任務(wù)執(zhí)行模塊和上述系統(tǒng)中其他正常工作的數(shù)據(jù)獲取單元的任務(wù)執(zhí)行模塊；以及將收到的位置信息發(fā)送給本地匯總模塊；

上述任務(wù)執(zhí)行模塊，用于執(zhí)行收到的任務(wù)，并將執(zhí)行結(jié)果所在的文件的位置信息返回給發(fā)送上述任務(wù)的任務(wù)分配模塊；

上述匯總模塊，用于根據(jù)收到的位置信息，讀取其中的內(nèi)容并進(jìn)行匯總處理，以及將匯總結(jié)果發(fā)送給本地查詢模塊。

優(yōu)選地，上述任務(wù)執(zhí)行模塊，用于根據(jù)收到的任務(wù)，在上述網(wǎng)絡(luò)文件管理單元中查找相應(yīng)的話單文件，以及在找到的話單文件中查找對(duì)應(yīng)的通話記錄，并讀取找到的通話記錄，將其存儲(chǔ)到上述網(wǎng)絡(luò)文件管理單元分配給本裝置的目錄文件中。

上述匯總模塊，用于根據(jù)收到的位置信息，在上述網(wǎng)絡(luò)文件管理單元查找對(duì)應(yīng)的目錄文件，讀取上述目錄文件中的通話記錄，對(duì)上述通話記錄進(jìn)行排序處理。

優(yōu)選地，上述任務(wù)分配模塊，用于暫存收到的任務(wù)；

上述任務(wù)執(zhí)行模塊，用于判斷本次收到的任務(wù)是否執(zhí)行完畢。

本發(fā)明還提供了一種話單管理查詢方法，預(yù)先將話單文件中的通話記錄的索引存儲(chǔ)到內(nèi)存文件數(shù)據(jù)庫單元中，并將上述話單文件存儲(chǔ)到網(wǎng)絡(luò)文件管理單元中，當(dāng)收到用戶查詢請(qǐng)求后，分布式查詢管理系統(tǒng)執(zhí)行如下操作：

收到用戶查詢請(qǐng)求的當(dāng)前數(shù)據(jù)獲取單元將查詢請(qǐng)求轉(zhuǎn)發(fā)給上述內(nèi)存文件數(shù)據(jù)庫單元；

上述內(nèi)存文件數(shù)據(jù)庫單元在本地索引記錄中查找符合查詢條件的索引記錄，并將查詢結(jié)果返回給上述當(dāng)前數(shù)據(jù)獲取單元；

上述當(dāng)前數(shù)據(jù)獲取單元將查詢結(jié)果作為一批次任務(wù)，分配給自身及分布上述系統(tǒng)中其他正常工作的數(shù)據(jù)獲取單元；

各數(shù)據(jù)獲取單元執(zhí)行收到的任務(wù)，并將執(zhí)行結(jié)果所在文件的位置信息返回給上述當(dāng)前數(shù)據(jù)獲取單元；

上述當(dāng)前數(shù)據(jù)獲取單元根據(jù)收到的位置信息，讀取其中的內(nèi)容并匯總，將匯總結(jié)果返回給用戶。

優(yōu)選地，上述通話記錄的索引包括主被叫號(hào)碼、通話起止時(shí)間、通話記錄在話單文件中的偏移量以及上述話單文件在上述網(wǎng)絡(luò)文件管理單元中的文件名。

優(yōu)選地，上述內(nèi)存文件數(shù)據(jù)庫單元在本地索引記錄中查找符合查詢條件的索引記錄，并將查詢結(jié)果返回給上述當(dāng)前數(shù)據(jù)獲取單元步驟具體包括以下步驟：

在本地索引記錄中查找符合查詢條件的索引記錄；