Welcome 微信登录

首页 / 操作系统 / Linux / Ubuntu下PHP + RabbitMQ使用

RabbitMQ是一个开源的基于AMQP(Advanced Message Queuing Protocol)标准,并且可靠性高的企业级消息系统,目前很多网站在用,包括reddit,Poppen.de等。1. Ubuntu下安装RabbitMQ
sudo apt-get install rabbitmq-server
sudo /etc/init.d/rabbitmq-server start2. 安装librabbitmq
sudo apt-get install mercurial
hg clone http://hg.rabbitmq.com/rabbitmq-c
cd rabbitmq-c
hg clone http://hg.rabbitmq.com/rabbitmq-codegen codegen
autoreconf -i && ./configure && make && sudo make install3. 安装php-rabbit扩展
wget http://php-rabbit.googlecode.com/files/php-rabbit.r91.tar.gz
tar -zxvf php-rabbit.r91.tar.gz
cd php-rabbit.r91
/path/to/php/bin/phpize
./configure –with-amqp –with-php-config=/path/to/php/bin/php-config
make && sudo make install
编辑 php.ini 添加:
extension=rabbit.so
输出phpinfo看下是否扩展已经加载成功,have fun:)4. Demo程序
producer:<?php/** * producer demo * * @author wei * @version $Id$ **/$params = array("host" =>"localhost","port" => 5672,"login" => "guest","password" => "guest","vhost" => "/");$cnn = new AMQPConnect($params); // declare Exchange$exchange = new AMQPExchange($cnn);$exchange->declare("ex1", "topic", AMQP_DURABLE ); // declare Queue$queue = new AMQPQueue($cnn);$queue->declare("queue1", AMQP_DURABLE);  // bind Queue$queue->bind("ex1","wei.#"); // publishing$msg = "msg"; for ($i=0; $i < 100; $i++) { $res = $exchange->publish($i . "msg", "wei." . $i);if ($res) {echo $i . "msg" . " Yes ";} else {echo $i . "msg" . " No ";}} ?>
  • 1
  • 2
  • 下一页
Ubuntu 下卸载 ATI 显卡驱动Fedora 13安装nVidia驱动重启不能进入系统的解决方法相关资讯      Ubuntu知识 
  • Ubuntu 有这功能吗?-回答4个新用  (10/14/2014 16:54:49)
  • Ubuntu小知识总结  (07/08/2013 17:02:10)
  • 万圣节Halloween与Ubuntu  (10/31/2012 07:59:01)
  • Ubuntu系统诞生10周年:让Linux更  (10/14/2014 16:53:00)
  • Ubuntu 官方发布 Ubuntu 应用程序  (02/15/2013 21:49:58)
  • Ubuntu内置捐款选项:为掌握用户需  (10/11/2012 13:57:23)
本文评论 查看全部评论 (0)
表情: 姓名: 字数