RabbitMq學習2-php命令行模式測試rabbitmq

1、RabbitMQ結構

一、幾個概念說明：

      Broker：簡單來講就是消息隊列服務器實體。
　　Exchange：消息交換機，它指定消息按什麼規則，路由到哪一個隊列。
　　Queue：消息隊列載體，每一個消息都會被投入到一個或多個隊列。
　　Binding：綁定，它的做用就是把exchange和queue按照路由規則綁定起來。
　　Routing Key：路由關鍵字，exchange根據這個關鍵字進行消息投遞。
　　vhost：虛擬主機，一個broker裏能夠開設多個vhost，用做不一樣用戶的權限分離。
　　producer：消息生產者，就是投遞消息的程序。
　　consumer：消息消費者，就是接受消息的程序。
　　channel：消息通道，在客戶端的每一個鏈接裏，可創建多個channel，每一個channel表明一個會話任務。

二、消息隊列的使用過程大概以下：

      （1）客戶端鏈接到消息隊列服務器，打開一個channel。
　　（2）客戶端聲明一個exchange，並設置相關屬性。
　　（3）客戶端聲明一個queue，並設置相關屬性。
　　（4）客戶端使用routing key，在exchange和queue之間創建好綁定關係。
　　（5）客戶端投遞消息到exchange。

exchange接收到消息後，就根據消息的key和已經設置的binding，進行消息路由，將消息投遞到一個或多個隊列裏。

exchange也有幾個類型，徹底根據key進行投遞的叫作Direct交換機，例如，綁定時設置了routing key爲」abc」，那麼客戶端提交的消息，只有設置了key爲」abc」的纔會投遞到隊列。對key進行模式匹配後進行投遞的叫作Topic交換機，符號」#」匹配一個或多個詞，符號」*」匹配正好一個詞。例如」abc.#」匹配」abc.def.ghi」，」abc.*」只匹配」abc.def」。還有一種不須要key的，叫作Fanout交換機，它採起廣播模式，一個消息進來時，投遞到與該交換機綁定的全部隊列。

RabbitMQ支持消息的持久化，也就是數據寫在磁盤上，爲了數據安全考慮，我想大多數用戶都會選擇持久化。消息隊列持久化包括3個部分：
　　（1）exchange持久化，在聲明時指定durable => 1
　　（2）queue持久化，在聲明時指定durable => 1
　　（3）消息持久化，在投遞時指定delivery_mode => 2（1是非持久化）

若是exchange和queue都是持久化的，那麼它們之間的binding也是持久化的。若是exchange和queue二者之間有一個持久化，一個非持久化，就不容許創建綁定。

2、安裝php的amqp擴展

先用phpinfo()查看php版本信息，

最後根據上面的信息去下載相應的amqp版本：http://pecl.php.net/package/amqp

據上面信息咱們的是64位線程安全版本

 

加壓後：

將php_amqp.dll複製到php/ext，同時在php.ini中添加以下代碼：

[amqp]  

extension=php_amqp.dll 

而後將rabbitmq.4.dll複製到php根目錄C:/xampp/php/，同時修改apache配置文件httpd.conf，添加以下代碼：

# rabbitmq

LoadFile  "C:/xampp/php/rabbitmq.4.dll"  

最後重啓看看是否已經加載了amqp模塊：

3、若是要在cli模式下測試運行rabbitmq，要配置cli模式的php.ini文件

一、查看運行模式下的php.ini的位置

（1）查看命令行模式下加載的php配置文件

php -i|findstr .ini (window)
php -i|grep .ini (linux)

一般爲php安裝目錄下的php.ini文件
如：D:\soft\wamp64\bin\php\php7.2.14\php.ini

（2）查看web模式下php加載的配置文件

phpinfo();
一般爲apache目錄下的php.ini文件
如：D:\soft\wamp64\bin\apache\apache2.4.37\bin\php.ini

二、配置D:\soft\wamp64\bin\php\php7.2.14\php.ini，在文件末尾加入

[amqp]
extension=php_amqp.dll

保存便可

4、php測試rabbitmq

　　一、發送者（publisher）：rabbit_publisher.php

　　建立鏈接-->建立channel-->建立交換機對象-->建立隊列-->發送消息

<?php

$exchangeName = 'demo';
$queueName = 'hello';
$routeKey = 'hello';
$message = 'Hello World!';

$connection = new AMQPConnection(
    array('host' => '127.0.0.1',
          'port' => '5672',
          'vhost' => '/', 
          'login' => 'guest', 
          'password' => 'guest')
);

$connection->connect() or die("Cannot connect to the broker!\n");

try {  
        $channel = new AMQPChannel($connection);
        $exchange = new AMQPExchange($channel);
        $exchange->setName($exchangeName);
        $queue = new AMQPQueue($channel);
        $queue->setName($queueName);
        $exchange->publish($message, $routeKey);
        var_dump("[x] Sent 'Hello World!'");
} catch (AMQPConnectionException $e) {
        var_dump($e);
        exit();
}
$connection->disconnect();
?>

View Code

　　二、消費者（consumer）：rabbit_consumer.php

      建立鏈接-->建立channel-->建立交換機-->建立隊列-->綁定交換機/隊列/路由鍵-->接收消息

<?php 

$exchangeName = 'demo';
$queueName = 'hello';
$routeKey = 'hello';

$connection = new AMQPConnection(array('host' => '127.0.0.1', 'port' => '5672', 'vhost' => '/', 'login' => 'guest', 'password' => 'guest'));
$connection->connect() or die("Cannot connect to the broker!\n");
$channel = new AMQPChannel($connection);
$exchange = new AMQPExchange($channel);
$exchange->setName($exchangeName);
$exchange->setType(AMQP_EX_TYPE_DIRECT);
$exchange->declareExchange(); // AMQP 1.2.0 由 declare() 改成 declareExchange(); 
$queue = new AMQPQueue($channel);
$queue->setName($queueName);
$queue->declareQueue();//AMQP 1.2.0 由 declare() 改成 declareQueue(); 
$queue->bind($exchangeName, $routeKey);

var_dump('[*] Waiting for messages. To exit press CTRL+C');  
while (TRUE) {  
        $queue->consume('callback');
}


function callback($envelope, $queue) {  
        $msg = $envelope->getBody();
        var_dump(" [x] Received:" . $msg);
        $queue->nack($envelope->getDeliveryTag());
}

$connection->disconnect();
 ?>

View Code

　　三、以管理者的身份運行RabbitMQ Command,啓動mq:net start rabbitmq。切換到項目文件目錄，執行消費者文件

　　

　　四、從新開啓一個命令行窗口，一樣切換到項目文件目錄，執行生產者文件

　　

　　會看到每執行一次生產者文件，消費者那裏都會受到生產者發送的消息：Hello World!