# composer.json { "require": { "php-amqplib/php-amqplib": ">=2.9.0" } }
> composer.phar install
# send.php <?php require_once __dir__ . '/vendor/autoload.php'; use phpamqplib\connection\amqpstreamconnection; use phpamqplib\message\amqpmessage; $connection = new amqpstreamconnection('localhost', 5672, 'guest', 'guest'); // 创建通道 $channel = $connection->channel(); // 创建队列 $channel->queue_declare('hello', false, false, false, false); $msg = new amqpmessage('hello world!'); // 通过默认的交换机发送消息到队列 (消息内容, 默认交换机, 路由键); $channel->basic_publish($msg, '', 'hello'); echo " [x] sent 'hello world!'\n"; $channel->close(); $connection->close();
# receive.php <?php require_once __dir__ . '/vendor/autoload.php'; use phpamqplib\connection\amqpstreamconnection; $connection = new amqpstreamconnection('localhost', 5672, 'guest', 'guest'); $channel = $connection->channel(); $channel->queue_declare('hello', false, false, false, false); echo " [*] waiting for messages. to exit press ctrl+c\n"; $callback = function ($msg) { echo ' [x] received ', $msg->body, "\n"; }; $channel->basic_consume('hello', '', false, true, false, false, $callback); while ($channel->is_consuming()) { $channel->wait(); } $channel->close(); $connection->close();
# shell 1 php receive.php # shell 2 php send.php
# linux sudo rabbitmqctl list_queues # windows rabbitmqctl.bat list_queues
如对本文有疑问, 点击进行留言回复!!
去 HBase,Kylin on Parquet 性能表现如何?
如何找到Hive提交的SQL相对应的Yarn程序的applicationId
如何在 HBase Shell 命令行正常查看十六进制编码的中文?哈哈~
网友评论