[發(fā)明專利]一種智能控制消費(fèi)腳本通道的方法

在審

• 申請(qǐng)?zhí)枺?/td>: 201811331132.7
• 申請(qǐng)日: 2018-11-09
• 公開（公告）號(hào): CN111176856A
• 公開（公告）日: 2020-05-19
• 發(fā)明（設(shè)計(jì)）人: 楊弈超
• 申請(qǐng)（專利權(quán)）人: 商派軟件有限公司
• 主分類號(hào): G06F9/54
• 分類號(hào): G06F9/54
• 代理公司: 常州佰業(yè)騰飛專利代理事務(wù)所(普通合伙) 32231
• 代理人: 顧翰林

1.一種智能控制消費(fèi)腳本通道的方法，其特征在于，包括如下步驟：

步驟1：使用Python+Redis+Ansible進(jìn)行集群化管理；

步驟2：配置隊(duì)列的基礎(chǔ)信息；

步驟3：任務(wù)路由分配；

步驟4：任務(wù)隊(duì)列控制。

2.根據(jù)權(quán)利要求1所述的一種智能控制消費(fèi)腳本通道的方法，其特征在于，所述步驟1中，使用Python+Redis+Ansible進(jìn)行集群化管理，其中：

Python是根據(jù)配置信息進(jìn)行邏輯處理；

Redis是存儲(chǔ)配置+消費(fèi)隊(duì)列；

Ansible是指定某臺(tái)服務(wù)器進(jìn)行消息腳本擴(kuò)容或回收。

3.根據(jù)權(quán)利要求1所述的一種智能控制消費(fèi)腳本通道的方法，其特征在于，所述步驟2中，配置隊(duì)列的基礎(chǔ)信息包括：

消費(fèi)隊(duì)列任務(wù)名稱；

執(zhí)行消費(fèi)腳本命令；

消費(fèi)腳本所在服務(wù)器IP；

隊(duì)列Work數(shù)【默認(rèn)＝》1】；

預(yù)警Work數(shù)；

預(yù)警聯(lián)系人手機(jī)號(hào)。

4.根據(jù)權(quán)利要求3所述的一種智能控制消費(fèi)腳本通道的方法，其特征在于，所述預(yù)警Work數(shù)包括：

每條消費(fèi)隊(duì)列超過某條等待任務(wù)后開啟新Work【默認(rèn)＝》100】；

每條消費(fèi)腳本低于多少條后進(jìn)行回收，新的work有免回收的保護(hù)期。

5.根據(jù)權(quán)利要求1所述的一種智能控制消費(fèi)腳本通道的方法，其特征在于，所述步驟3中，任務(wù)路由分配包括：

Python守護(hù)進(jìn)程監(jiān)聽總?cè)蝿?wù)隊(duì)列，根據(jù)任務(wù)類型分配到對(duì)應(yīng)的子隊(duì)列；

每個(gè)任務(wù)類型都對(duì)應(yīng)獨(dú)自的計(jì)數(shù)值，每進(jìn)來一個(gè)相應(yīng)的任務(wù)，進(jìn)行加一；

根據(jù)子任務(wù)work數(shù)進(jìn)行取模后進(jìn)行分派。

6.根據(jù)權(quán)利要求1所述的一種智能控制消費(fèi)腳本通道的方法，其特征在于，所述步驟4中，任務(wù)隊(duì)列控制包括：

每隔5秒，統(tǒng)計(jì)正在運(yùn)行的隊(duì)列的長(zhǎng)度；

讀取配置信息后進(jìn)行邏輯判斷，對(duì)任務(wù)隊(duì)列進(jìn)行擴(kuò)容或者回收；

每個(gè)子隊(duì)列都有【活動(dòng)中、回收中】二種狀態(tài)，處于回收中狀態(tài)不進(jìn)行分派，消費(fèi)完成后進(jìn)行回收。