一种基于数据库的轻量级消息队列实现方法及存储设备

摘要

本发明涉及消息处理技术领域，特别涉及一种基于数据库的轻量级消息队列实现方法及存储设备。所述一种基于数据库的轻量级消息队列实现方法，包括步骤：创建数据库表；接收请求操作，并根据请求操作更新消息表；启动本地消息监听程序，若监听到存在未处理的消息，则对对应的未处理的消息在数据库中写入消费占用标注；推送标注成功的消息至本地消费队列；启动本地消费线程，监听本地消费队列，若存在待消费的消息，则获取消息并进行消费；消费结束后，更新消息状态。本发明的技术方案采用基于数据库表的消息处理方式，整个消息的生产、消费过程无需使用MQ中间件作为媒介，降低了硬件环境、系统环境的各项配置要求，实现轻量级消息队列的功能。