生产者
<?php
$redis = new Redis();
$redis->connect('127.0.0.1', 6379);
$data = ['ti
// 生产者从列表右侧rpush加入消息到队列
$result = $redis->rpush("queue", json_encode($data));
if ($result) {
echo "写入队列成功";
}
消费者【linux下需要将消费者文件设置为常驻进程运行】
<?php
$redis = new Redis();
$redis->connect('127.0.0.1', 6379);
while(true){
$result = $redis->lpop("queue");
if ($result) {
$data = json_decode($result, true);
print '<pre>';
print_R($data);
}
}
欢迎大家访问我的博客:http://www.phpshizhan.com
