基于PHP使用rabbitmq实现消息队列
2016-11-28 18:05
1006 查看
1.从github上面获取AMQP基于php的实现扩展
2.创建生产者 send.php
View Code
4.在cli模式下 分别执行 send.php receive.php 可以看到如下:
说明生产 消费端均ok。
5.管理 查看队列消息:安装rabbitmq_management插件
【5-1】查看当前可用插件:
【5-2】 安装启用 rabbitmq_management插件
【5-3】进入rabbitmq_management管理端:http://192.168.38.129:15672/
【5-4】 guest用户没有权限 需要授权
rabbitmqctl set_user_tags guest monitoring
rabbitmqctl set_user_tags guest management
【5-5】登陆成功
2.创建生产者 send.php
1 require(__DIR__ . '/../protected/vendor/autoload.php'); 2 3 use PhpAmqpLib\Connection\AMQPStreamConnection; 4 use PhpAmqpLib\Message\AMQPMessage; 5 6 $connection = new AMQPStreamConnection('192.168.38.129', 5672, 'fanwq', 'ysq'); 7 $channel = $connection->channel(); 8 9 $channel->queue_declare('hello', false, false, false, false); 10 echo ' [*] Waiting for messages. To exit press CTRL+C', "\n"; 11 $callback = function($msg) { 12 echo " [x] Received ", $msg->body, "\n"; 13 }; 14 15 $channel->basic_consume('hello', '', false, true, false, false, $callback); 16 17 while(count($channel->callbacks)) { 18 $channel->wait(); 19 }
View Code
4.在cli模式下 分别执行 send.php receive.php 可以看到如下:
说明生产 消费端均ok。
5.管理 查看队列消息:安装rabbitmq_management插件
【5-1】查看当前可用插件:
【5-2】 安装启用 rabbitmq_management插件
【5-3】进入rabbitmq_management管理端:http://192.168.38.129:15672/
【5-4】 guest用户没有权限 需要授权
rabbitmqctl set_user_tags guest monitoring
rabbitmqctl set_user_tags guest management
【5-5】登陆成功
相关文章推荐
- 基于PHP使用rabbitmq实现消息队列
- 基于PHP使用rabbitmq实现消息队列
- PHP中使用ActiveMQ实现消息队列
- 基于Python语言使用RabbitMQ消息队列(三)
- PHP中使用ActiveMQ实现消息队列
- 跨数据库分布式实时事务 - 基于RabbitMQ实时消息队列服务实现
- 使用PHP访问RabbitMQ消息队列
- PHP使用Redis实现消息队列
- 消息队列的使用 RabbitMQ (二): Windows 环境下集群的实现与优化
- php 消息队列 rabbitmq 的安装使用
- 使用Redis+php-resque实现消息队列
- 基于Python语言使用RabbitMQ消息队列(五)
- 基于Python语言使用RabbitMQ消息队列(二)
- 基于Python语言使用RabbitMQ消息队列(四)
- PHP基于Redis消息队列实现发布微博的方法
- PHP中使用ActiveMQ实现消息队列
- 使用PHP访问RabbitMQ消息队列的方法示例
- 基于Python语言使用RabbitMQ消息队列(六)
- 基于Python语言使用RabbitMQ消息队列(一)
- 使用PHP访问RabbitMQ消息队列