[發(fā)明專利]消費(fèi)者消費(fèi)狀態(tài)控制方法、系統(tǒng)、終端及存儲(chǔ)介質(zhì)

在審

• 申請?zhí)枺?/td>: 202011189072.7
• 申請日: 2020-10-30
• 公開（公告）號: CN112328409A
• 公開（公告）日: 2021-02-05
• 發(fā)明（設(shè)計(jì)）人: 劉文彬
• 申請（專利權(quán)）人: 中國平安財(cái)產(chǎn)保險(xiǎn)股份有限公司
• 主分類號: G06F9/54
• 分類號: G06F9/54
• 代理公司: 深圳國新南方知識產(chǎn)權(quán)代理有限公司 44374
• 代理人: 周雷

1.一種消費(fèi)者消費(fèi)狀態(tài)控制方法，其特征在于，包括：

實(shí)時(shí)接收用戶輸入的針對于目標(biāo)消費(fèi)者集群的目標(biāo)消費(fèi)狀態(tài)表，所述目標(biāo)消費(fèi)狀態(tài)表記錄了所述目標(biāo)消費(fèi)者集群中每一個(gè)目標(biāo)消費(fèi)者的目標(biāo)狀態(tài)，所述目標(biāo)狀態(tài)包括上線狀態(tài)或下線狀態(tài)；

獲取每一個(gè)目標(biāo)消費(fèi)者的當(dāng)前上下線狀態(tài)；

判斷每一個(gè)目標(biāo)消費(fèi)者的當(dāng)前上下線狀態(tài)是否與對應(yīng)的所述目標(biāo)狀態(tài)一致；

若一致，則繼續(xù)維持所述當(dāng)前上下線狀態(tài)；

若不一致，則執(zhí)行相應(yīng)操作修改所述當(dāng)前上下線狀態(tài)以與所述目標(biāo)狀態(tài)一致。

2.根據(jù)權(quán)利要求1所述的消費(fèi)者消費(fèi)狀態(tài)控制方法，其特征在于，所述執(zhí)行相應(yīng)操作修改所述當(dāng)前上下線狀態(tài)以與所述目標(biāo)狀態(tài)一致，包括：

若所述目標(biāo)消費(fèi)者當(dāng)前處于下線狀態(tài)且對應(yīng)的所述目標(biāo)狀態(tài)為上線狀態(tài)，則向消息中間件注冊所述目標(biāo)消費(fèi)者的IP，且所述消息中間件接收所述目標(biāo)消費(fèi)者發(fā)送的心跳，再控制所述目標(biāo)消費(fèi)者向所述消息中間件發(fā)送訂閱所述目標(biāo)消息的請求；

若所述目標(biāo)消費(fèi)者當(dāng)前處于下線狀態(tài)且對應(yīng)的所述目標(biāo)狀態(tài)為下線狀態(tài)，則繼續(xù)維持下線狀態(tài)；

若所述目標(biāo)消費(fèi)者當(dāng)前處于上線狀態(tài)且對應(yīng)的所述目標(biāo)狀態(tài)為下線狀態(tài)，則從所述消息中間件中刪除所述目標(biāo)消費(fèi)者的IP，且控制所述消息中間件停止接收所述目標(biāo)消費(fèi)者發(fā)送的心跳；

若所述目標(biāo)消費(fèi)者當(dāng)前處于上線狀態(tài)且對應(yīng)的所述目標(biāo)狀態(tài)為上線狀態(tài)，則繼續(xù)維持上線狀態(tài)。

3.根據(jù)權(quán)利要求1所述的消費(fèi)者消費(fèi)狀態(tài)控制方法，其特征在于，所述實(shí)時(shí)接收用戶輸入的針對于目標(biāo)消費(fèi)者集群的目標(biāo)消費(fèi)狀態(tài)表之前，還包括：

當(dāng)消息中間件接收到一條由生產(chǎn)者發(fā)送的消息時(shí)，判斷是否存在訂閱所述消息的消費(fèi)者集群；

若不存在，則獲取向所述消息中間件訂閱所述消息的所有消費(fèi)者，構(gòu)成所述消費(fèi)者集群。

4.根據(jù)權(quán)利要求1所述的消費(fèi)者消費(fèi)狀態(tài)控制方法，其特征在于，所述執(zhí)行相應(yīng)操作修改所述當(dāng)前上下線狀態(tài)以與所述目標(biāo)狀態(tài)一致之后，還包括：

存儲(chǔ)所述目標(biāo)消費(fèi)狀態(tài)表至存儲(chǔ)器，且覆蓋掉所述目標(biāo)消費(fèi)者集群的歷史消費(fèi)狀態(tài)表。

5.根據(jù)權(quán)利要求4所述的消費(fèi)者消費(fèi)狀態(tài)控制方法，其特征在于，所述方法還包括：

啟動(dòng)應(yīng)用時(shí)，以所述應(yīng)用作為當(dāng)前消費(fèi)者啟動(dòng)MQ服務(wù)；

確認(rèn)所述當(dāng)前消費(fèi)者請求消費(fèi)的目標(biāo)消息，以確認(rèn)所述當(dāng)前消費(fèi)者所屬的目標(biāo)消費(fèi)者集群，并從所述存儲(chǔ)器中獲取所述目標(biāo)消費(fèi)者集群對應(yīng)的目標(biāo)消費(fèi)狀態(tài)表；

通過所述目標(biāo)消費(fèi)狀態(tài)表判斷所述當(dāng)前消費(fèi)者是上線狀態(tài)還是下線狀態(tài)；

若是上線狀態(tài)，則允許所述當(dāng)前消費(fèi)者觸發(fā)上線操作，所述當(dāng)前消費(fèi)者切換至上線狀態(tài)；

若是下線狀態(tài)，則禁止所述當(dāng)前消費(fèi)者觸發(fā)上線操作，所述當(dāng)前消費(fèi)者維持下線狀態(tài)。

6.根據(jù)權(quán)利要求5所述的消費(fèi)者消費(fèi)狀態(tài)控制方法，其特征在于，所述允許所述當(dāng)前消費(fèi)者觸發(fā)上線操作，所述當(dāng)前消費(fèi)者切換至上線狀態(tài)之后，還包括：

當(dāng)所述應(yīng)用發(fā)起關(guān)閉請求時(shí)，將所述當(dāng)前消費(fèi)者的狀態(tài)記錄至所述目標(biāo)消費(fèi)狀態(tài)表中，再控制所述當(dāng)前消費(fèi)者觸發(fā)下線操作，所述當(dāng)前消費(fèi)者切換至下線狀態(tài)。

7.根據(jù)權(quán)利要求1所述的消費(fèi)者消費(fèi)狀態(tài)控制方法，其特征在于，所述執(zhí)行相應(yīng)操作修改所述當(dāng)前上下線狀態(tài)以與所述目標(biāo)狀態(tài)一致之后，還包括：

將所述消費(fèi)狀態(tài)表上傳至區(qū)塊鏈中。