admin_consumer/runtime/container/proxy/App_Amqp_Consumer_MqConsumer.proxy.php

<?php

declare (strict_types=1);
namespace App\Amqp\Consumer;

use Hyperf\Amqp\Result;
use Hyperf\Amqp\Annotation\Consumer;
use Hyperf\Amqp\Message\ConsumerMessage;
use Hyperf\Di\Annotation\Inject;
use PhpAmqpLib\Message\AMQPMessage;
use App\JsonRpc\ChatServiceInterface;
#[Consumer(exchange: 'hyperf', routingKey: 'hyperf', queue: 'hyperf', name: "MqConsumer", nums: 1)]
class MqConsumer extends ConsumerMessage
{
    use \Hyperf\Di\Aop\ProxyTrait;
    use \Hyperf\Di\Aop\PropertyHandlerTrait;
    function __construct()
    {
        if (method_exists(parent::class, '__construct')) {
            parent::__construct(...func_get_args());
        }
        $this->__handlePropertyHandler(__CLASS__);
    }
    /**
     * @var ChatServiceInterface
     */
    #[Inject]
    private $chatServiceClient;
    public function consumeMessage($data, AMQPMessage $message) : Result
    {
        //数据存储
        var_dump($data, $message->getBodySize());
        $result = $this->chatServiceClient->addTalkRecords($data);
        var_dump("消费成功：", $result);
        return Result::ACK;
    }
    //    public function isEnable(): bool
    //    {
    //        return false;
    //    }
}