基于缓存机制和多线程的消息数据消费方法及装置
Abstract:
本申请提供一种基于缓存机制和多线程的消息数据消费方法及装置,根据预先设定的线程数对消息数据进行任务拆分,得到多份任务数据,并将该多份任务数据进行线程分发,将消息数据拆分至多线程进行处理,提高了数据处理的效率。在任一线程中,会基于数据字典中预设的判定条件,对输入的任务数据进行过滤,得到类线性数据或非类线性数据,若得到类线性数据,对类线性数据进行业务逻辑处理,得到处理数据,并将处理数据存入存储中心;若得到非类线性数据,直接将非类线性数据存入存储中心;将数据分配给不同的线程进行异步处理,将接收到的任务数据与数据字典进行比对,一次性实现异步类线性数据的处理,从而提高数据的处理效率。
Public/Granted literature
Patent Agency Ranking
0/0