Redis をメッセージキューとして使用できますか?-Redis-php.cn

Redis をメッセージキューとして使用できますか?

尚

リリース： 2019-07-05 15:31:48

オリジナル

3954 人が閲覧しました

Redis をメッセージキューとして使用できますか?

アプリケーションシナリオ:

たとえば、フラッシュセール。大量の注文が瞬時にデータベースに書き込まれ、データベースが時間内に応答できなくなります。現時点では、Redis をメッセージキューとして使用し、最初に書き込む必要があるすべてのデータを Redis メッセージキューに書き込んでから、サーバー上で php-cli プロセスを開始してキュー内のデータをループで読み取ることができます。そしてそれをデータベースに非同期で書き込みます。 Redis をメッセージキューとして使用すると、メッセージ受信の確認メカニズムがないため、メッセージが失われる可能性があります。大規模なプログラムでは、RabitMQ などを専門的なメッセージキューとして使用する必要があります。

1. パブリッシュ/サブスクライブメソッドをメッセージキューとして使用する

特徴: 1 つのメッセージパブリッシャー (プロデューサー) が複数のメッセージサブスクライバー (コンシューマー) に対応できます。メッセージがメッセージキューにパブリッシュされると、すべてのメッセージサブスクライバーがメッセージを受信できます。分散メッセージの配信に適しています。クライアントは、ブロッキング方式でパブリッシュ側からのメッセージを待ちます。複数のコンシューマーがメッセージの消費を高速化することはできません。

メッセージ生成:

$params =json_encode([&#39;x_uid&#39; => $x_uid, &#39;phone&#39; => $phone]);
$redis->publish(&#39;test&#39;,$params); //test表示发布的频道名字

ログイン後にコピー

メッセージ消費 (php-cli モード操作):

$redis = new Redis(); $redis->pconnect(&#39;127.0.0.1&#39;); //必须用pconnect长连接
//设置redis连接永远不超时。默认60s超时断开连接 $redis->setOption(Redis::OPT_READ_TIMEOUT, -1);
 
$redis->subscribe(array(&#39;test&#39;), &#39;callback&#39;); //test表示频道名字，callback 回调函数名
functioncallback($redis, $chan, $msg){ //对收到的消息进行处理函数
$params = json_decode($msg,true);
....
}

ログイン後にコピー

pconnect と connect の違い:

connect: connect afterスクリプトが終了してリリースされました。

pconnect: スクリプトの終了後も接続は解放されず、接続は php-fpm プロセスに残ります。

したがって、connect の代わりに pconnect を使用すると、頻繁に確立される Redis 接続の消費量を削減できます。

2. Redis メッセージキューとしてリストを使用する

特徴: メッセージプロデューサーはメッセージコンシューマーに対応します。複数のコンシューマを使用すると、メッセージの消費を高速化できます。

メッセージ生成:

$redis =newRedis();
$redis->connect(&#39;127.0.0.1&#39;); 
//将需要写入数据库的数据全部push到队列（复杂数据可以先json编码成字符串）
$list = json_encode([&#39;x_uid&#39; => $x_uid, &#39;phone&#39; => $phone, &#39;goods_id&#39; => $goodsId, 
&#39;add_time&#39; => time(), &#39;num_field&#39; => $num_field]);
$redis->lpush(&#39;winer&#39;,$list);

ログイン後にコピー

注: brpop 消費データがデータベースに正常に書き込まれない場合、データ損失が発生します。本番データが強く必要な場合は、Redis またはファイルにセカンダリバックアップを実行する必要があります。

メッセージ消費 (php-cli モード操作):

注: MySQL が接続を積極的に閉じない場合、接続は最大 8 時間後に自動的に切断されます。

<?php
//链接数据库
$conn = mysqli_connect("localhost","root","root");
if(!$conn){
die("连接数据库失败：". mysqli_error());
}
mysqli_select_db($conn,"api");
//字符转换，读库
mysqli_query($conn,"set character set &#39;utf8&#39;");
//写库
mysqli_query($conn,"set names &#39;utf8&#39;");
 
//连接本地的 Redis 服务
$redis =newRedis();
$redis->connect(&#39;127.0.0.1&#39;,6379);
//设置redis连接永远不超时。默认60s超时断开连接
$redis->setOption(Redis::OPT_READ_TIMEOUT,-1);
echo &#39;Listening...&#39;;
$i =1;
while(true){
$data = $redis->brpop(&#39;winer&#39;,0); // 0表示没有接收到参数的情况下，永远不超时断开
$info = json_decode($data[1],true);
$x_uid = $info[&#39;x_uid&#39;];
$phone = $info[&#39;phone&#39;];
$goods_id = $info[&#39;goods_id&#39;];
$add_time = $info[&#39;add_time&#39;];
$num_field = $info[&#39;num_field&#39;];
//将数组写入数据库、订单
$sql = "insert into hd_hengda11_order (`x_uid`,`phone`,`goods_id`,`add_time`) 
values ($x_uid,$phone,$goods_id,$add_time)"
$re = mysqli_query($conn,$sql);

echo $i.&#39;_ok||&#39;;
$i++;
}
?>

ログイン後にコピー

その他:

製品の売れすぎを防ぐためのフラッシュセールシナリオ:

1. データベース内の製品数量を符号なしに設定します。つまり、負の数値は許可されません。商品数量が負の数に更新された場合、false が返されます。

2. 商品の数量は Redis リストのキューに格納され、ラッシュが発生するたびにキューから要素がポップされます。

//存放商品数量的队列
for($j =1; $j <=10; $j++){ /设置商品数量为10
$re =Redis::lpush(gooods_count,1);
}

ログイン後にコピー

製品数量ロジックの判断

$count=Redis::lpop(&#39;gooods_count&#39;);
//$count = Redis::llen(&#39;gooods_count&#39;); //llen判断队列长度
if(!$count){
return&#39;已经抢光了哦&#39;;
}

ログイン後にコピー

Redis 関連の知識の詳細については、Redis 使用法チュートリアル列を参照してください。

以上がRedis をメッセージキューとして使用できますか?の詳細内容です。詳細については、PHP 中国語 Web サイトの他の関連記事を参照してください。