[發明專利]實時事務一致的變更通知

在審

• 申請號: 202210197345.5
• 申請日: 2017-04-27
• 公開（公告）號: CN114691306A
• 公開（公告）日: 2022-07-01
• 發明（設計）人: 阿爾弗雷德·富勒;維賈伊·庫馬爾;賴納·赫斯梅爾
• 申請（專利權）人: 谷歌有限責任公司
• 主分類號: G06F9/46
• 分類號: G06F9/46;G06F16/23;G06F16/27
• 代理公司: 中原信達知識產權代理有限責任公司 11219
• 代理人: 李寶泉;周亞榮

本發明涉及實時事務一致的變更通知。一種方法包括執行用于分布式系統(200)的變更日志進程(500)的初始實例(310)，所述變更日志進程的每個實例被配置成存儲在所述分布式系統上執行的事務(204、214)的事務歷史(132)。所述方法也包括接收用于執行對應事務的事務請求(138)并且基于所接收到的事務請求(322)確定變更日志負載。所述方法包括當所述變更日志負載滿足閾值負載時執行所述變更日志進程的至少一個后續實例。當所述變更日志進程的多個實例正在執行時，所述方法包括停止所述變更日志進程的至少一個后續實例的執行并且合并所述變更日志進程的初始實例的事務歷史和所述變更日志進程的至少一個后續實例的事務歷史。

分案說明

本申請屬于申請日為2017年4月27日的中國發明專利申請201780011478.6的分案申請。

技術領域

本公開涉及在分布式系統內向一個或多個監視器提供針對監視器訂閱的數據的一致變更通知。

背景技術

分布式存儲系統覆蓋一個或多個存儲器位置地將數據存儲在存儲器硬件上的數據存儲內。監視器可以發出常備查詢以訂閱存儲在分布式系統上的各條特定數據并且在訂閱數據經歷突變時的任何時候接收變更通知。例如，寫入器可以執行寫入事務以修改/突變存儲在分布式系統上的各條特定數據并且在數據被修改時訂閱數據的監視器得到通知。然而，當同時地發生多個變更/寫入時，對分布式系統的需求增加，導致分布式系統過度運行而無法實時地流式傳輸變更通知。已知在高需求的時段期間完全放棄訂閱以減輕分布式系統上的負載。由于這個原因，一些系統被設計得不保證按順序遞送并且通常排序被留給客戶端。然而，這導致訂閱監視器接收到分布式數據的不一致快照。此外，已知使用變更日志來將每個事務記錄到存儲在分布式系統上的數據。這些變更日志記錄對數據存儲做出的每一變更，并且當在數據存儲上發生讀取事務時，變更日志充當用于給定快照的所有數據的開/關檢查點。

發明內容

在分布式系統上采用持久變更日志一般地要求每隔一段時間將變更日志截斷到單個機器上，從而在事務等待執行時導致瓶頸效應。因此，持久變更日志由于其在對分布式系統的高需求的時段期間的固有可擴展性限制而否定由分布式系統提供的分布式功能性。本公開的一個方面提供用于創建事務一致的變更通知的方法。所述方法包括：由數據處理硬件執行用于分布式系統的變更日志進程的初始實例；在數據處理硬件處接收用于在分布式系統上執行對應事務的事務請求；以及由數據處理硬件基于所接收到的事務請求確定變更日志負載。變更日志進程的每個實例被配置成在與數據處理硬件通信的存儲器硬件上存儲在分布式系統上執行的事務的事務歷史。當變更日志負載滿足閾值負載時，所述方法包括由數據處理硬件執行變更日志進程的至少一個后續實例。所述方法還包括由數據處理硬件確定變更日志進程的多個實例是否正在執行。當變更日志進程的多個實例正在執行時，所述方法包括由數據處理硬件停止變更日志進程的至少一個后續實例的執行并且由數據處理硬件合并變更日志進程的初始實例的事務歷史和變更日志進程的至少一個后續實例的事務歷史。

本公開的實施方式可以包括以下可選特征中的一個或多個。在一些實施方式中，所述方法包括將每個事務歷史存儲在存儲器硬件的變更日志緩存中。存儲每個事務歷史可以包括：由數據處理硬件將事務歷史切分成數據條帶；復制每個數據條帶；將數據條帶和已復制的數據條帶存儲在存儲器硬件的多個存儲位置處。當在執行變更日志進程的至少一個后續實例之后變更日志負載不滿足閾值負載時，所述方法可以包括由數據處理硬件停止變更日志進程的至少一個后續實例的執行，以及由數據處理硬件合并變更日志進程的初始實例的事務歷史和變更日志進程的至少一個后續實例的事務歷史。

響應于接收到每個事務請求，所述方法可以包括：由數據處理硬件獲得真實時間；由數據處理硬件基于真實時間確定最大提交時間；以及將最大提交時間從數據處理硬件傳遞到存儲器硬件的至少一個變更日志緩存。最大提交時間可以指定用于完成對應事務在分布式系統上的執行的最大時間。