hyperf-view/builder/Amqp

1.创建生产者:

php bin/hyperf.php gen:amqp-producer DemoProducer

2.创建消费者:

php bin/hyperf.php gen:amqp-consumer DemoConsumer

3.修改生产者的注解,例如:

两个注解最好都要修改

Producer(exchange: 'hyperf.exchange', routingKey: 'role.routing')

4.修改消费者的注解,例如:

两个注解最好都要修改

Consumer(exchange: 'hyperf.exchange', routingKey: 'role.routing', queue: 'role.queue', name: "role.queue", nums: 1)]

5.依赖注入延迟队列类

use Hyperf\Di\Annotation\Inject;
use Builder\Amqp\DelayProducer;
/**
* @Inject
* @var DelayProducer
*/
protected $producer;

6.进行调用

$message = new RoleProducer('message');
参数1:生产者对象 2:队列的是否确认机制 3:超时时间重试 (秒) 4:延迟时间 (秒) 如果为0或者不传,默认立即发送
$this->producer->produce($message,false,5,5);
其他的问题请见hyperf官方的AMQP模块文档