redis+php实现队列代码

浏览:414 发布日期:2020/02/04 分类:用法示例
php结合redis实现消息不可靠队列系统
生产者
<?php
$redis = new Redis();
$redis->connect('127.0.0.1', 6379);

$data = ['title' => '你好'];
// 生产者从列表右侧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
评论( 相关
后面还有条评论,点击查看>>
五分时时彩 幸运飞艇官网 快乐赛车官网 澳洲幸运10开奖结果 德国时时彩 欢乐生肖 快乐赛车官网 优优彩票APP 欢乐生肖 PK10牛牛