本發明實施例公開了一種消息消費、消息分發方法、裝置、服務器及存儲介質。該消息消費方法包括：確定分發服務器的各分區中與消費服務器一一對應的目標分區，并從目標分區中獲取待消費消息，確定待消費消息的消息標識，其中消息標識表示待消費消息所屬的消息消費任務，且分發服務器是根據消息標識將待消費消息分發到目標分區上的；根據消息標識從消費服務器的各內存隊列中確定出目標內存隊列，并將待消費消息發送給目標內存隊列；確定消費服務器的各線程中與目標內存隊列一一對應的目標線程，基于目標線程對目標內存隊列中的待消費消息進行消費。本發明實施例的技術方案，可以在保證各待消費消息的順序消費的前提下，達到了高吞吐的效果。

技術領域

本發明實施例涉及計算機應用技術領域，尤其涉及一種消息消費、消息分發方法、裝置、服務器及存儲介質。

背景技術

為了提高物品獲取量，越來越多的電子商務平臺間存在對接關系，即用戶可以從某個電子商務平臺上獲取到與其存在對接關系的另一電子商務平臺上的物品，此時，兩個電子商務平臺間針對一次物品獲取任務中的各物品獲取狀態會采用異步消息來同步。

由于一次物品獲取任務中的各種物品獲取狀態的生產過程是存在順序的，那么電子商務平臺需要按照物品獲取狀態的生產順序對其依次進行消費。目前主要是采用消息應答機制來達到順序消費的目的，即某個電子商務平臺在接收到另一電子商務平臺發送的已對前一消息處理完畢的反饋后，再向其發送下一消息，循環往復，直至本次的物品獲取任務中全部的消息處理完畢。

在實現本發明的過程中，發明人發現現有技術中存在以下技術問題：因為大部分的時間都在等待反饋、網絡波動和/或消息未處理成功導致無法收到反饋等等原因，現有技術的吞吐量較低。

發明內容

本發明實施例提供了一種消息消費、消息分發方法、裝置、服務器及存儲介質，以實現待消費消息的高吞吐的順序消費的效果。

第一方面，本發明實施例提供了一種消息消費方法，應用于消費服務器，該方法可以包括：

確定分發服務器的各分區中與消費服務器一一對應的目標分區，并從目標分區中獲取待消費消息，確定待消費消息的消息標識，其中消息標識表示待消費消息所屬的消息消費任務，且分發服務器是根據消息標識將待消費消息分發到目標分區上的；

根據消息標識從消費服務器的各內存隊列中確定出目標內存隊列，并將待消費消息發送給目標內存隊列；

確定消費服務器的各線程中與目標內存隊列一一對應的目標線程，基于目標線程對目標內存隊列中的待消費消息進行消費。

第二方面，本發明實施例還提供了一種消息分發方法，應用于分發服務器，該方法可以包括：

接收生產服務器生產后推送的待消費消息，并確定待消費消息的消息標識，其中消息標識表示待消費消息所屬的消息消費任務；

根據消息標識從分發服務器的各分區中確定出目標分區，將待消費消息分發到目標分區上，以使與目標分區一一對應的消費服務器將從目標分區中獲取到的待消費消息發送給根據消息標識從各內存隊列中確定出的目標內存隊列，并基于各線程中與目標內存隊列一一對應的目標線程對待消費消息進行消費。

第三方面，本發明實施例還提供了一種消息消費裝置，配置于消費服務器，該裝置可以包括：

第一消息標識確定模塊，用于確定分發服務器的各分區中與消費服務器一一對應的目標分區，并從目標分區中獲取待消費消息，確定待消費消息的消息標識，其中消息標識表示待消費消息所屬的消息消費任務，且分發服務器是根據消息標識將待消費消息分發到目標分區上的；

待消費消息發送模塊，用于根據消息標識從消費服務器的各內存隊列中確定出目標內存隊列，并將待消費消息發送給目標內存隊列；