消息队列出现的原因

随着互联网的高速发展，门户网站、视频直播、电商领域等web应用中，高并发、大数据已经成为基本的标识。淘宝双11、京东618、各种抢购、秒杀活动、以及12306的春运抢票等，他们这些网站都有一个显著的特点：在短时间内，会涌现出大量的用户（高并发请求），导致并发访问量过大，超过了系统的最大负载能力。一方面可以通过增加服务器数量配置服务器集群实现均衡负载，另外一方面异步操作也被广泛采用。而异步操作中最核心的就是使用消息队列。

消息队列的优点

• 异步通信，可以向队列里放入很多消息，在你想要的时候再去处理队列消息。
• 保证数据的可靠性，消息队列把数据进行持久化直到它们已经被完全处理，通过这一方式规避数据丢失。消息数据处理的删除是在已经确认处理成功后才会删除。
• 灵活性和可扩展性以及高并发处理能力，消息队列可以缓解数据处理过程，可以动态扩展多系统来处理消息数据。
• 减少系统相关耦合度，保证了可恢复性。比如生成订单和处理订单，处理系统可以相互独立，当体系的一部分组件失效也不会影响到整个系统。

消息队列之redis的简单应用

结合php，实现redis消息队列的简单应用，主要用到redis三个命令：zAdd、zRange、zDelete。关于这三个命令的含义在此就不再赘述了。

入库操作：

<?php

if(!extension_loaded('redis')){

        exit('redis extension is not install!');

}

    $redis = new Redis();

    $redis->connect('127.0.0.1',6379,300);

    $redis->zAdd("order_queue",time(),'11111');

    $redis->zAdd("order_queue",time(),'22222');

    $redis->zAdd("order_queue",time(),'33333');

    $redis->zAdd("order_queue",time(),'44444');

    $redis->zAdd("order_queue",time(),'55555');

    $arr =$redis->zRange("order_queue",0,$redis->zCard("order_queue"));

    print_r($arr);

打印出：

Array

(

    [0] => 11111

    [1] => 22222

    [2] => 33333

    [3] => 44444

    [4] => 55555

)

出库操作：

<?php

$redis = new Redis;

$redis->connect('127.0.0.1',6379,300);

$curvalue = $redis->zRange("order_queue",0,0);

echo "当前值:{$curvalue[0]}\n";

$res=true;

if($res){

        $redis->zDelete("order_queue",$curvalue[0]);

        echo "队列操作成功\n";

}else{

        echo "队列操作失败\n";

}

打印出：

当前值:11111

队列操作成功