admin_consumer/app/Amqp/Producer/MqProducer.php

<?php

declare (strict_types = 1);

namespace App\Amqp\Producer;

use Hyperf\Amqp\Annotation\Producer;
use Hyperf\Amqp\Message\ProducerMessage;

#[Producer(exchange: 'chatprod', routingKey: 'chatprod')]
class MqProducer extends ProducerMessage
{
    public function __construct($data)
    {
//        $this->poolName = 'default';
        var_dump($data, '生产者数据');

        $this->payload = $data;
    }
}