在SNS中，经常出现1秒钟上万个用户同时发布消息的情况，如果在这种情况下使用mysql很有可能出现"too many connections"的错误，而且使用mysql写大量数据的时候，往往效率并不是特别高。这种情况下就可以使用redis的List类型作为消息队列，把用户发布的消息暂时存储在消息队列中，接下来使用一个cron程序把消息队列中消息插入到mysql，这样就有效的降低mysql的并发量。

下面写两个简单的页面模拟消息的发布，以及消息的存储。

$redis = new Redis;$redis->connect('127.0.0.1');$redis->auth('rainn1234');$article = get_article();$redis->rpush('article',json_encode($article));function get_article(){    $shuffle = "abcdefghigklmnopqrstuvwxyz1234567890";    $title   = substr(str_shuffle($shuffle), 0,6);    $content = substr(str_shuffle($shuffle), 6);    $time    = 1420000000 + rand(1,10000000);    return array('title' => $title, 'content' => $content, 'time' => $time);}$redis->close();

消息的内容都是随机获取的，只是为了简单模拟获取消息的过程。以上代码获取消息内容，并将内容转化为json后存储在redis的List中。

下面是一个从List中获取消息，并存到mysql中，为了方便也粗略写出。

$pdo = new PDO("mysql:host=localhost;dbname=1xin","root","root");$redis = new Redis;$redis->connect('127.0.0.1');$redis->auth('rainn1234');while(true){	if ($info = $redis->lpop('article')){		$article = json_decode($info,true);		$sql = "INSERT INTO `test`(`title`,`content`,`time`)                 VALUES('{$article['title']}','{$article['content']}',{$article['time']})";		$pdo->exec($sql);	} else {		sleep(1);		//队列中没有消息时，睡眠1s，让出cpu给其他进程	}}$pdo->close();$redis->close();

以上代码可以由cron代码执行，从redis的List中判断是否存在待写入mysql的文章，没有则睡眠1秒。

由测压工具模拟访问第一个文件:

在redis-cli中执行 lrange article 0 -1:

可以看到执行过程中是有存储消息的，然而最终却没有了，查看mysql，里面已经有数据了，随机查看上图中的几条，看看是否存在:

数据全部存在，消息队列实现。

以上只是消息队列原理，实际应用中肯定还会有诸多限制，我这里只是抛砖引玉，希望大家能有更多更好的实现方式。