<?php
//redis数据入队操作
$redis = new Redis();
$hanedel=$redis->connect('127.0.0.1',6379);
$redis->auth("redis888");
if($hanedel){
echo 'redis服务器链接成功';
}else{
echo 'redis服务器无法链接';
exit;
}
for($i=0;$i<50;$i++){
try{
$redis->LPUSH('click',rand(1000,5000));
}catch(Exception $e){
echo $e->getMessage();
exit();
}
}
$redis->pconnect('127.0.0.1',6379);
$redis->auth("redis888");
while(true){
try{
$value = $redis->LPOP('click');
if(!$value){
break;
}
var_dump($value)."\n";
///利用$value进行逻辑和数据处理
}catch(Exception $e){
echo $e->getMessage();
exit();
}
}
?>
网友评论