PHP 메시지 큐 구현 및 적용에 대한 자세한 설명(흐름도 포함)

                                                                                                               

메시지 큐의 개념, 원리 및 구현

개념

• 큐 구조의 미들웨어
• 메시지를 즉시 소비할 필요 없음
• 소비자 또는 구독자 순으로 소비

The 기본 흐름도는 다음과 같습니다

• Process
  

적용 시나리오

• Redundancy
• Decoupling
• Traffic peak shaving
• Asynchronous communications

imple 멘션

• mysql : 안정적이고 느림
• redis: 빠르지만 대용량 메시지 패킷 처리는 느림
• 메시지 시스템: 신뢰성, 고도로 전문적

메시지 트리거 메커니즘

• 무한 루프 방식, 실패는 적시에 복원될 수 없음
• 예약된 작업: 균등하게 분산된 압력이지만 처리 용량에 상한이 있음
• 데몬 접근 방식

디커플링(주문 및 배송 시스템)

• 아키텍처 설계 1 예정된 작업 채택
  

• 처리를 위해 유통 처리 시스템을 사용할 경우 현재 데이터베이스에서 처리해야 하는 주문의 상태를 2로 설정하고, 처리가 완료된 후 상태를 1로 설정합니다

• 매회 업데이트할 데이터 수를 지정할 수 있습니다

트래픽 샤프닝(redis는 플래시 판매를 구현함)

• 큐 데이터 구조를 사용

  • lpush/rpush를 사용하여 데이터를 목록에 넣습니다
  • lpop/rpop을 사용하여 목록에서 데이터를 제거하고 제거된 값을 가져옵니다
  • ltrim 예약됨 지정된 범위의 요소
  • llen 목록의 길이를 가져옵니다.
  • lset index
  • lindex로 목록의 값을 설정합니다. index
  • lrange로 목록의 값을 가져옵니다. 지정된 범위의 요소를 가져옵니다

• 다이어그램은 다음과 같습니다
  

• 코드 흐름은 다음과 같습니다

  • 플래시 킬 프로그램이 redis(uid, time)에 요청을 씁니다

  • redis 목록 저장 공간의 길이를 확인하세요. 10개 이상은 바로 폐기

  • redis 데이터를 무한 루프로 읽어서 데이터베이스에 저장

    // Spike.php 秒杀程序if(Redis::llen('lottery') <pre class="brush:php;toolbar:false">// Warehousing.php 入库程序while(true){
        $user = Redis::rpop('lottery');
        if (!$user || $user == 'nil') {
            sleep(2);
            continue;
        }
        $user_arr = explode($user, '%');
        $insert_user = [
            'uid' => $user_arr[0],
            'time' => $user_arr[1]
        ];
        $res = DB::table('lottery_queue')->insert($insert_user);
        if (!$res) {
            Redis::lpush('lottery', $user);
        }}

• 위 코드의 동시성이 너무 크면 과매도 상황이 발생합니다. 시간이 지나면 파일 잠금이나 Redis 분산 잠금을 사용하여 제어할 수 있습니다. 먼저 Redis 목록에 제품을 넣고 rpop을 사용하십시오. 얻을 수 없으면 품절되었음을 의미합니다. 구체적인 아이디어와 의사 코드는 다음과 같습니다

    // 先将商品放入redis中
    $goods_id = 2;
  
    $sql = select id,num from goods where id = $goods_id;
    $res = DB::select($sql);
    if (!empty($res)) {
        // 也可以指定多少件
        Redis::del('lottery_goods' . $goods_id);
        for($i=0;$i<pre class="brush:php;toolbar:false">  // 开始秒杀
    $count = Redis::rpop('lottery_goods' . $goods_id);
    if (!$count) {
        // 商品已抢完
        ...
    }
  
    // 用户抢购队列
    $user_list = 'user_goods_id_' . $goods_id;
    $user_status = Redis::sismember($user_list, $user_id);
    if ($user_status) {
        // 已抢过
        ...
    }
  
    // 将抢到的放到列表中
    Redis::sadd($user_list, $uid);
    $msg = '用户：' . $uid . '顺序' . $count;
    Log::info($msg);
    // 生成订单等
    ...
    // 减库存
    $sql = update goods set num = num -1 where id = $goods_id and num > 0; // 防止超卖
    DB::update($sql)
    // 抢购成功

rabbitmq

아키텍처 및 원리

• 여기서 P는 생산자를 나타내고 X는 스위치(채널)를 나타내며 C는 소비자를 나타냅니다

  
  
  간단하게 사용

    // Send.php
    require_once __DIR__.'/vendor/autoload.php';
  
    use PhpAmqpLib\Connection\AMQPStreamConnection;
    use PhpAmqpLib\Message\AMQPMessage;
  
    $connection = new AMQPStreamConnection('localhost', 5672, 'guest', 'guest');
  
    // 创建通道
    $channel = $connection->channel();
    // 声明一个队列
    $channel->queue_declare('user_email', false, false, false, false);
    // 制作消息
    $msg = new AMQPMessage('send email');
    // 将消息推送到队列
    $channel->basic_publish($msg, '', 'user_email');
  
    echo '[x] send email';
  
    $channel->close();
    $connection->close();

    // Receive.php
    require_once __DIR__.'/vendor/autoload.php';
  
    use PhpAmqpLib\Connection\AMQPStreamConnection;
    use PhpAmqpLib\Message\AMQPMessage;
  
    $connection = new AMQPStreamConnection('localhost', 5672, 'guest', 'guest');
  
    //创建通道
    $channel = $connection->channel();
  
    $channel->queue_declare('user_email', false, false, false, false);
  
    // 当收到消息时的回调函数
    $callback = function($msg){
        //发送邮件
        echo 'Received '.$msg->body.'\n';
    };
  
    $channel->basic_consume('user_email', '', false, true, false, false, $callback);
  
    // 保持监听状态
    while($channel->is_open()){
        $channel->wait();
    }

위 내용은 PHP 메시지 큐 구현 및 적용에 대한 자세한 설명(흐름도 포함)의 상세 내용입니다. 자세한 내용은 PHP 중국어 웹사이트의 기타 관련 기사를 참조하세요!