[發明專利]一種消息傳遞方法和系統及消息處理設備

有效

• 申請號: 201410128537.6
• 申請日: 2014-04-01
• 公開（公告）號: CN104980450B
• 公開（公告）日: 2018-08-24
• 發明（設計）人: 謝中富
• 申請（專利權）人: 阿里巴巴集團控股有限公司
• 主分類號: H04L29/08
• 分類號: H04L29/08
• 代理公司: 北京三友知識產權代理有限公司 11127
• 代理人: 黨曉林

1.一種消息傳遞方法，其特征在于，包括以下處理步驟：

消息中間件接收消息發送者發布的消息，并提取該消息在指定屬性上的屬性信息，所述屬性信息包括消息對應的主體信息；

消息中間件比較所述提取的屬性信息與錯誤信息表中保存的預置屬性信息是否相同，所述預置屬性信息包括預先確定的主體信息，所述錯誤信息表通過消息消費者反饋的接收不成功消息增加該消息相應的主體信息至錯誤信息表；如果不相同，則將所述的接收的消息傳遞至消息消費者；如果相同，則持久化該接收的消息；

消息中間件將所述持久化的消息按照預定順序發送。

2.如權利要求1所述的方法，其特征在于，所述預定順序采用消息產生時間的先后順序、消息在持久化前由消息發送者發布的時間的先后順序中的任意一種。

3.如權利要求2所述的方法，其特征在于，所述主體信息包括消息的生產者信息.消息的消費者信息和消息的生產者信息與消息的消費者信息的結合中的至少一種。

4.如權利要求1所述的方法，其特征在于，所述屬性信息位于消息的屬性字段中。

5.如權利要求1所述的方法，其特征在于，所述錯誤信息表中保存的預置屬性信息包括：

消息中間件存儲消息消費者反饋的接收不成功的消息對應的主體信息。

6.如權利要求5所述的方法，其特征在于，所述消息中間件將所述持久化的消息按照預定順序發送之前，還包括：

消息中間件提取緩存中存有的所述消息消費者接收不成功的消息，并持久化該消息；

或，

消息中間件請求消息發送者再次發送所述消息消費者接收不成功的消息，并在接收消息發送者再次發送的消息之后持久化該消息。

7.如權利要求1所述的方法，其特征在于，所述消息中間件將所述持久化的消息按照預定的順序發送，包括：

在首次接收到消息消費者反饋的錯誤信息后達到預定時長時按照預定順序發送，

或，

在首次接收到消息消費者反饋的錯誤信息后，持久化處理的消息數量達到預定數目時，按照預定的順序發送。

8.如權利要求1所述的方法，其特征在于，所述方法之后還包括：

在所述持久化的消息發送成功后刪除所述錯誤信息表中的所述屬性信息。

9.一種消息傳遞系統，其特征在于，包括：

消息發送者，包括至少一個消息生產者，所述消息生產者用于發布不同屬性的消息；

消息中間件，用于接收所述發布的消息，并提取該消息在指定屬性上的屬性信息，所述屬性信息包括消息對應的主體信息；還用于比較所述提取的屬性信息與錯誤信息表中保存的預置屬性信息是否相同，所述預置屬性信息包括預先確定的主體信息，所述錯誤信息表通過消息消費者反饋的接收不成功消息增加該消息相應的主體信息至錯誤信息表；當比較結果為不相同時，將所述的接收的消息傳遞至消息消費者；當比較結果為相同時，持久化該接收的消息；還用于將所述持久化的消息按照預定的順序發送；

消息消費者，用于接收消息中間件發來的消息。

10.一種消息處理設備，其特征在于，包括：

消息接收單元，用于接收消息發送者發布的消息；

屬性提取單元，用于從消息接收單元接收的消息中提取該消息在指定屬性上的屬性信息，所述屬性信息包括消息對應的主體信息；

錯誤信息表，用于保存預置的屬性信息，所述預置屬性信息包括預先確定的主體信息，所述錯誤信息表通過消息消費者反饋的接收不成功消息增加該消息相應的主體信息至錯誤信息表；

比較單元，用于比較所述提取的屬性信息與錯誤信息表中保存的預置屬性信息是否相同；

第一發送單元，用于當比較單元比較結果為不相同時，將所述的接收的消息傳遞至消息消費者；

持久化單元，用于當比較單元比較結果為相同時，持久化所述屬性信息相同的消息；

第二發送單元，用于將所述持久化的消息按照預定的順序發送所述持久化單元中的消息。