基于分布式消息隊(duì)列中間件的處理方法和處理系統(tǒng)
基本信息
申請(qǐng)?zhí)?/td> | CN201710533747.7 | 申請(qǐng)日 | - |
公開(公告)號(hào) | CN107194013B | 公開(公告)日 | 2019-10-29 |
申請(qǐng)公布號(hào) | CN107194013B | 申請(qǐng)公布日 | 2019-10-29 |
分類號(hào) | G06F16/2455;G06F9/54 | 分類 | 計(jì)算;推算;計(jì)數(shù); |
發(fā)明人 | 駱海燕 | 申請(qǐng)(專利權(quán))人 | 杭州排列科技有限公司 |
代理機(jī)構(gòu) | 杭州裕陽(yáng)聯(lián)合專利代理有限公司 | 代理人 | 杭州排列科技有限公司 |
地址 | 311121 浙江省杭州市文一西路998號(hào)海創(chuàng)園19號(hào)樓501室 | ||
法律狀態(tài) | - |
摘要
摘要 | 本發(fā)明公開了一種基于分布式消息隊(duì)列中間件的處理方法和處理系統(tǒng),其中,方法包括:獲取上傳消息根據(jù)上傳消息建立帶有消息模式的消息信息;對(duì)消息模式進(jìn)行處理得到查詢信息;根據(jù)查詢信息進(jìn)行查詢的結(jié)果提取第一高速緩存器中的消息模式,再根據(jù)消息模式對(duì)消息信息進(jìn)行編碼得到編碼信息,并將編碼信息發(fā)送至分布式消息隊(duì)列集群儲(chǔ)存;根據(jù)查詢信息進(jìn)行查詢的結(jié)果提取第二高速緩存器中的消息模式,再根據(jù)消息模式從分布式消息隊(duì)列集群中得到對(duì)應(yīng)的編碼信息進(jìn)行解碼,并根據(jù)解碼結(jié)果進(jìn)行消費(fèi)。本發(fā)明避免了線下“握手”過程,當(dāng)生產(chǎn)者信息模式需要變更時(shí),不需要線下通知消費(fèi)者,便可以自動(dòng)完成消息模式的升級(jí),減輕日常維護(hù)和運(yùn)營(yíng)成本。 |
