本公開提供了一種二級緩存的一致性處理方法，包括：當前服務節(jié)點基于數(shù)據(jù)更新請求對目標數(shù)據(jù)庫進行更新；當前服務節(jié)點由目標數(shù)據(jù)庫獲取更新數(shù)據(jù)以更新本地緩存及遠程緩存，并將包括更新緩存的消息寫入消息隊列；以及當前服務節(jié)點之外的至少一個其他服務節(jié)點基于消息隊列中的包括更新緩存的消息，對本地緩存進行更新，以使得本地緩存與遠程緩存保持一致性。本公開還提供了一種分布式服務系統(tǒng)。

技術領域

本公開涉及數(shù)據(jù)處理技術領域，本公開尤其涉及一種二級緩存的一致性處理方法及分布式服務系統(tǒng)。

背景技術

企業(yè)中，服務面臨高并發(fā)問題時，往往采用二級緩存設計，使用“遠程緩存+本地緩存”的方式來提高并發(fā)能力，但數(shù)據(jù)的多處存儲會帶來數(shù)據(jù)一致性問題。

相關技術中，當一個服務節(jié)點更新遠程緩存及該節(jié)點的本地緩存后，其余服務節(jié)點對遠程緩存變更無感知，依舊讀取未更改的本地緩存，導致了數(shù)據(jù)的一致性問題。當遠程緩存更新，本地緩存沒有更新時，本地緩存的數(shù)據(jù)滯后更新也導致了數(shù)據(jù)的一致性問題。

發(fā)明內(nèi)容

本公開提供了一種二級緩存的一致性處理方法及分布式服務系統(tǒng)。

根據(jù)本公開的一個方面，提供一種二級緩存的一致性處理方法，包括：

當前服務節(jié)點基于數(shù)據(jù)更新請求對目標數(shù)據(jù)庫進行更新；

當前服務節(jié)點由所述目標數(shù)據(jù)庫獲取更新數(shù)據(jù)以更新本地緩存及遠程緩存，并將包括更新緩存的消息寫入消息隊列；

當前服務節(jié)點之外的至少一個其他服務節(jié)點基于所述消息隊列中的包括更新緩存的消息(Message)，對本地緩存進行更新，以使得本地緩存與遠程緩存保持一致性。

根據(jù)本公開的至少一個實施方式的二級緩存的一致性處理方法，當前服務節(jié)點基于數(shù)據(jù)更新請求對目標數(shù)據(jù)庫進行更新，包括：

當前服務節(jié)點接收數(shù)據(jù)更新請求；

當前服務節(jié)點獲取分布式鎖；

當前服務節(jié)點基于所述分布式鎖及所述數(shù)據(jù)更新請求對目標數(shù)據(jù)庫執(zhí)行數(shù)據(jù)更新操作。

根據(jù)本公開的至少一個實施方式的二級緩存的一致性處理方法，當前服務節(jié)點由所述目標數(shù)據(jù)庫獲取更新數(shù)據(jù)以更新遠程緩存，包括：

當前服務節(jié)點基于所述分布式鎖及所述更新數(shù)據(jù)對所述遠程緩存進行更新。

根據(jù)本公開的至少一個實施方式的二級緩存的一致性處理方法，所述當前服務節(jié)點基于獲取的所述更新數(shù)據(jù)同步地對當前服務節(jié)點的本地緩存及遠程緩存進行更新。

根據(jù)本公開的至少一個實施方式的二級緩存的一致性處理方法，所述當前服務節(jié)點將包括更新緩存的消息即時地寫入所述消息隊列。

根據(jù)本公開的至少一個實施方式的二級緩存的一致性處理方法，包括更新緩存的所述消息還包括所述當前服務節(jié)點的特征標識，以使得當前服務節(jié)點在讀取所述消息隊列中的數(shù)據(jù)時，不讀取當前服務節(jié)點已寫入的消息。

根據(jù)本公開的至少一個實施方式的二級緩存的一致性處理方法，所述特征標識為當前服務節(jié)點的IP。

根據(jù)本公開的至少一個實施方式的二級緩存的一致性處理方法，當前服務節(jié)點及當前服務節(jié)點之外的各個其他服務節(jié)點在讀取消息隊列中的數(shù)據(jù)時，串行地進行讀取。

根據(jù)本公開的至少一個實施方式的二級緩存的一致性處理方法，所述當前服務節(jié)點持獲取的所述分布式鎖將包括更新緩存的消息寫入所述消息隊列。

根據(jù)本公開的另一個方面，提供一種二級緩存的一致性處理方法，包括：

分布式服務系統(tǒng)中的兩個以上的服務節(jié)點接收到數(shù)據(jù)更新請求以對目標數(shù)據(jù)庫進行更新；