买专利卖专利找龙图腾，真高效！ 查专利查商标用IPTOP,全免费！专利年费监控用IP管家,真方便！

龙图腾网获悉平安银行股份有限公司申请的专利海量数据处理方法方法和装置、电子设备及存储介质获国家发明授权专利权，本发明授权专利权由国家知识产权局授予，授权公告号为：CN119415288B 。

龙图腾网通过国家知识产权局官网在2026-02-10发布的发明授权授权公告中获悉：该发明授权的专利申请号/专利号为：202411549592.2，技术领域涉及：G06F9/54；该发明授权海量数据处理方法方法和装置、电子设备及存储介质是由龙涛设计研发完成，并于2024-10-31向国家知识产权局提交的专利申请。

本海量数据处理方法方法和装置、电子设备及存储介质在说明书摘要公布了：本申请实施例提供了一种海量数据处理方法和装置、电子设备及存储介质。该方法包括：获取若干个待处理的第一数据信息以及每个第一数据信息对应的标识号；根据预设的阻塞队列中的队列状态，将第一数据信息对应的标识号依次添加至阻塞队列中，并更新队列状态；按照阻塞队列的队列顺序，依次向预设的消息中间件的消息队列中推送标识号，并对阻塞队列和队列状态进行更新；根据消息队列中的标识号，将标识号对应的第一数据信息转换为第二数据信息；将若干个第二数据信息和对应的标识号推送至任务线程池中进行任务分配并处理。本申请实施例能够通过消息中间件协调任务分工，实现了对海量数据并行处理，提高了处理效率，且使用简单便于扩展。

本发明授权海量数据处理方法方法和装置、电子设备及存储介质在权利要求书中公布了：1.一种海量数据处理方法，其特征在于，所述方法包括： 获取若干个待处理的第一数据信息以及每个所述第一数据信息对应的标识号； 根据预设的阻塞队列中的队列状态，将所述第一数据信息对应的所述标识号依次添加至所述阻塞队列中，并更新所述队列状态，包括： 根据预设的消息中间件的消息队列的变化情况，得到任务线程池的处理速度；根据所述处理速度，调整将所述标识号添加至所述阻塞队列的进队速度；根据预设的阻塞队列中的队列状态，按照所述进队速度，将所述第一数据信息对应的所述标识号依次添加至所述阻塞队列中，并更新所述队列状态，包括： 将所述标识号添加至预设的阻塞队列中，更新所述阻塞队列对应的任务累计值；当所述任务累计值大于或等于预设的满载阈值，将所述阻塞队列的队列状态更新为忙碌状态； 按照所述阻塞队列的队列顺序，依次向预设的消息中间件的消息队列中推送所述标识号，并对所述阻塞队列和所述队列状态进行更新； 根据所述消息队列中的标识号，将所述标识号对应的所述第一数据信息转换为第二数据信息； 将若干个所述第二数据信息和对应的所述标识号推送至任务线程池中进行任务分配并处理；其中，所述任务线程池包括若干个任务处理线程，每个所述任务处理线程负责处理一个所述第二数据信息； 当所述任务处理线程未能完成对当前所述第二数据信息的数据处理，生成重试反馈信号和重试次数信息；其中，所述重试反馈信号包括当前所述第二数据信息对应的所述标识号；响应于所述重试反馈信号，重新将所述标识号对应的所述第二数据信息推送至任务线程池中进行任务分配并处理；当所述重试次数信息大于或等于预设的异常阈值，停止对所述第二数据信息进行任务分配，并对所述标识号生成异常标识； 其中，所述根据所述消息队列的变化情况，得到所述任务线程池的处理速度，包括： 将若干个所述第一数据信息对应的标识号标记为测试标记号；记录所述测试标记号进入所述消息队列的入队时间戳，以及所述测试标记号在所述消息队列中的出队时间戳；根据所述入队时间戳和所述出队时间戳，得到所述测试标记号对应的所述第一数据信息的第一处理时间；根据所有所述测试标记号对应的第一处理时间，得到平均处理时间；根据所述平均处理时间，得到所述任务线程池的处理速度。

如需购买、转让、实施、许可或投资类似专利技术，可联系本专利的申请人或专利权人平安银行股份有限公司，其通讯地址为：518000 广东省深圳市罗湖区深南东路5047号；或者联系龙图腾网官方客服，联系龙图腾网可拨打电话0551-65771310或微信搜索“龙图腾网”。

以上内容由龙图腾AI智能生成。