问一个rabbitmq的问题没有加入队列和消费

lijizheng 的个人博客 / 0 / 10 / 创建于 1年前

框架hyperf 按照插件composer require hyperf/amqp

问一个rabbitmq的问题没有加入队列和消费
有哪位大神知道是为啥吗求解，第一次玩rabbitmq 方法都试完了看日志也不报错

本作品采用《CC 协议》，转载必须注明作者和本文链接

lijizheng

课程读者 102 声望

会写bug，也会改bug

0 人点赞

从小程序个人账户申请开始，带你一步步进行开发一个微信小程序，直到提交微信控制台上线发布。

我们将带你从零开发一个项目并部署到线上，本课程教授 Web 开发中专业、实用的技能，如 Git 工作流、Laravel Mix 前端工作流等。

讨论数量: 10

kolin

130 声望

消费者那里注解不用写两次如果你是php8用原生的注解就好了贴的信息太少其他的没看出啥问题可以先按照文档写个demo试一下正不正常

1年前评论

lijizheng （楼主）

为啥要把注释取消掉，目前还没有试晚上回去试试

kolin （作者）

@lijizheng 你贴图那里不是写了两次注解么写一个就好了

lijizheng

课程读者 102 声望

file @kolin 两个注释是只需要一个吗？

1年前评论

kolin

是啊定义一个就好了

lijizheng （作者）（楼主）

额哦

lijizheng

课程读者 102 声望

<?php

declare(strict_types=1);

namespace App\Amqp\Consumer;

use App\Model\Customer; use App\Model\CustomerAddress; use Hyperf\Amqp\Result; use Hyperf\Amqp\Annotation\Consumer; use Hyperf\Amqp\Message\ConsumerMessage; use Hyperf\DbConnection\Db; use PhpAmqpLib\Message\AMQPMessage; use Hyperf\Logger\LoggerFactory; use Ramsey\Uuid\Uuid;

/**

@Consumer(exchange="customer", routingKey="customer", queue="customer", name="CustomerConsumer", nums=1)

/ class CustomerConsumer extends ConsumerMessage { private $logger;

public function __construct(LoggerFactory $loggerFactory) {

  $this->logger = $loggerFactory->get('rabbitmq');

}

public function consumeMessage($data, AMQPMessage $message): string {

  Db::beginTransaction();
  try {
      if(!Customer::query()->where('ios_guid',$data['ios_guid'])->exists()){
          $customer=new Customer();
          $customer->Guid=Uuid::uuid4()->getHex();
          $customer->ios_guid=$data['ios_guid'];
          $customer->Name=$data['name'];
          $customer->Email=$data['email'];
          $customer->Phone=$data['phone'];
          $customer->company_name=$data['company_name'];
          $customer->equipment_no=$data['equipment_no'];
          $customer->tax_number=$data['tax_number'];
          $customer->selling_price=$data['selling_price'];
          $customer->remark=$data['remark'];
          $customer->is_ipad=$data['is_ipad']??1;
          $customer->save();
      }else{
          Customer::query()
              ->where('ios_guid',$data['ios_guid'])
              ->update([
                  'ios_guid'=>$data['ios_guid'],
                  'Name'=>$data['name'],
                  'Email'=>$data['email'],
                  'Phone'=>$data['phone'],
                  'company_name'=>$data['company_name'],
                  'equipment_no'=>$data['equipment_no'],
                  'tax_number'=>$data['tax_number'],
                  'selling_price'=>$data['selling_price'],
                  'remark'=>$data['remark'],
                  'is_ipad'=>$data['is_ipad']??1,
              ]);
      }
      if($customer){
          if(!CustomerAddress::query()
              ->where('CustomerGuid',$customer->Guid)
              ->exists()){
              $customeraddress=new CustomerAddress();
              $customeraddress->Guid=Uuid::uuid4()->getHex();
              $customeraddress->CustomerGuid=$customer->Guid;
              $customeraddress->Address1=$data['address'];
              $customeraddress->City=$data['city'];
              $customeraddress->Province=$data['province'];
              $customeraddress->CreateTime=date('Y-m-d H:i:s',time());
              $customeraddress->save();
          }else{
              CustomerAddress::query()
                  ->where('CustomerGuid',$customer->Guid)
                  ->update([
                      'CustomerGuid'=>$customer->Guid,
                      'Address1'=>$data['address'],
                      'City'=>$data['city'],
                      'Province'=>$data['province'],
                      'CreateTime'=>date('Y-m-d H:i:s',time())
                  ]);
          }
      }
      Db::commit();
      $this->logger->info('Received and processed message:成功');
      return Result::ACK;
  }catch (\Exception $exception){
      Db::rollBack();
      $this->logger->info('Received and processed message:'.$exception->getMessage());
      return Result::DROP;
  }