Yii2整合RabbitMQ

Yii2整合RabbitMQ

在这里用Yii2.0 advanced版本整合rabbitmq,并用rabbitmq的简单模式作为测试。

1、既然是yii,那就使用composer安装依赖包

composer require php-amqplib/php-amqplib  2.9.*

注意:对于php-amqplib>2.6.0的版本,有可能在下载的过程中报错,这里要确保php.ini中的php_sockets扩展前面的;是去掉了的

 

2、代码编写

无需在配置文件中做任何配置,代码编写在consolecontrolles下

发送消息

 

接收消息

 

3、控制台测试

    yii receive/index 消费者在相应的队列处监听:

    

   yii send/index 生产者往队列里发布消息

  

  消费者接收到消息并进行处理

    

 

 

 

原文地址:https://www.cnblogs.com/hld123/p/12745274.html