一種基于消息鏈的輕量級數(shù)據(jù)處理方法

基本信息

申請?zhí)?/td> CN201310714072.8 申請日 -
公開（公告）號 CN103677844B 公開（公告）日 2017-02-01
申請公布號 CN103677844B 申請公布日 2017-02-01
分類號 G06F9/44(2006.01)I 分類 計算；推算；計數(shù);
發(fā)明人 熊夢;楊松;莫展鵬;季統(tǒng)凱 申請（專利權(quán)）人 湖南中科國云大數(shù)據(jù)產(chǎn)業(yè)發(fā)展有限公司
代理機(jī)構(gòu) 北京科億知識產(chǎn)權(quán)代理事務(wù)所（普通合伙） 代理人 國云科技股份有限公司;湖南中科國云大數(shù)據(jù)產(chǎn)業(yè)發(fā)展有限公司
地址 523808 廣東省東莞市松山湖科技產(chǎn)業(yè)園區(qū)松科苑14號樓
法律狀態(tài) -

摘要

摘要 本發(fā)明涉及分布式計算技術(shù)領(lǐng)域，特別是指一種基于消息鏈的輕量級數(shù)據(jù)處理框架。當(dāng)消息被接收后進(jìn)入消息處理鏈模塊；經(jīng)過鏈上每個處理器上行處理邏輯的處理后，緩存到上行消息隊列中；上行消息隊列管理線程取出消息放入消息線程池；消息線程池將消息解析成對象或者結(jié)構(gòu)體；消息觀察者根據(jù)類型決定是否接受消息，并對其進(jìn)行特殊業(yè)務(wù)邏輯處理；另外，用戶請求或響應(yīng)經(jīng)過消息解析模塊轉(zhuǎn)化成消息緩存到下行消息隊列中；消息隊列把下行消息保存在待發(fā)送隊列中；按順序出列進(jìn)入消息處理鏈，經(jīng)過鏈上每個處理器下行處理邏輯處理后發(fā)送至消息通道。本發(fā)明解決了采用消息中間件所存在的問題，可用于實現(xiàn)基于本數(shù)據(jù)處理框架的第三方軟硬件的快速集成開發(fā)。