RabbitMq初探——Hello World
阿新 • • 發佈:2017-10-18
req don world 內部 echo heap dir hello clas
HelloWorld
前言
這裏我們弱化broker內部構造。將整體分為三部分。
P:producer。生產者。
C:Consumer。消費者。
queue:隊列。
後面的代碼都依賴於 the php-amqplib API
composer安裝php-amqplib
1. 新建composer.json
{ "require": { "php-amqplib/php-amqplib": ">=2.6.1" } }
2. composer.phar install
Hello World
talk is cheap , show you the code
sender.php
require_once __DIR__ . ‘/vendor/autoload.php‘; use PhpAmqpLib\Connection\AMQPStreamConnection; use PhpAmqpLib\Message\AMQPMessage; $connection = new AMQPStreamConnection(‘127.0.0.1‘, 5672, ‘guest‘, ‘guest‘); $channel = $connection->channel(); $channel->queue_declare(‘hello‘, false, false, false, false); $data = implode(" ", array_slice($argv, 1)); empty($data) && $data = "Hello World!"; $msg = new AMQPMessage($data); $channel->basic_publish($msg, ‘‘, ‘hello‘); echo " [x] Sent ‘$data‘\n"; //close the channel and connection; $channel->close(); $connection->close();
receive.php
require_once __DIR__ . ‘/vendor/autoload.php‘; use PhpAmqpLib\Connection\AMQPStreamConnection; $connection = new AMQPStreamConnection(‘127.0.0.1‘, 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"; sleep(substr_count($msg->body, ‘.‘)); echo "[x] Done\n"; }; $channel->basic_consume(‘hello‘, ‘‘, false, true, false, false, $callback); while(count($channel->callbacks)) { $channel->wait(); }
執行
打開兩個終端,分別執行兩個腳本。
終端一:
終端二:
終端一收到終端二發送的消息。
RabbitMq初探——Hello World