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

藏色散人
풀어 주다: 2023-04-11 08:22:02
앞으로
5308명이 탐색했습니다.

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

개념

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

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

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

적용 시나리오

  • Redundancy
  • Decoupling
  • Traffic peak shaving
  • Asynchronous communications

imple 멘션

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

메시지 트리거 메커니즘

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

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

  • 아키텍처 설계 1 예정된 작업 채택
    PHP 메시지 큐 구현 및 적용에 대한 자세한 설명(흐름도 포함)

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

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

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

  • 큐 데이터 구조를 사용

    • lpush/rpush를 사용하여 데이터를 목록에 넣습니다
    • lpop/rpop을 사용하여 목록에서 데이터를 제거하고 제거된 값을 가져옵니다
    • ltrim 예약됨 지정된 범위의 요소
    • llen 목록의 길이를 가져옵니다.
    • lset index
    • lindex로 목록의 값을 설정합니다. index
    • lrange로 목록의 값을 가져옵니다. 지정된 범위의 요소를 가져옵니다
  • 다이어그램은 다음과 같습니다
    PHP 메시지 큐 구현 및 적용에 대한 자세한 설명(흐름도 포함)

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

    • 플래시 킬 프로그램이 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는 소비자를 나타냅니다


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

      // 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 중국어 웹사이트의 기타 관련 기사를 참조하세요!

관련 라벨:
원천:learnku.com
본 웹사이트의 성명
본 글의 내용은 네티즌들의 자발적인 기여로 작성되었으며, 저작권은 원저작자에게 있습니다. 본 사이트는 이에 상응하는 법적 책임을 지지 않습니다. 표절이나 침해가 의심되는 콘텐츠를 발견한 경우 admin@php.cn으로 문의하세요.
최신 이슈
인기 튜토리얼
더>
최신 다운로드
더>
웹 효과
웹사이트 소스 코드
웹사이트 자료
프론트엔드 템플릿