redis实现简单的消息队列(php)

程序员文章站 2022-05-18 10:25:02

...

2019独角兽企业重金招聘Python工程师标准>>> redis实现简单的消息队列(php)

在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实现简单的消息队列(php)