PHP + Redis 实现简单消息队列
Redis做消息队列的好处在于它的轻量级,高并发,延迟敏感,应用场景有 即时数据分析、秒杀计数器、缓存等 Redis做消息队列待解决的问题: 1、消息的可靠性: 没有相应的机制保证消息的消费,当消费者消费失败的时候,消息体丢失,需要手动处理。生产者只管向队列中插入数据,不管消费者是否成功消费。 2、消费者挂掉消息不会丢失,但是需要重新触发一下消费者,才能够继续消费消息。 代码如下: lib.php是工具文件,里面有数据库的连接、Redis的连接: <?php /** * 获取数据库连接 * * @param $host * @param $username * @param $password * @param $database * @return mysqli */ function getDBConnection($host, $username, $password, $database){ $connection = new mysqli('p:'.$host, $username, $password, $database); if (!$co...













