[發明專利]基于webflux框架的數據處理方法、系統及介質

在審

• 申請號: 202211542248.1
• 申請日: 2022-12-02
• 公開（公告）號: CN115858586A
• 公開（公告）日: 2023-03-28
• 發明（設計）人: 鐘惠壕;唐鈴淞
• 申請（專利權）人: 深圳匠人網絡科技有限公司
• 主分類號: G06F16/2455
• 分類號: G06F16/2455;G06F16/2453;G06F16/2457;G06F16/2458;G06F16/953
• 代理公司: 深圳茂達智聯知識產權代理事務所(普通合伙) 44394
• 代理人: 夏龍

本發明公開了一種基于webflux框架的數據處理方法、系統及介質，方法包括：服務器集群在接收到用戶的數據查詢指令時，判斷本地緩存中是否存在用戶的查詢數據；如果有，則從本地緩存中加載出來查詢數據返回給用戶；如果沒有，則向緩存中間件發起數據查詢請求；緩存中間件接收到數據查詢請求時，判斷緩存是否命中；如果命中，則返回查詢數據至服務器集群，由服務器集群將查詢數據返回給用戶；如果沒有命中，緩存中間件則返回沒有命中信息至服務器集群；服務器集群向緩存中間件申請分布式鎖；服務器集群若獲得分布式鎖，則直接向數據層請求獲取查詢數據。本發明可以減輕服務器和數據庫壓力，提升服務性能。

技術領域

本發明涉及數據處理技術領域，特別涉及一種基于webflux框架的數據處理方法、系統及介質。

背景技術

目前，在用戶進行查詢時，常用的都是直接去數據庫查詢，然后直接返回給前端，在頁面展示。

具體地，傳統用戶查詢數據是直接從數據庫加載出來，然后直接渲染頁面，這樣就會導致當有大量用戶進行查詢數據時，所有的查詢動作都會直接到數據庫，對數據庫造成極大壓力，容易造成數據庫崩潰。

發明內容

本發明的主要目的提出一種基于webflux框架的數據處理方法、系統及介質，旨在減輕服務器和數據庫壓力，提升服務性能，特別是當大量用戶在同一時刻進行查詢時，可以有效的利用緩存，在到達服務器集群，查詢本地緩存時就可以直接返回，提高頁面的響應速度。

為實現上述目的，本發明提供了一種基于webflux框架的數據處理方法，所述基于webflux框架的數據處理方法應用于基于webflux框架的數據處理系統，所述基于webflux框架的數據處理系統具有服務器集群、緩存中間件和數據層多層緩存系統，所述基于webflux框架的數據處理方法包括以下步驟：

步驟S10，所述服務器集群在接收到用戶的數據查詢指令時，判斷本地緩存中是否存在用戶的查詢數據；

步驟S20，如果有，則從本地緩存中加載出來所述查詢數據返回給用戶；

步驟S30，如果沒有，則向所述緩存中間件發起數據查詢請求；

步驟S40，所述緩存中間件接收到所述數據查詢請求時，判斷緩存是否命中；

步驟S50，如果命中，則返回查詢數據至所述服務器集群，由所述服務器集群將查詢數據返回給用戶；

步驟S60，如果沒有命中，所述緩存中間件則返回沒有命中信息至所述服務器集群；

步驟S70，所述服務器集群向所述緩存中間件申請分布式鎖；

步驟S80，所述服務器集群若獲得所述分布式鎖，則直接向所述數據層請求獲取查詢數據。

本發明進一步的技術方案是，所述步驟S70，所述服務器集群向所述緩存中間件申請分布式鎖，直接向所述數據層請求獲取查詢數據的步驟之后包括：

步驟S90，所述服務器集群若沒有獲得所述分布式鎖，則執行序列延遲等待，等待預設時長后返回執行所述步驟S80。

本發明進一步的技術方案是，所述步驟S90，所述服務器集群若沒有獲得所述分布式鎖，則執行序列延遲等待，等待預設時長后返回執行所述步驟S80的步驟包括：

所述服務器集群若沒有獲得所述分布式鎖，則執行序列延遲等待，獲取預設時長內沒有獲得所述分布式鎖的信號次數；

若預設時長內沒有獲得所述分布式鎖的信號次數小于或等于5次，則設置短時間默認緩存值通過所述緩存中間件返回給所述服務器集群。

本發明進一步的技術方案是，所述若沒有獲得所述分布式鎖，則執行序列延遲等待，獲取預設時長內沒有獲得所述分布式鎖的信號次數的步驟之后還包括：