Tea9源码网 - 免费分享精品源码、教程、软件|全网干货资源收集,免费下载。

利用Redis实现消息队列

发布:吾爱破解论坛2021-8-30 16:45分类: PHP源码 标签: Redis 利用Redis实现消息队列 消息队列

什么是消息队列

消息队列(message queue) 可以分为两部分,即消息(message)与队列(queue),它是分布式系统中重要的组件,其通用的使用场景可以简单地描述为:

  1. 当不需要立即获得结果,但是并发量又需要进行控制的时候,差不多就是需要使用消息队列的时候。   
  2. 消息队列主要解决了应用耦合、异步处理、流量削锋等问题。   

当前使用较多的消息队列有RabbitMQ、RocketMQ、ActiveMQ、Kafka、ZeroMQ、MetaMq等,而部分数据库如Redis、Mysql以及phxsql也可实现消息队列的功能。

遇到的场景

在这里我遇到的场景是: 对于同步发信(点击按钮时立即发信)可能会造成响应过慢或同一时间请求量过大导致的QPS限制,为此我尝试用PHP+Redis设计了一个消息队列服务.

开始实现

消息队列的本质和队列结构类似,均为先进先出(FIFO),这里利用到的是redis的List(列表).利用lpush进行入队,然后通过rpop出队.

class Mq{
    public static $key = 'mq'; //Redis键名称
    function __construct(){
        $this->redis = new Redis(); 
        $this->redis->connect('127.0.0.1', 6379); //连接Redis
    } 

    public function push($str){
        $this->redis->lpush(self::$key,$str); //从队尾入队
    }

    public function push($str){
        $data = $this->redis->rpop(self::$key); //从队首出队并处理
        print_r($data);
        /* code */
    }
}
至此我们让Mq类中的push方法循环运行,便实现了一个最简单的消息队列服务,但是在实际过程中可能会遇到一些问题,比如循环运行push方法导致的负载高,对于这个问题,我们可以用brpop来缓解。

    public function push($str){
        while($data = $this->redis->brpop(self::$key),3600){ //从队首出队并处理
            print_r($data);
            /* code */
        }
    }
这里的3600代表超时时间,如果队列中一直没有数据,便会阻塞3600秒,当然我们也可以把这个值设置成0来无限阻塞,但是我们又遇到了一个问题,长时间的阻塞导致Redis自动断开了连接,这里可以试着在redis连接后使用$redis->setOption(3, -1);来将Redis的连接时间设置成永不超时.
温馨提示如有转载或引用以上内容之必要,敬请将本文链接作为出处标注,谢谢合作!

已有 2895 人阅读