[發明專利]一種信息處理方法及設備

有效

• 申請號: 201611038830.9
• 申請日: 2016-11-23
• 公開（公告）號: CN108090731B
• 公開（公告）日: 2021-10-15
• 發明（設計）人: 宋文軍;黃明;馬淑婧
• 申請（專利權）人: 騰訊科技（深圳）有限公司
• 主分類號: G06Q10/10
• 分類號: G06Q10/10
• 代理公司: 北京派特恩知識產權代理有限公司 11270
• 代理人: 崔曉嵐;張穎玲

1.一種信息處理方法，其特征在于，所述方法包括：

基于用戶行為獲得工作流請求信息；

當所述工作流請求信息的驅動類型為第一驅動類型時，生成所述工作流請求信息對應的關鍵信息，通過第一分發器將所述關鍵信息寫入第一等待隊列中，并將所述工作流請求信息對應的工作流內容存儲到數據庫中；其中，所述第一驅動類型為以下驅動類型的其中之一：定時驅動、重調驅動、參數驅動，其中，所述定時驅動對應于執行系統需要定時執行的工作流，所述重調驅動對應于計算歷史數據或重新執行定時任務的工作流，所述參數驅動對應于自定義參數且需要后臺應用程序編程接口執行的工作流；

通過第一事件處理器按順序從所述第一等待隊列中讀取關鍵信息，基于所述關鍵信息從所述數據庫中讀取所述工作流內容，并基于所述工作流內容生成工作流實例，將所述工作流實例寫入第一下發隊列中；

通過第一提交器從所述第一下發隊列中讀取工作流實例發送至對應的執行節點以執行所述工作流實例；

其中，針對每一驅動類型的工作流預先配置相應的分發器、等待隊列、事件處理器、下發隊列以及提交器，并通過所述分發器、所述等待隊列、所述事件處理器、所述下發隊列以及所述提交器處理所述每一驅動類型的工作流請求信息。

2.根據權利要求1所述的方法，其特征在于，所述通過第一分發器將所述關鍵信息寫入第一等待隊列時，所述方法還包括：控制所述第一等待隊列對應的第一計數器加一；

相應的，所述通過第一事件處理器按順序從所述第一等待隊列中讀取關鍵信息時，所述方法還包括：所述第一事件處理器控制所述第一計數器減一；

所述將所述工作流實例寫入第一下發隊列時，所述方法還包括：所述第一事件處理器控制所述第一下發隊列對應的第二計時器加一；

相應的，所述通過第一提交器從所述第一下發隊列中讀取工作流實例時，所述方法還包括：所述第一提交器控制所述第一下發隊列對應的第二計時器減一；

所述讀取工作流實例發送至對應的執行節點時，所述方法還包括：所述第一提交器控制所述執行節點對應的第三計時器加一。

3.根據權利要求1所述的方法，其特征在于，所述通過第一分發器將所述關鍵信息寫入第一等待隊列中之后，所述方法還包括：所述第一等待隊列中的關鍵信息按照預設規則進行排序；其中，所述第一等待隊列中的關鍵信息按照預設規則排序，包括：

不同用戶產生的工作流請求信息對應的關鍵信息按照所述工作流請求信息的生成時間的先后順序排序；

同一用戶不同批次產生的工作流請求信息對應的關鍵信息按照所述工作流請求信息的生成時間的先后順序排序；

同一用戶同一批次產生的工作流請求信息對應的關鍵信息，當所述第一驅動類型為重調驅動類型時，所述關鍵信息按照所述工作流請求信息對應的業務日期的先后順序排序；當所述第一驅動類型為除所述重調驅動類型以外的其他驅動類型時，所述關鍵信息按照工作流實例生成的先后順序排序。

4.根據權利要求1所述的方法，其特征在于，所述生成所述工作流請求信息對應的關鍵信息，通過第一分發器將所述關鍵信息寫入第一等待隊列中，包括：

識別所述工作流請求信息中包括的工作流，獲得所述工作流的標識以及參數信息，將所述工作流的標識和對應的參數信息作為關鍵信息，通過第一分發器將所述關鍵信息寫入第一等待隊列中。

5.根據權利要求1所述的方法，其特征在于，所述驅動類型還包括手工驅動類型，所述方法還包括：通過第二分發器直接分發所述工作流請求信息；

通過第二提交器直接基于所述工作流請求信息生成工作流實例；將所述工作流實例發送至對應的執行節點以執行所述工作流實例，其中，所述手工驅動對應于在前臺調試的工作流。