基于kafka實現(xiàn)穩(wěn)定的高吞吐量的異步任務處理方法

基本信息

申請?zhí)?/td> CN201910613837.6 申請日 -
公開（公告）號 CN110377486B 公開（公告）日 2022-07-08
申請公布號 CN110377486B 申請公布日 2022-07-08
分類號 G06F11/30（2006.01）I;G06F9/48（2006.01）I 分類 計算；推算；計數(shù);
發(fā)明人 胡玉煌;吳浩 申請（專利權）人 福建南威軟件有限公司
代理機構 福州元創(chuàng)專利商標代理有限公司 代理人 -
地址 350003福建省福州市鼓樓區(qū)軟件大道89號福州軟件園F區(qū)5號樓6-8層
法律狀態(tài) -

摘要

摘要 本發(fā)明涉及一種基于kafka實現(xiàn)穩(wěn)定的高吞吐量的異步任務處理方法。采用基于kafka的異步任務模式，對于異步任務的處理機制，采用管理線程來監(jiān)控工作線程的各種活動情況并結合定時任務來按照監(jiān)控間隔時間的頻率輸出異步任務的執(zhí)行情況，提供對于超時任務處理機制和異常任務處理機制，增加監(jiān)控任務消費情況，統(tǒng)計任務執(zhí)行時間、任務完成詳細情況，可通過統(tǒng)計情況來優(yōu)化調整參數(shù)，此統(tǒng)計信息會寫入日志，用戶可以通過日志來分析性能。本發(fā)明能夠大大降低系統(tǒng)于業(yè)務系統(tǒng)的耦合性。