PHP中利用redis实现消息队列

Posted on |

在电商活动中，常常会出现高并发的情况，例如很多人同时点击购买按钮，以至于购买人数超出了库存量，这是一种非常不理想的状况，因此，我们在PHP开发中就会引入消息队列来解决这种高并发的问题。

将请求存入redis

当用户点击抢购按钮时，我们通过ajax将请求发给php进行处理，前台返回给用户正在处理的提示（当然，这种提示让设计师设计出让用户满意的效果）。

1
2
3
4
5
6
7
$redis = new Redis();
$redis->connect('127.0.0.1',6379);
try{
    $redis->LPUSH('click',$user_id);
}catch(Exception $e){
    echo $e->getMessage();
}

在后台进行数据处理

守护进程

当上述请求存入redis后，就可以直接将结果返回给用户了。我们需要在服务端创建一个后台运行的程序，从redis中取出请求数据，并利用这些数据读取和更新数据库。但是这一切都是后台运行解决的，而非用户请求触发的。

从redis中将请求取出

通过上面的代码，redis中会存储很多请求，这些请求都是准备用来处理的。这个列队已经存在了之后，再服务器后台，则对这些请求进行处理，第一步就是先从redis中逐一取出请求。

1
2
3
4
5
6
7
8
9
10
11
12
$redis = new Redis();
$redis->pconnect('127.0.0.1',6379);
while(True){
    try{
        $value = $redis->LPOP('click');
        /*
         *  利用$value进行逻辑和数据处理
         */
    }catch(Exception $e){
        echo $e->getMessage();
    }
}

数据处理：长连接与事件

为了保证数据处理正常进行，必须和数据库之间建立长连接，因此上面我们采用了pconnect。在于mysql连接时，也要采用长连接，保证数据处理的有效性。同时，由于在后台运行，我们不可能随时获取数据库操作的状态，因此，我们最好采用innodb引擎，对数据库操作事件进行监听，如果出现了异常，要对事件结果进行检查，如果数据插入失败，应该重新执行该事件。

本文转自：http://www.tangshuang.net/100.html