RabbitMQ的原理和用法

這篇文章主要講解了“RabbitMQ的原理和用法”，文中的講解內(nèi)容簡(jiǎn)單清晰，易于學(xué)習(xí)與理解，下面請(qǐng)大家跟著小編的思路慢慢深入，一起來研究和學(xué)習(xí)“RabbitMQ的原理和用法”吧！

什么是MQ？

MQ全稱為Message Queue, 消息隊(duì)列（MQ）是一種應(yīng)用程序?qū)?yīng)用程序的通信方法。MQ是消費(fèi)-生產(chǎn)者模型的一個(gè)典型的代表，一端往消息隊(duì)列中不斷寫入消息，而另一端則可以讀取隊(duì)列中的消息。

RabbitMQ就是MQ的一種，本文介紹了使用PHP訪問RabbitMQ消息隊(duì)列的方法,結(jié)合實(shí)例形式分析了RabbitMQ消息隊(duì)列的相關(guān)擴(kuò)展安裝、隊(duì)列建立、隊(duì)列綁定、消息發(fā)送、消息接收等相關(guān)操作技巧,需要的朋友可以參考下

擴(kuò)展安裝

PHP訪問RabbitMQ實(shí)際使用的是AMQP協(xié)議，所以我們只要安裝epel庫(kù)中的php-pecl-amqp這個(gè)包即可

rpm -ivh http://mirror.neu.edu.cn/fedora/epel/6/x86_64/epel-release-6-8.noarch.rpm
yum install php-pecl-amqp

交換建立

<?php
$connection = new AMQPConnection();
$connection->connect();
$channel = new AMQPChannel($connection);
$exchange = new AMQPExchange($channel);
$exchange->setName('exchange1');
$exchange->setType('fanout');
$exchange->declare();

隊(duì)列建立

<?php
$connection = new AMQPConnection();
$connection->connect();
$channel = new AMQPChannel($connection);
$queue = new AMQPQueue($channel);
$queue->setName('queue1');
$queue->declare();

隊(duì)列綁定

<?php
$connection = new AMQPConnection();
$connection->connect();
$channel = new AMQPChannel($connection);
$queue = new AMQPQueue($channel);
$queue->setName('queue1');
$queue->declare();
$queue->bind('exchange1', 'routekey');

消息發(fā)送

<?php
$connection = new AMQPConnection();
$connection->connect();
$channel = new AMQPChannel($connection);
$exchange = new AMQPExchange($channel);
$exchange->setName('exchange5');
$exchange->setType('fanout');
$exchange->declare();
for($i = 0; $i < 2000000; $i++) {
 $exchange->publish("message $i", "routekey");
}

消息接收

<?php
$connection = new AMQPConnection();
$connection->connect();
$channel = new AMQPChannel($connection);
$queue = new AMQPQueue($channel);
$queue->setName('queue1');
$queue->declare();
$queue->bind('exchange1', 'routekey');
while (true) {
  $queue->consume(function($envelope, $queue){
   echo $envelope->getBody(), PHP_EOL;
  }, AMQP_AUTOACK);
}

看完是不是覺得很簡(jiǎn)單，這個(gè)做消息隊(duì)列不難！

感謝各位的閱讀，以上就是“RabbitMQ的原理和用法”的內(nèi)容了，經(jīng)過本文的學(xué)習(xí)后，相信大家對(duì)RabbitMQ的原理和用法這一問題有了更深刻的體會(huì)，具體使用情況還需要大家實(shí)踐驗(yàn)證。這里是億速云，小編將為大家推送更多相關(guān)知識(shí)點(diǎn)的文章，歡迎關(guān)注！