Redis를 메시지 대기열로 사용할 수 있나요?

적용 시나리오:

예: 반짝 세일. 대량의 주문이 즉시 데이터베이스에 기록되어 데이터베이스가 제때에 응답할 수 없게 됩니다. 이때 Redis를 메시지 큐로 사용하고, 먼저 Redis 메시지 큐에 써야 하는 모든 데이터를 쓴 다음 서버에서 php-cli 프로세스를 시작하여 루프에서 큐에 있는 데이터를 읽을 수 있습니다. 그리고 비동기적으로 데이터베이스에 씁니다. Redis를 메시지 대기열로 사용하면 메시지 수신에 대한 확인 메커니즘이 없기 때문에 메시지 손실이 발생할 수 있습니다. 대규모 프로그램은 RabitMQ와 같은 것을 전문적인 메시지 대기열로 사용해야 합니다.

1. 게시/구독 방법을 메시지 대기열로 사용

특징: 메시지 게시자(생산자)는 여러 메시지 구독자(소비자)에 대응할 수 있습니다. 메시지가 메시지 대기열에 게시되면 모든 메시지 구독자가 메시지를 받을 수 있습니다. 분산 메시지 배포에 적합합니다. 클라이언트는 차단 방식으로 게시 측의 메시지를 기다립니다. 여러 소비자가 메시지 소비 속도를 높일 수는 없습니다.

메시지 생성:

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

메시지 소비(php-cli 모드 작업):

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

pconnect와 connect의 차이점:

connect: 스크립트가 끝난 후 연결이 해제됩니다.

pconnect: 스크립트가 끝난 후에도 연결이 해제되지 않으며 연결은 php-fpm 프로세스에 남아 있습니다.

따라서 connect 대신 pconnect를 사용하면 redis 연결을 자주 설정하는 데 드는 소비를 줄일 수 있습니다.

2. 목록을 redis 메시지 대기열로 사용

특징: 메시지 생성자는 메시지 소비자에 해당합니다. 여러 소비자가 메시지 소비 속도를 높일 수 있습니다.

메시지 생성:

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

참고: brpop 소비 데이터가 데이터베이스에 성공적으로 기록되지 않으면 데이터 손실이 발생합니다. 프로덕션 데이터가 강력히 필요한 경우 Redis 또는 파일에 2차 백업을 수행해야 합니다.

메시지 소비(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('gooods_count');
//$count = Redis::llen('gooods_count'); //llen判断队列长度
if(!$count){
return'已经抢光了哦';
}

Redis 관련 더 많은 지식은 Redis 사용법 튜토리얼 칼럼을 참고해주세요!

위 내용은 Redis를 메시지 대기열로 사용할 수 있나요?의 상세 내용입니다. 자세한 내용은 PHP 중국어 웹사이트의 기타 관련 기사를 참조하세요!