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

龙图腾网恭喜北京秒针人工智能科技有限公司申请的专利基于消息队列的数据库写入调度器、写入方法和存储介质获国家发明授权专利权，本发明授权专利权由国家知识产权局授予，授权公告号为：CN113010297B 。

龙图腾网通过国家知识产权局官网在2025-03-07发布的发明授权授权公告中获悉：该发明授权的专利申请号/专利号为：202110443466.9，技术领域涉及：G06F9/48；该发明授权基于消息队列的数据库写入调度器、写入方法和存储介质是由夏锦阳设计研发完成，并于2021-04-23向国家知识产权局提交的专利申请。

本基于消息队列的数据库写入调度器、写入方法和存储介质在说明书摘要公布了：本申请涉及一种基于消息队列的数据库写入调度器、写入方法和存储介质，其中，该写入调度器包括：优先级确定模块，根据数据对实时性的敏感指数设置不同的优先级；批次大小确定模块，根据数据的优先级设置不同的消息队列，并确定对应消息队列的批次大小；线程管理模块，管理一数据库的并发线程并设置并发线程上限；数据写入模块，将数据写入对应消息队列，并经对应消息队列根据批次大小在线程管理模块管理下批量写入数据库。通过设置批次大小、最大消费时间和并发线程上限，实现请求并发和处理速度矛盾时的均衡策略，通过批次大小和最大等待时间两个维度的控制，提高了系统服务的稳定性，提升了处理速度。

本发明授权基于消息队列的数据库写入调度器、写入方法和存储介质在权利要求书中公布了：1.一种基于消息队列的数据库写入调度器，其特征在于，包括：优先级确定模块，根据数据对实时性的敏感指数设置不同的优先级，用于入库速度调度，数据对实时性的敏感指数显示数据对于实时性的敏感程度，将数据的实时性的敏感程度与写入数据的次序相关，当资源紧张时，优先将优先级高的数据进行处理，均衡并发请求数和处理速度；批次大小确定模块，根据所述数据的优先级设置不同的消息队列，并确定对应所述消息队列的批次大小；线程管理模块，管理一数据库的并发线程并设置并发线程上限；数据写入模块，将所述数据写入对应所述消息队列，并经对应所述消息队列根据所述批次大小在所述线程管理模块管理下批量写入所述数据库；时间均衡模块，所述时间均衡模块设置一最大消费时间，当所述消息队列的消息数大于所述批次大小时，触发写入动作；当所述消息队列的消息数小于所述批次大小时，等待至所述最大消费时间，触发所述写入动作；异步计算模块，所述数据经所述消息队列并发进入所述数据库，当所述数据库的请求并发量到达并发请求上限，处理速度也达到上限时，根据所述数据对实时性的敏感指数设定数据处理的优先级；其中，所述数据写入所述消息队列的频率与所述数据库的写入速度一致；其中，所述数据库具体设置为ElasticSearch；其中，消息队列设置为Kafka，对待写入数据库ElasticSearch的数据进行暂存，并通过统一的消费程序，实现写入数据库ElasticSearch数据的时间纬度上的调度控制。

如需购买、转让、实施、许可或投资类似专利技术，可联系本专利的申请人或专利权人北京秒针人工智能科技有限公司，其通讯地址为：100010 北京市石景山区石景山路68号冬训中心冰壶馆一层A108；或者联系龙图腾网官方客服，联系龙图腾网可拨打电话0551-65771310或微信搜索“龙图腾网”。