本申請公開了一種消息隊列的消息傳遞方法，包括：當?shù)谝幌㈥犃械姆掌飨虻诙㈥犃械姆掌靼l(fā)送跨隊列消息時，代理服務器根據(jù)第一預設協(xié)議對第一消息隊列進行消息獲取處理，得到所述跨隊列消息；根據(jù)第二預設協(xié)議將所述跨隊列消息向第二消息隊列進行消息投遞處理，以便所述第二消息隊列的服務器從所述第二消息隊列獲取所述跨隊列消息。通過每個消息隊列對應的預設協(xié)議，在第一消息隊列與第二消息隊列之間進行跨隊列消息的搬運，避免服務器直接與其它消息隊列連接，實現(xiàn)了不同數(shù)據(jù)中心之間的消息傳遞。本申請還公開了一種消息隊列的消息傳遞裝置、服務器以及計算機可讀存儲介質，具有以上有益效果。

技術領域

本申請涉及計算機技術領域，特別涉及一種消息隊列的消息傳遞方法、消息傳遞裝置、服務器以及計算機可讀存儲介質。

背景技術

隨著計算機技術的不斷發(fā)展，在集群系統(tǒng)中的計算機之間出現(xiàn)了大量不同層次、不同進程以及不同線程設備之間的消息通信，為了提高消息通信效率，現(xiàn)有技術提供了消息隊列的相關技術，以便在不同進程之間或同一進程的不同線程之間進行通信。通過消息隊列可以使消息的發(fā)送者和接收者不需要同時與消息隊列進行交互。發(fā)送者發(fā)送的消息會保存在消息隊列中，直到接收者從消息隊列中獲取該消息。

一般的，在一個數(shù)據(jù)中心中只使用一個消息隊列，由于信息技術不斷發(fā)展，在數(shù)據(jù)處理環(huán)境中會出現(xiàn)多個數(shù)據(jù)中心。當不同數(shù)據(jù)中心的服務器之間進行消息傳送時，現(xiàn)有技術通常是在多個數(shù)據(jù)中心之間建立一個或比數(shù)據(jù)中心數(shù)量少的消息隊列，那么就會出現(xiàn)某一個數(shù)據(jù)中心的服務器需要跨越數(shù)據(jù)中心之間的隔離到其他數(shù)據(jù)中心的消息隊列獲取消息。由于是跨越數(shù)據(jù)中心連接到對應的消息隊列，會嚴重降低數(shù)據(jù)中心發(fā)送和接收消息的效率，嚴重降低性能。同時，不同的數(shù)據(jù)中心之間進行數(shù)據(jù)傳輸需要跨越公網(wǎng)或長距離的專線網(wǎng)絡，當網(wǎng)絡抖動時，則需要數(shù)據(jù)中心的服務器面對和處理網(wǎng)絡抖動情況，會導致不同數(shù)據(jù)中心之間的消息阻塞，影響業(yè)務系統(tǒng)的正常工作。最后，跨越數(shù)據(jù)中心與消息隊列建立連接，由于是數(shù)據(jù)中心的服務器直接跨越數(shù)據(jù)中心之間的隔離進行連接，不利于數(shù)據(jù)中心之間網(wǎng)絡的隔離和管理。

因此，如何避免跨越數(shù)據(jù)中心，實現(xiàn)不同數(shù)據(jù)中心的消息隊列之間的消息傳輸是本領域技術人員關注的重點問題。

發(fā)明內容

本申請的目的是提供一種消息隊列的消息傳遞方法、消息傳遞裝置、服務器以及計算機可讀存儲介質，通過每個消息隊列對應的預設協(xié)議，在第一消息隊列與第二消息隊列之間進行跨隊列消息的搬運，避免服務器直接與其它消息隊列連接，實現(xiàn)了不同數(shù)據(jù)中心之間的消息傳遞。

為解決上述技術問題，本申請?zhí)峁┮环N消息隊列的消息傳遞方法，包括：

當?shù)谝幌㈥犃械姆掌飨虻诙㈥犃械姆掌靼l(fā)送跨隊列消息時，代理服務器根據(jù)第一預設協(xié)議對第一消息隊列進行消息獲取處理，得到所述跨隊列消息；

根據(jù)第二預設協(xié)議將所述跨隊列消息向第二消息隊列進行消息投遞處理，以便所述第二消息隊列的服務器從所述第二消息隊列獲取所述跨隊列消息。

可選的，還包括：

當所述消息投遞處理成功時，所述第二消息隊列向所述代理服務器發(fā)送確認消息；

當所述代理服務器接收到所述確認消息時，所述代理服務器向所述第一消息隊列發(fā)送確認消息。

可選的，當?shù)谝幌㈥犃械姆掌飨虻诙㈥犃械姆掌靼l(fā)送跨隊列消息時，代理服務器根據(jù)第一預設協(xié)議對第一消息隊列進行消息獲取處理，得到所述跨隊列消息，包括：

所述第一隊列的服務器根據(jù)所述第一預設協(xié)議將所述跨隊列消息向所述第一消息隊列進行消息投遞處理；

當所述消息投遞處理成功時，所述代理服務器根據(jù)第一預設協(xié)議對所述第一消息隊列進行消息獲取處理，得到所述跨隊列消息。

可選的，所述第二消息隊列的服務器從所述第二消息隊列獲取所述跨隊列消息，包括：