主頁 > 知識(shí)庫 > 使用PHP訪問RabbitMQ消息隊(duì)列的方法示例

使用PHP訪問RabbitMQ消息隊(duì)列的方法示例

熱門標(biāo)簽:智能外呼電銷系統(tǒng) 合肥外呼系統(tǒng)app 沈陽人工智能電銷機(jī)器人公司 拉薩打電話機(jī)器人 h5 地圖標(biāo)注 高識(shí)別電銷機(jī)器人 哈爾濱400電話辦理到易號(hào)網(wǎng) 電銷機(jī)器人-快迭智能 寶安400電話辦理

本文實(shí)例講述了使用PHP訪問RabbitMQ消息隊(duì)列的方法。分享給大家供大家參考,具體如下:

擴(kuò)展安裝

PHP訪問RabbitMQ實(shí)際使用的是AMQP協(xié)議,所以我們只要安裝epel庫中的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);
}

更多關(guān)于PHP相關(guān)內(nèi)容感興趣的讀者可查看本站專題:《PHP數(shù)據(jù)結(jié)構(gòu)與算法教程》、《php程序設(shè)計(jì)算法總結(jié)》、《php字符串(string)用法總結(jié)》、《PHP數(shù)組(Array)操作技巧大全》、《PHP常用遍歷算法與技巧總結(jié)》及《PHP數(shù)學(xué)運(yùn)算技巧總結(jié)》

希望本文所述對(duì)大家PHP程序設(shè)計(jì)有所幫助。

您可能感興趣的文章:
  • php實(shí)現(xiàn)通過stomp協(xié)議連接ActiveMQ操作示例
  • php ActiveMQ的安裝與使用方法圖文教程
  • PHP使用ActiveMQ實(shí)現(xiàn)消息隊(duì)列的方法詳解
  • PHP使用ActiveMQ實(shí)例
  • PHP Beanstalkd消息隊(duì)列的安裝與使用方法實(shí)例詳解
  • PHP高級(jí)編程之消息隊(duì)列原理與實(shí)現(xiàn)方法詳解
  • php+redis實(shí)現(xiàn)消息隊(duì)列功能示例
  • PHP+RabbitMQ實(shí)現(xiàn)消息隊(duì)列的完整代碼
  • php實(shí)現(xiàn)websocket實(shí)時(shí)消息推送
  • php 使用ActiveMQ發(fā)送消息,與處理消息操作示例

標(biāo)簽:巴中 山東 成都 威海 林芝 泰州 張家口 梅州

巨人網(wǎng)絡(luò)通訊聲明:本文標(biāo)題《使用PHP訪問RabbitMQ消息隊(duì)列的方法示例》,本文關(guān)鍵詞  使用,PHP,訪問,RabbitMQ,消息,;如發(fā)現(xiàn)本文內(nèi)容存在版權(quán)問題,煩請(qǐng)?zhí)峁┫嚓P(guān)信息告之我們,我們將及時(shí)溝通與處理。本站內(nèi)容系統(tǒng)采集于網(wǎng)絡(luò),涉及言論、版權(quán)與本站無關(guān)。
  • 相關(guān)文章
  • 下面列出與本文章《使用PHP訪問RabbitMQ消息隊(duì)列的方法示例》相關(guān)的同類信息!
  • 本頁收集關(guān)于使用PHP訪問RabbitMQ消息隊(duì)列的方法示例的相關(guān)信息資訊供網(wǎng)民參考!
  • 推薦文章