那啥啥啥，小项目，完全可以就地取材，MySQL 也可以很好地实现消息队列的。。。反正我们小项目都用 MySQL 做消息队列了，多一个组件，多一份危险；大项目再上 MQ，保证 MQ 的高可用性需要花很多精力的。

假设数据表 tab_task 大致这样的：
seq_id, is_active, create_time, update_time

其中 is_active = 0 标示待消费的，is_active = 1 表示正在被处理，is_active = 2 标示已经处理好的。

--------------------------------------------------
正常消费线程，获取一个待处理任务（在一个事务中执行）：

UPDATE tab_task SET `is_active` = 1 AND `seq_id` = LAST_INSERT_ID(`seq_id`)
WHERE AND `is_active` = 0
ORDER BY `seq_id` ASC LIMIT 1;

SELECT * FROM tab_task
WHERE ROW_COUNT() > 0 AND `seq_id` = LAST_INSERT_ID();

----------------------------------------------------

定期检查超时的任务，然后发送报警，获取一个超时的任务（假设超时时间为 5 分钟）：

SELECT * FROM tab_task
WHERE is_active = 1 AND NOW() > DATE_ADD(`update_time`, INTERVAL 5 MINUTE)


--------------------------------------------------