一種分布式消息系統(tǒng)

基本信息

申請(qǐng)?zhí)?/td> CN201810010651.7 申請(qǐng)日 -
公開(kāi)(公告)號(hào) CN108306941A 公開(kāi)(公告)日 2018-07-20
申請(qǐng)公布號(hào) CN108306941A 申請(qǐng)公布日 2018-07-20
分類(lèi)號(hào) H04L29/08;H04L29/06 分類(lèi) 電通信技術(shù);
發(fā)明人 周凌;李金東 申請(qǐng)(專(zhuān)利權(quán))人 上海五行嘉信息技術(shù)有限公司
代理機(jī)構(gòu) 北京德恒律治知識(shí)產(chǎn)權(quán)代理有限公司 代理人 章社杲;盧軍峰
地址 200941 上海市寶山區(qū)德都路月浦六村88號(hào)B380室
法律狀態(tài) -

摘要

摘要 本發(fā)明公開(kāi)了一種分布式消息系統(tǒng),該分布式系統(tǒng)包括:消息生產(chǎn)者,消息生產(chǎn)者用于發(fā)出事務(wù)消息;注冊(cè)服務(wù)器,注冊(cè)服務(wù)器分別與消息生產(chǎn)者和消息代理端通信連接,注冊(cè)服務(wù)器用于根據(jù)事務(wù)消息,查找消息消費(fèi)者,并通知消息消費(fèi)者從消息代理端拉取事務(wù)消息;消息消費(fèi)者,消息消費(fèi)者和消息代理端通信連接,消息消費(fèi)者根據(jù)接收到的通知,從消息代理端拉取事務(wù)消息;消息代理端還將自己的信息注冊(cè)到注冊(cè)服務(wù)器以供消息生產(chǎn)者和消息消費(fèi)者查詢,以及消息代理端還用于接收消息生產(chǎn)者的消息和提供消息消費(fèi)者訂閱的消息。本發(fā)明通過(guò)該分布式消息系統(tǒng),從而在出現(xiàn)高并發(fā)時(shí)能保證不會(huì)出現(xiàn)性能瓶頸。