首页 > 技术文章 > php实现简单的消息队列

echoou 2021-06-09 10:18 原文

生产者

<?php
$redis = new Redis();

$redis->connect('127.0.0.1',6379);
$redis->auth("123456");

$redis->rpush('queue_list_test',time());

消费者


<?php
ini_set('default_socket_timeout', -1); //不超时

$redis = new Redis();

$redis->connect('127.0.0.1',6379);
$redis->auth("123456");

while($message = $redis->brpop('queue_list_test',0)) {
    var_dump($message);
}

推荐阅读