Redis应用实践-使用消息队列发布微博

水深无声 2022-05-30 03:44 126阅读 0赞

# 使用消息队列发布微博 #

有时候我们的应用中（如：微博）会出现这样的情况，一秒钟有很多用户同时发布消息。这个时候数据库Mysql可能会出现**“too many connections”**。碰到这个情况的时候，我们可能会是修改Mysql中的**max\_connections**的值为更大的值。不过后来经过搜索，发现这是一个并不太好的方法，治标不治本。后来使用的是Redis进行解决的。  
使用Redis的**List**类型作为消息队列，把用户发布的的消息暂时的存储到消息队列中，然后把消息队列中的数据插入数据库Mysql中。这样可以降低Mysql的并发量。

# 实例 #

##### 1.发布微博 #####

<?php //参数按照假设的方法,相关接口文档可以去微博开发平台查阅。 $uid = get_uid();//用户UID $content = get_content();//用户发布的内容 $timestamp = time();//发表时间 $weibo = new Weibo();//微博对象，post方法就是发布微博的接口 $weibo->post($uid,$content,$timestamp);

##### 2.降低数据库并发，将发布内容存储进Redis #####

<?php
        $redis = new Redis('127.0.0.1',6379);//创建Redis对象
        $redis->connect();//连接
    
        $weibo_info = array(
            'uid' = get_uid(),
            'content' = get_content(),
            'timestamp' = time(),
        );
    
        $redis->lpush('weibo_list',json_enccode($weibo_info));
        //使用json_encode()将信息编码为json格式，json是可存储格式，流行的编程语言都支持
        //然后使用redis的lpush()方法将信息插入创建的weibo_list队列
        $redis->close();

##### 3.将Redis中信息插入Mysql #####

<?php
        $redis = new Redis('127.0.0.1',6379);
        $redis->connect();
        $weibo = new Weibo();
    
        while(true){
            if($redis->lsize('weibo_list') > 0){
       //判断队列中是否还有任务
                $info = $redis->rpop('weibo_list');//使用rpop从队列中取出一条
                $info = json_decode($info);//进行json格式-》数组格解码
                $weibo->post($info->uid,$info->content,$info->timestamp);//调用post插入数据库
            }
        }else{
            sleep(l);//这个地方是为了如果队列中没有任务，就睡眠，让出CPU给其他进程
        }
        $redis->close();

如果并发量特别大的时候，可以利用Redis扩展性强的有点，将并发分发到不同服务器。