[發明專利]用于創建時間準確的事件流的系統和方法

在審

• 申請號: 201780053512.6
• 申請日: 2017-08-29
• 公開（公告）號: CN109716317A
• 公開（公告）日: 2019-05-03
• 發明（設計）人: 羅伯特·帕克;丹尼爾·查爾斯·愛森;阿莉森·布雷頓·畢少普;普雷拉克·P·桑維;博·謝伊奇·塔特雅瑪;詹姆斯·M·卡波;弗朗西斯·鐘;康士坦丁·索科洛夫
• 申請（專利權）人: 艾一克斯集團有限公司
• 主分類號: G06F15/173
• 分類號: G06F15/173;G06F15/16;H04L12/24;H04L12/26;H04L29/06;H04L29/08;H04M3/42
• 代理公司: 北京集佳知識產權代理有限公司 11227
• 代理人: 王萍;楊林森

1.一種分布式計算系統，包括：

多個寫入器，每個寫入器生成消息并且將時間戳附加至所述消息；以及

多個讀取器，其與所述多個寫入器分離，至少一個讀取器訂閱所述多個寫入器中的至少兩個寫入器，并且所述至少一個讀取器接收來自其所訂閱的至少兩個寫入器的消息并且通過基于附加至所述消息的時間戳按時間順序對來自所述至少兩個寫入器的消息進行排列來生成事件流。

2.根據權利要求1所述的系統，還包括網關，所述網關用于將終端用戶應用在通信上耦接至所述多個寫入器中的至少一個寫入器和所述多個讀取器中的至少一個讀取器。

3.根據權利要求2所述的系統，其中，所述終端用戶應用將消息發送至所述至少一個寫入器。

4.根據權利要求1所述的系統，其中，每個寫入器將唯一的數字簽名附加至所述消息。

5.根據權利要求4所述的系統，其中，所述數字簽名基于以下中的一個更多個：時間戳、消息內容、寫入器ID和序列號。

6.根據權利要求1所述的系統，還包括：用于對來自所述至少兩個寫入器的先前發送的消息進行存儲的一個或更多個中繼器。

7.根據權利要求6所述的系統，其中，響應于來自所述至少一個讀取器的重傳請求，所述中繼器檢索并發送存儲的消息。

8.根據權利要求1所述的系統，其中，所述多個寫入器中的一個寫入器具有將新寫入器添加至所述多個寫入器的能力。

9.根據權利要求1所述的系統，其中，所述多個寫入器中的一個寫入器具有刪除所述多個寫入器中的另一寫入器的能力。

10.根據權利要求1所述的系統，其中，所述多個寫入器周期性地發送心跳。

11.根據權利要求1所述的系統，其中，不同的寫入器的至少兩個消息通過主題進行組織。

12.一種寫入器設備，包括：

時鐘，其用于生成時鐘信號；

處理器，其基于來自網關的傳入消息生成傳出消息，基于所述時鐘信號將時間戳附加至所述傳出消息，以及將所述傳出消息發送至一個或更多個讀取器設備。

13.根據權利要求12所述的寫入器設備，還包括：

高速緩存，其存儲先前發送的消息。

14.根據權利要求13所述的寫入器，其中，所述高速緩存用于在存在對存儲的消息的請求時檢索所述存儲的消息以進行重傳。

15.根據權利要求12所述的寫入器設備，其中，所述處理器用于將數字簽名附加至所述傳出消息。

16.根據權利要求15所述的寫入器設備，其中，所述數字簽名基于以下中的一個更多個：時間戳、消息內容、寫入器ID和序列號。

17.根據權利要求12所述的寫入器設備，其中，處理器周期性地發送心跳。

18.根據權利要求12所述的寫入器設備，其中，所述時鐘與分布式計算網絡中的其他寫入器的其他時鐘同步。

19.根據權利要求12所述的寫入器設備，其中，所述寫入器設備將所述傳出消息直接發送至所述一個或更多個讀取器設備。

20.根據權利要求12所述的寫入器設備，其中，所述寫入器設備在所述寫入器設備解除運作之前發送“序列結束”消息。