使用PHP訪問RabbitMQ消息隊列的方法示例
更新時間：2018年06月06日 14:30:07 作者：Zach-vip
這篇文章主要介紹了使用PHP訪問RabbitMQ消息隊列的方法,結合實例形式分析了RabbitMQ消息隊列的相關擴展安裝、隊列建立、隊列綁定、消息發(fā)送、消息接收等相關操作技巧,需要的朋友可以參考下
本文實例講述了使用PHP訪問RabbitMQ消息隊列的方法。分享給大家供大家參考，具體如下：
擴展安裝
PHP訪問RabbitMQ實際使用的是AMQP協(xié)議，所以我們只要安裝epel庫中的php-pecl-amqp這個包即可
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();
隊列建立
<?php
$connection = new AMQPConnection();
$connection->connect();
$channel = new AMQPChannel($connection);
$queue = new AMQPQueue($channel);
$queue->setName('queue1');
$queue->declare();
隊列綁定
<?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);
}
更多關于PHP相關內(nèi)容感興趣的讀者可查看本站專題：《PHP數(shù)據(jù)結構與算法教程》、《php程序設計算法總結》、《php字符串(string)用法總結》、《PHP數(shù)組(Array)操作技巧大全》、《PHP常用遍歷算法與技巧總結》及《PHP數(shù)學運算技巧總結》
希望本文所述對大家PHP程序設計有所幫助。
相關文章
本文主要介紹了PHP調用Go服務的正確方式 - Unix Domain Sockets，對進程間通信感興趣的同學，可以參考一下。2021-05-05
phpmyadmin里面導入sql語句格式的大量數(shù)據(jù)的方法
phpmyadmin里面導入sql語句格式的大量數(shù)據(jù)的方法2010-06-06
我們在實現(xiàn)PHP彈出對話框之后，一般還需要返回原來頁面或者用新的頁面替換原來的頁面等，本文將會講解詳細代碼編寫，需要的朋友可以參考下2015-09-09
抖音直播是當今熱門的實時互動平臺之一,用戶在直播間內(nèi)發(fā)送的彈幕消息是互動的關鍵組成部分,在本文中,我們將介紹如何使用 PHP 技術實現(xiàn)抖音直播彈幕的抓取,文中通過代碼示例給大家介紹的非常詳細,需要的朋友可以參考下2023-12-12
本文主要介紹了PHP程序指定的過程原理。為了以后能開發(fā)PHP擴展，就一定要了解PHP的執(zhí)行順序。這篇文章就是為C開發(fā)PHP擴展做鋪墊。2021-05-05
微信公眾平臺開發(fā)教程④ ThinkPHP框架下微信支付功能圖文詳解
這篇文章主要介紹了微信公眾平臺開發(fā)ThinkPHP框架下微信支付功能,結合圖文形式詳細分析了基于thinkPHP框架的微信支付功能實現(xiàn)步驟、操作技巧與相關注意事項,需要的朋友可以參考下2019-04-04
一個英文語句怎樣把它的每個單詞的字母順序顛倒而單詞順序不變？2010-08-08
以下是對數(shù)組非數(shù)字鍵名引號的必要性進行了詳細的分析介紹，需要的朋友可以過來參考下2013-08-08
這篇文章主要介紹了php數(shù)組使用規(guī)則,實例分析了php中數(shù)組的用法,具有一定參考借鑒價值,需要的朋友可以參考下2015-02-02
詳解WordPress中分類函數(shù)wp_list_categories的使用
這篇文章主要介紹了詳解WordPress中分類函數(shù)wp_list_categories的使用,文中羅列其主要參數(shù)的功能和寫法,需要的朋友可以參考下2016-01-01