一種基于RocketMq的VPC配置下發(fā)方法

基本信息

申請?zhí)?/td> CN202111175221.9 申請日 -
公開(公告)號 CN113923115A 公開(公告)日 2022-01-11
申請公布號 CN113923115A 申請公布日 2022-01-11
分類號 H04L41/0803(2022.01)I;H04L41/08(2022.01)I;H04L41/0893(2022.01)I;H04L41/0246(2022.01)I;H04L12/46(2006.01)I 分類 電通信技術(shù);
發(fā)明人 楊志鵬 申請(專利權(quán))人 紫光云技術(shù)有限公司
代理機(jī)構(gòu) 天津?yàn)I??凭曋R產(chǎn)權(quán)代理有限公司 代理人 李彥彥
地址 300459天津市濱海新區(qū)高新區(qū)塘沽海洋科技園匯祥道399號6號樓
法律狀態(tài) -

摘要

摘要 本發(fā)明提供了一種基于RocketMq的VPC配置下發(fā)方法,具體步驟如下:獲取虛機(jī)上線信息,分配設(shè)備配置參數(shù);將分配的設(shè)備配置參數(shù)根據(jù)網(wǎng)絡(luò)協(xié)議,寫為JSON報(bào)文格式;連接消息中間件RocketMq,獲取指定主題下面的配置信息,所述配置信息包括邏輯隊(duì)列數(shù)量、分區(qū)數(shù);根據(jù)虛機(jī)所屬VPC_ID和設(shè)備ID獲取HashCode;利用邏輯隊(duì)列數(shù)量和HashCode進(jìn)行取模,取模的值為JSON報(bào)文要發(fā)送到Rocketmq邏輯隊(duì)列的位置;異步發(fā)送JSON報(bào)文到Rocketmq的服務(wù)端中指定邏輯隊(duì)列位置,并做異步監(jiān)聽;收到消息發(fā)送成功回調(diào),記錄配置下發(fā)操作日志。本發(fā)明所述的邏輯隊(duì)列數(shù)和HashCode進(jìn)行取模,保證消息可以有序下發(fā)到指定設(shè)備;通過日志,可以回溯下發(fā)失敗的配置,進(jìn)行配置重新下發(fā)。