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

在審

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

本申請(qǐng)公開(kāi)了一種消費(fèi)者消費(fèi)狀態(tài)控制方法、系統(tǒng)、終端及存儲(chǔ)介質(zhì)，方法包括：實(shí)時(shí)接收用戶(hù)輸入的針對(duì)于目標(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)包括上線(xiàn)狀態(tài)或下線(xiàn)狀態(tài)；獲取每一個(gè)目標(biāo)消費(fèi)者的當(dāng)前上下線(xiàn)狀態(tài)；判斷每一個(gè)目標(biāo)消費(fèi)者的當(dāng)前上下線(xiàn)狀態(tài)是否與對(duì)應(yīng)的目標(biāo)狀態(tài)一致；若一致，則繼續(xù)維持當(dāng)前上下線(xiàn)狀態(tài)；若不一致，則執(zhí)行相應(yīng)操作修改當(dāng)前上下線(xiàn)狀態(tài)以與目標(biāo)狀態(tài)一致。本申請(qǐng)通過(guò)實(shí)時(shí)接收用戶(hù)輸入的消費(fèi)者狀態(tài)表對(duì)目標(biāo)消費(fèi)者集群中的目標(biāo)消費(fèi)者的消費(fèi)狀態(tài)進(jìn)行修改，從而達(dá)到了動(dòng)態(tài)、大批量管理目標(biāo)消費(fèi)者消費(fèi)狀態(tài)的目的。

技術(shù)領(lǐng)域

本申請(qǐng)涉及數(shù)據(jù)通信技術(shù)領(lǐng)域，特別是涉及一種消費(fèi)者消費(fèi)狀態(tài)控制方法、系統(tǒng)、終端及存儲(chǔ)介質(zhì)。

背景技術(shù)

隨著計(jì)算機(jī)技術(shù)的發(fā)展，越來(lái)越多的技術(shù)(如分布式、區(qū)塊鏈Blockchain、人工智能等)應(yīng)用在金融領(lǐng)域，傳統(tǒng)金融業(yè)正在逐步向金融科技(Fintech)轉(zhuǎn)變，越來(lái)越多的技術(shù)應(yīng)用于金融行業(yè)，如分布式應(yīng)用系統(tǒng)。現(xiàn)有的分布式應(yīng)用系統(tǒng)采用消息中間件方式來(lái)構(gòu)建，開(kāi)發(fā)人員通過(guò)使用消息中間件把應(yīng)用擴(kuò)展到不同的操作系統(tǒng)和不同的網(wǎng)絡(luò)環(huán)境。基于消息的機(jī)制更適用于由事件驅(qū)動(dòng)的應(yīng)用，當(dāng)一個(gè)事件發(fā)生時(shí)，消息中間件通知服務(wù)方應(yīng)該進(jìn)行如何操作。

消息中間件用于消息存儲(chǔ)，以及消息轉(zhuǎn)發(fā)。消息中間件的一個(gè)重要作用是可以跨平臺(tái)操作，為不同操作系統(tǒng)上的應(yīng)用軟件集成提供便利。

MQ消息隊(duì)列一般作為第三方服務(wù)引擎，都會(huì)配置與之配套的后臺(tái)管理系統(tǒng)。在后臺(tái)管理系統(tǒng)中，可以實(shí)時(shí)管理MQ的上線(xiàn)和下線(xiàn)，但是需要用戶(hù)手動(dòng)一臺(tái)一臺(tái)服務(wù)器進(jìn)行操作上線(xiàn)或者下線(xiàn)，當(dāng)同時(shí)操作大量服務(wù)器時(shí)，使用后臺(tái)管理系統(tǒng)進(jìn)行MQ上、下線(xiàn)操作將會(huì)非常繁瑣，需要花費(fèi)大量時(shí)間和人力來(lái)進(jìn)行。

發(fā)明內(nèi)容

本申請(qǐng)?zhí)峁┮环N消費(fèi)者消費(fèi)狀態(tài)控制方法、系統(tǒng)、終端及存儲(chǔ)介質(zhì)，以解決現(xiàn)有方案無(wú)法動(dòng)態(tài)大批量控制消費(fèi)者消費(fèi)狀態(tài)的問(wèn)題。

為解決上述技術(shù)問(wèn)題，本申請(qǐng)采用的一個(gè)技術(shù)方案是：提供一種消費(fèi)者消費(fèi)狀態(tài)控制方法，包括：實(shí)時(shí)接收用戶(hù)輸入的針對(duì)于目標(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)包括上線(xiàn)狀態(tài)或下線(xiàn)狀態(tài)；獲取每一個(gè)目標(biāo)消費(fèi)者的當(dāng)前上下線(xiàn)狀態(tài)；判斷每一個(gè)目標(biāo)消費(fèi)者的當(dāng)前上下線(xiàn)狀態(tài)是否與對(duì)應(yīng)的目標(biāo)狀態(tài)一致；若一致，則繼續(xù)維持當(dāng)前上下線(xiàn)狀態(tài)；若不一致，則執(zhí)行相應(yīng)操作修改當(dāng)前上下線(xiàn)狀態(tài)以與目標(biāo)狀態(tài)一致。

作為本申請(qǐng)的進(jìn)一步改進(jìn)，執(zhí)行相應(yīng)操作修改當(dāng)前上下線(xiàn)狀態(tài)以與目標(biāo)狀態(tài)一致，包括：若目標(biāo)消費(fèi)者當(dāng)前處于下線(xiàn)狀態(tài)且對(duì)應(yīng)的目標(biāo)狀態(tài)為上線(xiàn)狀態(tài)，則向消息中間件注冊(cè)目標(biāo)消費(fèi)者的IP，且消息中間件接收目標(biāo)消費(fèi)者發(fā)送的心跳，再控制目標(biāo)消費(fèi)者向消息中間件發(fā)送訂閱目標(biāo)消息的請(qǐng)求；若目標(biāo)消費(fèi)者當(dāng)前處于下線(xiàn)狀態(tài)且對(duì)應(yīng)的目標(biāo)狀態(tài)為下線(xiàn)狀態(tài)，則繼續(xù)維持下線(xiàn)狀態(tài)；若目標(biāo)消費(fèi)者當(dāng)前處于上線(xiàn)狀態(tài)且對(duì)應(yīng)的目標(biāo)狀態(tài)為下線(xiàn)狀態(tài)，則從消息中間件中刪除目標(biāo)消費(fèi)者的IP，且控制消息中間件停止接收目標(biāo)消費(fèi)者發(fā)送的心跳；若目標(biāo)消費(fèi)者當(dāng)前處于上線(xiàn)狀態(tài)且對(duì)應(yīng)的目標(biāo)狀態(tài)為上線(xiàn)狀態(tài)，則繼續(xù)維持上線(xiàn)狀態(tài)。

作為本申請(qǐng)的進(jìn)一步改進(jìn)，實(shí)時(shí)接收用戶(hù)輸入的針對(duì)于目標(biāo)消費(fèi)者集群的目標(biāo)消費(fèi)狀態(tài)表之前，還包括：當(dāng)消息中間件接收到一條由生產(chǎn)者發(fā)送的消息時(shí)，判斷是否存在訂閱消息的消費(fèi)者集群；若不存在，則獲取向消息中間件訂閱消息的所有消費(fèi)者，構(gòu)成消費(fèi)者集群。

作為本申請(qǐng)的進(jìn)一步改進(jìn)，執(zhí)行相應(yīng)操作修改當(dāng)前上下線(xiàn)狀態(tài)以與目標(biāo)狀態(tài)一致之后，還包括：存儲(chǔ)目標(biāo)消費(fèi)狀態(tài)表至存儲(chǔ)器，且覆蓋掉目標(biāo)消費(fèi)者集群的歷史消費(fèi)狀態(tài)表。