分布式消息處理方法及系統(tǒng)
基本信息
| 申請?zhí)?/td> | CN202010401681.8 | 申請日 | - |
| 公開（公告）號 | CN111611090A | 公開（公告）日 | 2020-09-01 |
| 申請公布號 | CN111611090A | 申請公布日 | 2020-09-01 |
| 分類號 | G06F9/54(2006.01)I | 分類 | 計算；推算；計數(shù); |
| 發(fā)明人 | 張晨 | 申請（專利權(quán)）人 | 浙江創(chuàng)鄰科技有限公司 |
| 代理機構(gòu) | 杭州裕陽聯(lián)合專利代理有限公司 | 代理人 | 浙江創(chuàng)鄰科技有限公司 |
| 地址 | 310012浙江省杭州市西湖區(qū)三墩鎮(zhèn)紫萱路158號1幢801室 | ||
| 法律狀態(tài) | - | ||
摘要
| 摘要 | 本發(fā)明公開一種分布式消息處理方法及系統(tǒng)，其中方法包括以下步驟：接收客戶端發(fā)送的消息發(fā)送請求，根據(jù)所述消息發(fā)送請求生成包含發(fā)送時間戳的消息，將所述消息加入相應的消息隊列，所述發(fā)送時間戳在所述消息隊列中具有唯一性，基于所述發(fā)送時間戳對消息隊列中的消息進行排列；判斷消息是否超時，根據(jù)判斷結(jié)果標記超時消息并將所述超時消息備份至分布式文件系統(tǒng)；按照預設(shè)的清除時間，周期性的刪除消息隊列中的超時消息。本發(fā)明通過對發(fā)送時間戳的設(shè)計保證消息傳遞的順序；通過對超時消息進行判斷和清除步驟的設(shè)計，能夠令分布式文件系統(tǒng)和消息隊列相互配合，便于客戶端查詢消息的同時減輕消息隊列帶來的數(shù)據(jù)存儲壓力。?? |
