本發明公開一種基于消息隊列的數據收發處理方法，涉及信息技術領域；消息生產者定義消息狀態，消息本身以及消息隊列與消息消費者之間的狀態，消息生產者接收消息隊列和消息消費者的ACK消息及上一次消息狀態時，更新數據，并判斷消息是否需要重發，消息隊列收到消息消費者的ACK消息及上一次消息狀態時，更新數據，并更改消息狀態，查看是否存在需要發送到消息消費者的消息，消息消費者收到消息，更改消息狀態，返回ACK消息及消息狀態，利用本發明方法達到消息發送的精確性，原子性，一致性，保證三者的消息同步一致，不會造成某一條消息的漏發或者重發。

技術領域

本發明公開一種數據收發處理方法，涉及信息技術領域，具體地說是一種基于消息隊列的數據收發處理方法。

背景技術

最初互聯網發展，消息都是同步發送的，發送方將消息發送到接口方，無需中間服務商，你來我往方便快捷。但是當網絡飛速發展，信息交互繁忙的時候，數以萬計的消息不再適合簡單同步直接發送。隨之，出現了RPC同步技術，雖然效率有所提升，但是依舊無法解決信息爆炸的現狀。于是出現了消息的異步處理機制，發送方將消息發送到消息服務器，消息服務器發送到接收方，消息可以正常的接收和發送，但是成百上千條數據信息同時涌入消息服務器，分發信息對應不同的消費者，勢必會出現發送的信息一致性問題，其次，發送消息失敗或是接收不到，重復的發送消息導致生成重復的訂單，容易在消息發送鏈路產生的巨大負載壓力。

發明內容

本發明針對現有技術的問題，提供一種基于消息隊列的數據收發處理方法，解決MQ異步處理機制產生的消息不一致的問題，保證了信息發送的穩定性和安全性以及產品的高可用。

本發明提出的具體方案是：

一種基于消息隊列的數據收發處理方法：消息生產者定義消息狀態，消息本身以及消息隊列與消息消費者之間的狀態，

消息發送過程中，消息生產者接收消息隊列和消息消費者的ACK消息及上一次消息狀態時，更新數據，并判斷消息是否需要重發，

消息隊列收到消息消費者的ACK消息及上一次消息狀態時，更新數據，并更改消息狀態，查看是否存在需要發送到消息消費者的消息，

消息消費者收到消息，更改消息狀態，返回ACK消息及消息狀態。

所述的一種基于消息隊列的數據收發處理方法中消息生產者定期查詢消息的消息狀態，根據消息預設的發送次數，判斷消息是否需要重發。

所述的一種基于消息隊列的數據收發處理方法中消息隊列定期查詢消息的消息狀態，根據消息狀態查看是否存在需要發送到消息消費者的消息或是否需要刪除消息。

所述的一種基于消息隊列的數據收發處理方法中消息狀態包括待發送、發送成功及發送失敗。

所述的一種基于消息隊列的數據收發處理方法中超過預設的發送次數，消息的消息狀態為發送失敗，并利用統一的標記進行設置。

所述的一種基于消息隊列的數據收發處理方法中針對消息狀態為發送失敗的消息，進行告警。

所述的一種基于消息隊列的數據收發處理方法中消息生產者利用數據庫表存儲消息狀態，消息本身以及消息隊列與消息消費者之間的狀態。

一種基于消息隊列的數據收發處理系統，包括消息生產者、消息隊列及消息消費者，

消息生成者定義消息狀態，消息本身以及消息隊列與消息消費者之間的狀態，

消息發送過程中，消息生產者接收消息隊列和消息消費者的ACK消息及上一次消息狀態時，更新數據，并判斷消息是否需要重發，

消息隊列收到消息消費者的ACK消息及上一次消息狀態時，更新數據，并更改消息狀態，查看是否存在需要發送到消息消費者的消息，