[發明專利]一種加速消息隊列寫消息的方法、設備及介質在審
| 申請號： | 201911090596.8 | 申請日： | 2019-11-09 |
| 公開（公告）號： | CN111104232A | 公開（公告）日： | 2020-05-05 |
| 發明（設計）人： | 胡德鵬;文瑞超 | 申請（專利權）人： | 蘇州浪潮智能科技有限公司 |
| 主分類號： | G06F9/54 | 分類號： | G06F9/54 |
| 代理公司： | 北京連和連知識產權代理有限公司 11278 | 代理人： | 楊帆 |
| 地址： | 215100 江蘇省蘇州市吳*** | 國省代碼： | 江蘇;32 |
| 權利要求書： | 查看更多 | 說明書： | 查看更多 |
| 摘要： | |||
| 搜索關鍵詞： | 一種 加速 消息 隊列 方法 設備 介質 | ||
1.一種加速消息隊列寫消息的方法，其特征在于，包括以下步驟：
設置遠程直接非易失性內存訪問協議；
消息隊列生產者產生數據并將所述數據轉換成消息寫入到生產者非易性內存；
基于所述遠程直接非易失性內存訪問協議將所述消息從所述生產者非易性內存直接傳輸到生產者網絡設備；
消息隊列節點通過遠程直接訪問接口從所述生產者網絡設備接收所述消息；以及
所述消息隊列節點將所述消息直接持久化到節點非易失性內存。
2.根據權利要求1所述的方法，其特征在于，所述設置遠程直接非易失性內存訪問協議包括：
建立所述生產者非易失性內存與所述生產者網絡設備的映射；以及
建立所述遠程直接訪問接口與所述節點非易失性內存的映射。
3.根據權利要求2所述的方法，其特征在于，所述設置遠程直接非易失性內存訪問協議還包括：
建立消息隊列生產者傳輸到消息隊列節點的數據一致性的判斷。
4.根據權利要求3所述的方法，其特征在于，所述建立消息隊列生產者傳輸到消息隊列的數據一致性的判斷包括：
設立消息傳輸中間節點，每隔第一預定時間判斷所述消息傳輸中間節點是否接收到所述消息隊列節點的心跳數據。
5.根據權利要求4所述的方法，其特征在于，所述建立消息隊列生產者傳輸到消息隊列的數據一致性的判斷還包括：
響應于所述消息傳輸中間節點沒有接收到所述消息隊列節點的心跳數據，消息隊列生產者記錄當前消息隊列發送位置并停止消息發送。
6.一種計算機設備，其特征在于，包括：
至少一個處理器；以及
存儲器，所述存儲器存儲有可在所述處理器上運行的計算機指令，所述指令由所述處理器執行時實現以下步驟：
設置遠程直接非易失性內存訪問協議；
消息隊列生產者產生數據并將所述數據轉換成消息寫入到生產者非易性內存；
基于所述遠程直接非易失性內存訪問協議將所述消息從所述生產者非易性內存直接傳輸到生產者網絡設備；
消息隊列節點通過遠程直接訪問接口從所述生產者網絡設備接收所述消息；以及
所述消息隊列節點將所述消息直接持久化到節點非易失性內存。
7.根據權利要求6所示的計算機設備，其特征在于，所述設置遠程直接非易失性內存訪問協議包括：
建立所述生產者非易失性內存與所述生產者網絡設備的映射；以及
建立所述遠程直接訪問接口與所述節點非易失性內存的映射。
8.根據權利要求7所示的計算機設備，其特征在于，所述設置遠程直接非易失性內存訪問協議還包括：
建立消息隊列生產者傳輸到消息隊列節點的數據一致性的判斷。
9.根據權利要求8所示的計算機設備，其特征在于，所述建立消息隊列生產者傳輸到消息隊列的數據一致性的判斷包括：
設立消息傳輸中間節點，每隔第一預定時間判斷所述消息傳輸中間節點是否接收到所述消息隊列節點的心跳數據。
10.一種計算機可讀存儲介質，所述計算機可讀存儲介質存儲有計算機程序，其特征在于，所述計算機程序被處理器執行時實現權利要求1-5任意一項所述方法的步驟。
該專利技術資料僅供研究查看技術是否侵權等信息，商用須獲得專利權人授權。該專利全部權利屬于蘇州浪潮智能科技有限公司，未經蘇州浪潮智能科技有限公司許可，擅自商用是侵權行為。如果您想購買此專利、獲得商業授權和技術合作，請聯系【客服】
本文鏈接：http://www.szxzyx.cn/pat/books/201911090596.8/1.html，轉載請聲明來源鉆瓜專利網。
