基于kafka实现稳定的高吞吐量的异步任务处理方法
基本信息
申请号 | CN201910613837.6 | 申请日 | - |
公开(公告)号 | CN110377486B | 公开(公告)日 | 2022-07-08 |
申请公布号 | CN110377486B | 申请公布日 | 2022-07-08 |
分类号 | G06F11/30(2006.01)I;G06F9/48(2006.01)I | 分类 | 计算;推算;计数; |
发明人 | 胡玉煌;吴浩 | 申请(专利权)人 | 福建南威软件有限公司 |
代理机构 | 福州元创专利商标代理有限公司 | 代理人 | - |
地址 | 350003福建省福州市鼓楼区软件大道89号福州软件园F区5号楼6-8层 | ||
法律状态 | - |
摘要
摘要 | 本发明涉及一种基于kafka实现稳定的高吞吐量的异步任务处理方法。采用基于kafka的异步任务模式,对于异步任务的处理机制,采用管理线程来监控工作线程的各种活动情况并结合定时任务来按照监控间隔时间的频率输出异步任务的执行情况,提供对于超时任务处理机制和异常任务处理机制,增加监控任务消费情况,统计任务执行时间、任务完成详细情况,可通过统计情况来优化调整参数,此统计信息会写入日志,用户可以通过日志来分析性能。本发明能够大大降低系统于业务系统的耦合性。 |
