一種處理紅包的方法及系統與流程

2023-10-10 23:12:14 4

本申請涉及通信技術領域，尤其涉及一種處理紅包的方法及系統。

背景技術：

隨著科學技術的不斷發展，通信技術也得到了飛速的發展，電子產品的種類也越來越多，人們也享受到了科技發展帶來的各種便利。

網際網路應用中處處可見類似搶紅包的應用，尤其是在彈幕式視頻直播行業，各種由贈送高價值禮物而觸發的虛擬貨幣的紅包應用已經非常普遍。

而在搶紅包應用場景中，由於用戶的搶紅包行為存在一定的不可預測性，在面對高並發的搶紅包請求場景下會形成搶紅包的高峰期，在搶紅包高峰期時，搶紅包請求難以快速響應。

技術實現要素：

本發明了提供了一種處理紅包的方法及系統，以解決搶紅包請求難以快速響應的技術問題。

為解決上述技術問題，本發明提供了一種處理紅包的方法及系統，所述方法應用於處理紅包的系統，所述系統包括客戶端、紅包伺服器、資料庫組，所述資料庫組中包含有主資料庫和從資料庫集合，所述從資料庫集合中包含有用於查詢紅包對應的貨幣價值的多個查詢資料庫；所述方法包括：

所述紅包伺服器接收所述客戶端發送的搶紅包請求，判斷所述搶紅包請求中是否攜帶所述紅包對應的身份標識ID；

若所述搶紅包請求中攜帶有所述紅包對應的身份標識ID，所述紅包伺服器隨機從所述多個查詢資料庫中的確定出第一查詢資料庫，並利用所述第一查詢資料庫基於所述紅包對應的身份標識ID查找是否有所述紅包對應的貨幣價值；

若有所述紅包對應的貨幣價值，所述紅包伺服器從所述主資料庫中獲取所述紅包對應的貨幣價值返回給所述客戶端。

優選的，所述判斷所述搶紅包請求中是否攜帶所述紅包對應的身份標識ID之後，所述方法還包括：

若所述搶紅包請求中沒有攜帶所述紅包對應的身份標識ID，生成貨幣價值為0的紅包返回給所述客戶端。

優選的，所述利用所述第一查詢資料庫基於所述紅包對應的身份標識ID查找是否有所述紅包對應的貨幣價值之後，所述方法還包括：

若沒有所述紅包對應的貨幣價值，生成貨幣價值為0的紅包返回給所述客戶端。

優選的，所述客戶端發送搶紅包請求之前，所述方法還包括：

所述客戶端發送用於創建紅包的請求數據包；

所述紅包伺服器接收到所述請求數據包；

所述紅包伺服器判斷所述請求數據包中是否包含有貨幣總價值Vt和紅包分配份數Cn，其中Cn為正整數且Cn≥1；

若所述請求數據包中包含有所述貨幣總價值Vt和所述紅包分配份數Cn，所述紅包伺服器將所述貨幣總值Vt隨機分配成Cn份紅包，每份紅包對應有各自的貨幣價值；

所述紅包伺服器為所述Cn份紅包創建各自的身份標識ID。

優選的，從資料庫集合中還包括有一個用於永久存儲所述Cn份紅包和各自的貨幣價值的存儲資料庫。

優選的，所述紅包伺服器為所述Cn份紅包創建各自的身份標識ID之後，所述方法還包括：

所述紅包伺服器在多個資料庫組中確定出包含有所述主資料庫和所述從資料庫集合的資料庫組，其中，在多個資料庫組中，每個資料庫組包含有主資料庫和從資料庫集合；

所述紅包伺服器利用所述主資料庫存儲所述Cn份紅包、所述Cn份紅包各自身份標識ID、所述Cn份紅包各自的貨幣價值。

優選的，所述紅包伺服器利用所述主資料庫存儲所述Cn份紅包、所述Cn份紅包各自身份標識ID、所述Cn份紅包各自的貨幣價值之後，所述方法還包括：

所述紅包伺服器將所述Cn份紅包、所述Cn份紅包各自身份標識ID、所述Cn份紅包各自的貨幣價值同步存儲到所述從資料庫集合中。

優選的，所述紅包伺服器將所述貨幣總值Vt隨機分配成Cn份紅包，包括：

以Cn份紅包為標準對所述貨幣總值Vt進行分配；或者

以貨幣價值為標準對所述貨幣總值Vt進行分配，紅包的份數Cn隨機。

本發明的另一個方面，公開了一種處理紅包的系統，所述系統包括：客戶端、紅包伺服器、資料庫組，所述資料庫組中包含主資料庫和從資料庫集合，所述從資料庫集合中包含有用於查詢紅包對應的貨幣價值的多個查詢資料庫；

所述客戶端，用於發送搶紅包請求；

所述紅包伺服器，用於接收到由所述客戶端發送的搶紅包請求，然後判斷所述搶紅包請求中是否攜帶所述紅包對應的身份標識ID；

所述紅包伺服器，用於若所述搶紅包請求中攜帶有所述紅包對應的身份標識ID，隨機從所述多個查詢資料庫中的確定出第一查詢資料庫，並利用所述第一查詢資料庫基於所述紅包對應的身份標識ID查找是否有所述紅包對應的貨幣價值；

所述紅包伺服器，用於若有所述紅包對應的貨幣價值，從所述主資料庫中獲取所述紅包對應的貨幣價值返回給所述客戶端。

優選的，所述客戶端，用於發送用於創建紅包的請求數據包；

所述紅包伺服器，用於接收到所述請求數據包；判斷所述請求數據包中是否包含有貨幣總價值Vt和紅包分配份數Cn，其中Cn為正整數且Cn≥1；若所述請求數據包中包含有所述貨幣總價值Vt和所述紅包分配份數Cn，將所述貨幣總值Vt隨機分配成Cn份紅包，每份紅包對應有各自的貨幣價值；為所述Cn份紅包創建各自的身份標識ID。

通過本發明的一個或者多個技術方案，本發明具有以下有益效果或者優點：

本發明公開了一種處理紅包的方法及系統，當所述客戶端發送搶紅包請求之後，所述紅包伺服器判斷所述搶紅包請求中是否攜帶所述紅包對應的身份標識ID；若是則隨機從所述多個查詢資料庫中的確定出第一查詢資料庫，並利用所述第一查詢資料庫基於所述紅包對應的身份標識ID查找是否有所述紅包對應的貨幣價值；若有所述紅包對應的貨幣價值，所述紅包伺服器從所述主資料庫中獲取所述紅包對應的貨幣價值返回給所述客戶端。本發明將資料庫組分為主資料庫和從資料庫集合，採用通過從資料庫集合中的查詢資料庫來查紅包中是否有剩餘紅包，再確定是否要去主資料庫中完成相應操作，降低了主資料庫的壓力，直接提升了搶紅包的響應效率。

附圖說明

圖1為本發明實施例中的整體框架圖；

圖2為本發明實施例中Redis Group的組成圖；

圖3為本發明實施例中本發明的創建紅包的流程圖；

圖4為本發明實施例中發紅包的流程圖。

具體實施方式

為了使本申請所屬技術領域中的技術人員更清楚地理解本申請，下面結合附圖，通過具體實施例對本申請技術方案作詳細描述。

圖1為本發明的整體框架圖：

1)Client:客戶端，發送搶寶箱請求。舉例來說，本發明具有客戶端1、客戶端2、客戶端3……客戶端n。每個客戶端都可以發送搶寶箱請求。

2)GateServer Cluster:網關服務集群，負責client的網絡接入，隔離、保護公網和內網的數據交換。

3)RedpacketServer Cluster：紅包伺服器的集群，負責處理創建紅包、搶紅包的網絡請求。

4)Redis Group:資料庫組，負責紅包數據持久化和搶紅包的結果處理，根據紅包身份標識ID進行分片，每個紅包都有一個唯一的身份標識ID。舉例來說，本發明具有m個資料庫組，分別為：資料庫組1、資料庫組2、資料庫組3……資料庫組m。

圖2為Redis Group的組成圖：

在圖2中，一個Redis Group(資料庫組)由一個Master Redis主資料庫和一個從資料庫集合組成，所述從資料庫集合中包含有用於存儲紅包數據的一個存儲資料庫和用於查詢紅包對應的貨幣價值的多個查詢資料庫。

具體來說，在從資料庫集合中包含有若干(大於等於2)個Slave Redis從資料庫。其中，這若干個從資料庫中，可隨機確定一個從資料庫作為存儲資料庫，其餘的從資料庫作為查詢資料庫。例如圖2中，x個從資料庫中的第一從資料庫作為存儲資料庫，而其餘的第2從資料庫至第x個從資料庫作為查詢資料庫。

5)Master Redis：主資料庫，負責創建紅包、搶紅包數據的寫入操作。主資料庫和從資料庫集合存在同步機制，Mater Redis的數據發生變化，會自動同步到所有的Slave Redis從資料庫。

6)Slave Redis 1：從資料庫中的第一從資料庫，也作為存儲資料庫，只負責紅包數據的持久化。持久化的含義即是：第一從資料庫會永久存儲創建的所有紅包、所有紅包各自的身份標識ID、所有紅包各自的貨幣價值等等。這些數據不會隨著伺服器的重啟、故障等等原因而丟失。

7)Slave Redis 2至Slave Redis x：從資料庫中的第2從資料庫至第x個從資料庫，作為查詢資料庫。這些從資料庫只負責處理紅包數據的查詢操作，Redis在當下比較主流的伺服器上的QPS(Query Per Second，每秒查詢率)可高達5～8W。

綜上，本發明公開的一種處理紅包的系統，包括：客戶端集群、紅包伺服器集群、網關服務集群、多個資料庫組。

客戶端和紅包伺服器的信息交互時通過網關服務集群進行轉發的。

每個資料庫組中包含一個主資料庫和一個從資料庫集合，所述從資料庫集合中包含有用於查詢紅包對應的貨幣價值的多個查詢資料庫。

下面先介紹創建紅包的具體實施過程，當然，本發明是以一個客戶端為例進行介紹，其他客戶端創建紅包的過程類似，故而不再贅述。

所述客戶端，用於發送用於創建紅包的請求數據包；

所述紅包伺服器，用於接收到所述請求數據包；判斷所述請求數據包中是否包含有貨幣總價值Vt和紅包分配份數Cn，其中Cn為正整數且Cn≥1；若所述請求數據包中包含有所述貨幣總價值Vt和所述紅包分配份數Cn，將所述貨幣總值Vt隨機分配成Cn份紅包，每份紅包對應有各自的貨幣價值；為所述Cn份紅包創建各自的身份標識ID。

另外，所述紅包伺服器，還用於為所述Cn份紅包創建各自的身份標識ID之後，在多個資料庫組中確定出包含有所述主資料庫和所述從資料庫集合的資料庫組，其中，在多個資料庫組中，每個資料庫組包含有一主資料庫和一從資料庫集合；利用所述主資料庫存儲所述Cn份紅包、所述Cn份紅包各自身份標識ID、所述Cn份紅包各自的貨幣價值。

作為一種可選的實施例，紅包伺服器，還用於將所述Cn份紅包、所述Cn份紅包各自身份標識ID、所述Cn份紅包各自的貨幣價值同步存儲到所述從資料庫集合中。

下面介紹發紅包的實施原理。

所述客戶端，用於發送搶紅包請求；

所述紅包伺服器，用於接收到由所述客戶端發送的搶紅包請求，然後判斷所述搶紅包請求中是否攜帶所述紅包對應的身份標識ID；若所述搶紅包請求中攜帶有所述紅包對應的身份標識ID，隨機從所述多個查詢資料庫中的確定出第一查詢資料庫，並利用所述第一查詢資料庫基於所述紅包對應的身份標識ID查找是否有所述紅包對應的貨幣價值；若有所述紅包對應的貨幣價值，從所述主資料庫中獲取所述紅包對應的貨幣價值返回給所述客戶端。

基於上述架構，圖3為本發明的創建紅包的流程圖：

步驟31，客戶端發送用於創建紅包的請求數據包。

具體來說，在客戶端上，安裝有對應的應用程式Application。該應用程式可以執行創建紅包操作，也可以執行搶紅包操作。

在創建紅包時，客戶端上的應用程式發送創建紅包的請求數據包CreateData給紅包伺服器Redpacket Server。該請求數據包CreateData中至少包含有紅包的貨幣總價值Vt、紅包分配份數Cn。

紅包伺服器Redpacket Server，是Redpacket Server Cluster的組成單元，每個紅包伺服器Redpacket Server擁有唯一的16位服務ID，本發明將其簡稱為RSID。

請求數據包CreateData發送到哪一個紅包伺服器Redpacket Server由隨機函數Random(time(NULL))得出的結果Rm對紅包伺服器Redpacket Server總數量Rn取模確定的。例如：Rm％Rn為0，則請求數據包CreateData的落點就是第1個紅包伺服器Redpacket Server上，依次類推。

步驟32，所述紅包伺服器接收到所述請求數據包。

步驟33，所述紅包伺服器判斷所述請求數據包中是否包含有貨幣總價值Vt和紅包分配份數Cn。

其中，Cn為正整數且Cn≥1。

具體來說，紅包伺服器Redpacket Server檢查請求數據包CreateData中是否攜帶必要參數。如請求數據包CreateData中是否攜帶了貨幣總價值Vt，紅包分配份數Cn，若都不存在，或者只有一個參數存在，則直接返回創建紅包失敗。

若貨幣總價值Vt，紅包分配份數Cn都存在，則進入步驟34。

步驟34，若所述請求數據包中包含有所述貨幣總價值Vt和所述紅包分配份數Cn，所述紅包伺服器將所述貨幣總值Vt隨機分配成Cn份紅包，每份紅包對應有各自的貨幣價值。

具體來說，紅包伺服器Redpacket Server將貨幣總值Vt隨機分配(分配規則可根據不同的業務需求自定義)成Cn份紅包，每個紅包包含貨幣價值Vn。

在分配的實施過程中，有兩種分配方式：

第一種分配方式：以Cn份紅包為標準，對所述貨幣總值Vt進行分配，每份紅包中的貨幣價值隨機。舉例來說，Cn＝5，貨幣總值＝100塊，那麼將這100塊分成5個紅包，每個紅包的貨幣價值可以隨機，例如50塊、20塊、10塊、10塊、10塊。當然也可以平均分配，每個紅包20塊。

第二種分配方式，以貨幣價值為標準對所述貨幣總值Vt進行分配，紅包的份數Cn隨機。舉例來說，貨幣總值＝100塊，每個紅包的貨幣價值為1塊或者2塊，那麼按照貨幣價值進行分配，就可以分配到50個紅包-100個紅包。

步驟35，所述紅包伺服器為所述Cn份紅包創建各自的身份標識ID。

具體來說，每個紅包有唯一的64位身份標識ID，簡稱為RPID。RPID的高32位為當前時間戳，中間的16位為RSID，低16位為0～65536循環的自增長ID。

紅包伺服器為所述Cn份紅包創建各自的身份標識ID之後，紅包伺服器在多個資料庫組中確定出包含有所述主資料庫和所述從資料庫集合的資料庫組。其中，在多個資料庫組中，每個資料庫組包含有一主資料庫和一從資料庫集合。

故而，在步驟35之後會執行步驟36：所述紅包伺服器利用所述主資料庫存儲所述Cn份紅包、所述Cn份紅包各自身份標識ID、所述Cn份紅包各自的貨幣價值。舉例來說，選在一個Redis Group資料庫時，對RPID進行BKDR hash得到結果Hn，Hn對Redis Group總量Gn取模確認落點在哪個Redis Group上。Hn％Gn為0，則紅包數據就落地到第1個Redis Group上，依次類推。

在Redis Group內，Master Redis用List數據結構存儲Cn份紅包，Key值為RPID。

完成此流程後，Redis主、從同步機制會自動完成數據同步工作。即步驟37：所述紅包伺服器將所述Cn份紅包、所述Cn份紅包各自身份標識ID、所述Cn份紅包各自的貨幣價值同步存儲到所述從資料庫集合中。

返回紅包創建成功的結果。

圖4為本發明一種處理紅包的方法的流程圖。

步驟41，所述客戶端發送搶紅包請求。

具體來說，客戶端Client發送搶紅包請求GrabData。用戶A在客戶端發出的紅包，都攜帶有對應的身份標識ID。故而用戶B在搶紅包時，客戶端會基於用戶B的操作生成搶紅包請求，該請求會攜帶該紅包對應的身份標識ID，然後將搶紅包請求發送給網關服務Gate Server。網關服務Gate Server是Gate Server Cluster的組成單元。

Gate Server將搶紅包請求GrabData轉發到內網的紅包伺服器Redpacket Server。

步驟42，所述紅包伺服器接收到由所述客戶端發送的搶紅包請求，然後判斷所述搶紅包請求中是否攜帶所述紅包對應的身份標識ID。

若所述搶紅包請求中沒有攜帶所述紅包對應的身份標識ID，生成貨幣價值為0的紅包返回給所述客戶端。

具體來說，Redpacket Server通過檢查搶紅包請求GrabData的數據是否有效(例如，是否包含合法的RPID)，如果合法則進入下一流程，否則返回未搶到紅包獎勵的結果(偽造一條Vn為0的紅包數據返回)。

步驟43，若所述搶紅包請求中攜帶有所述紅包對應的身份標識ID，所述紅包伺服器隨機從所述多個查詢資料庫中的確定出第一查詢資料庫，並利用所述第一查詢資料庫基於所述紅包對應的身份標識ID查找是否有所述紅包對應的貨幣價值。

第一查詢資料庫是多個查詢資料庫中任意確定的一查詢資料庫，其作用是基於所述紅包對應的身份標識ID查找是否有所述紅包對應的貨幣價值。若沒有所述紅包對應的貨幣價值，生成貨幣價值為0的紅包返回給所述客戶端，表示未搶到紅包獎勵。

具體來說，在某一個Slave Redis中查詢id為RPID的紅包中是否任然存在紅包，如果存在，則進入下一流程，否則返回未搶到紅包的結果(偽造一條Vn為0的紅包數據返回)。

步驟44，若有所述紅包對應的貨幣價值，所述紅包伺服器從所述主資料庫中獲取所述紅包對應的貨幣價值返回給所述客戶端。

具體來說，在Master Redis中找到Key為RPID的List，並pop出一條紅包數據，如果List為空或者不存在，則偽造一條Vn為0的紅包數據返回。到此處就可返回成功搶紅包的結果。

將紅包中Vn大於0的數據和UID拋入MQ(MessageQueue消息隊列)異步完成貨幣交易。

本方案的關鍵點在於Redis Group。

Redis Group根據RPID分片，可橫線擴展Redis Group用於均衡不同的紅包帶來的請求壓力。每個Redis Group中的Slave Redis也能橫向擴展，用於均衡同一個紅包帶來的請求壓力。具體每一個紅包List落在哪一個Redis Group上，是根據RPID做BKDR hash確定的，如此保證了離散型。

Redis Group採用Slave Redis 1來持久化紅包數據，可避免Master Redis和其他Slave Redis因持久化數據而降低QPS。

採用通過Slave Redis查紅包中是否有剩餘紅包，再確定是否要去Master Redis中完成相應操作。雖然搶紅包的client數量可能在百萬級，但是紅包真正能分配出去的份額遠在這個數量級之下(千或者萬級別)。通過從Slave Redis中查詢紅包剩餘數量就能過濾掉90％以上Mater Redis非必要響應的GrabData。降低了Mater Redis的壓力，就直接提升了搶寶箱的響應效率。

通過本發明的一個或者多個實施例，本發明具有以下有益效果或者優點：

本發明公開了一種處理紅包的方法及系統，當所述客戶端發送搶紅包請求之後，所述紅包伺服器判斷所述搶紅包請求中是否攜帶所述紅包對應的身份標識ID；若是則隨機從所述多個查詢資料庫中的確定出第一查詢資料庫，並利用所述第一查詢資料庫基於所述紅包對應的身份標識ID查找是否有所述紅包對應的貨幣價值；若有所述紅包對應的貨幣價值，所述紅包伺服器從所述主資料庫中獲取所述紅包對應的貨幣價值返回給所述客戶端。本發明將資料庫組分為主資料庫和從資料庫集合，採用通過從資料庫集合中的查詢資料庫來查紅包中是否有剩餘紅包，再確定是否要去主資料庫中完成相應操作，降低了主資料庫的壓力，直接提升了搶紅包的響應效率。

儘管已描述了本申請的優選實施例，但本領域內的普通技術人員一旦得知了基本創造性概念，則可對這些實施例作出另外的變更和修改。所以，所附權利要求意欲解釋為包括優選實施例以及落入本申請範圍的所有變更和修改。

顯然，本領域的技術人員可以對本申請進行各種改動和變型而不脫離本申請的精神和範圍。這樣，倘若本申請的這些修改和變型屬於本申請權利要求及其等同技術的範圍之內，則本申請也意圖包含這些改動和變型在內。