PHPにおけるredisによるメッセージキュー処理高同時要求の実現--簡潔なコード実現効果
redis
, for
//redis
$redis = new Redis();
$redis->connect('127.0.0.1',6379);
for($i=0;$i<50;$i++){
try{
$redis->LPUSH('click',rand(1000,5000));
}catch(Exception $e){
echo $e->getMessage();
}
}
//redis , redis
$redis = new Redis();
$redis->pconnect('127.0.0.1',6379);
while(true){
try{
$value = $redis->LPOP('click');
if(!$value){
break;
}
//var_dump($value)."
";
/*
* $value
*/
}catch(Exception $e){
echo $e->getMessage();
}
}
: