[發明專利]游戲數據處理方法、系統及存儲介質

在審

• 申請號: 202310395728.8
• 申請日: 2023-04-13
• 公開（公告）號: CN116492690A
• 公開（公告）日: 2023-07-28
• 發明（設計）人: 潘希健
• 申請（專利權）人: 廣州炫動信息科技有限公司
• 主分類號: A63F13/77
• 分類號: A63F13/77;G06F9/54;G06F16/27;H04L67/1004;H04L67/131
• 代理公司: 廣東穗科知識產權代理事務所(普通合伙) 44834
• 代理人: 黃啟文;李英杰

1.游戲數據處理方法，其特征在于：包括以下步驟：

S1.創建Mysql集群：通過分布式部署的方式在第一服務器集群上安裝Mysql；

S2.創建Kafka集群：在第一服務器集群上安裝Kafka，根據業務需求，在第一服務器集群上創建與Mysql表對應的分片；

S3.創建Elasticsearch集群：通過分布式部署方式在第二服務器集群上安裝Elasticsearch，根據業務需求，創建對應的索引；

S4.提供數據源腳本或者API接口，作為數據源的接入，寫入Mysql集群；

S5.使用Nginx作為負載均衡器，對數據源的請求通過負載均衡分發到Mysql集群上；

S6.通過腳本從對應的Mysql集群服務器上讀取Mysql數據源，將數據源進行封裝；

S7.將封裝好的數據源，通過Kafka的api發送至Kafka集群對應的topic中；

S8.Elasticsearch集群中的服務器，通過Kafka?Consumer?API消費Kafka消息隊列中的數據；對于每個消費的消息，使用Elasticsearch?Bulk?API將其寫入Elasticsearch索引中；

S9.使用Elasticsearch?Index?Templates定義Elasticsearch集群服務器的索引模板；使用自定義分詞器通過Elasticsearch?Search?API配置Elasticsearch集群服務器的搜索策略；

S10.根據業務需求，Elasticsearch集群服務器編寫對應的Elasticsearch腳本，對游戲數據進行分析和展示。

2.根據權利要求1所述的游戲數據處理方法，其特征在于：所述步驟S1中，通過分布式部署的方式在第一服務器集群上安裝Mysql后，配置Mysql按日期分表，定時清理舊數據表。

3.根據權利要求1所述的游戲數據處理方法，其特征在于：若步驟S6、S7出現數據讀取失敗、數據發送失敗的情況，則重新執行數據讀取操作、數據發送操作。

4.根據權利要求1所述的游戲數據處理方法，其特征在于：所述步驟S8中，使用Elasticsearch?Bulk?API將消費的消息寫入Elasticsearch索引后，在ElasticsearchBulk?API中配置寫入的索引名稱、數據映射和分片參數。

5.根據權利要求4所述的游戲數據處理方法，其特征在于：在Elasticsearch?Bulk?API中配置寫入的索引名稱、數據映射和分片參數后，將游戲數據按照時間分片的方式將Elasticsearch的策略定為時間分片索引，每個索引對應一個時間片，按時間先后順序將游戲數據分離，指定冷熱數據的分離時間。

6.根據權利要求5所述的游戲數據處理方法，其特征在于：使用Curator管理工具將Elasticsearch的策略定為時間分片索引。

7.根據權利要求6所述的游戲數據處理方法，其特征在于：所述步驟S10中，根據業務需求，Elasticsearch集群服務器編寫對應的Elasticsearch腳本，對游戲數據進行分析和展示，具體包括：

使用Elasticsearch的REST?API實現數據索引；

使用Elasticsearch提供的查詢語句搜索游戲數據；

將搜索的數據進行可視化展示。

8.根據權利要求7所述的游戲數據處理方法，其特征在于：利用Kibana工具將搜索數據進行可視化展示。

9.一種游戲數據處理系統，包括存儲器及處理器，所述存儲器內存儲有程序，其特征在于：所述程序被所述處理器執行時，執行權利要求1-8任一項所述方法的方法步驟。

10.一種計算機可讀存儲介質，包括存儲器，所述存儲器內存儲有程序，其特征在于：所述程序被處理器執行時，執行權利要求1-8任一項所述方法的方法步驟。