mq例子程序-php版
2017-07-13 10:57
225 查看
//生产者 public function actionDemo22(){ $connection = new AMQPStreamConnection('localhost', 5672, 'guest', 'guest'); $channel = $connection->channel(); $channel->exchange_declare("exchangeb","direct", false, false, false) ; $msg = new AMQPMessage('Hello World info aa!'); $channel->basic_publish($msg, 'exchangeb',"info"); echo " [x] Sent 'Hello World!'\n"; $channel->close(); $connection->close(); } //消费者 public function actionDemo23(){ $connection = new AMQPStreamConnection('localhost', 5672, 'guest', 'guest'); $channel = $connection->channel(); $channel->exchange_declare("exchangeb","direct", false, false, false) ; list($queue_name, ,) = $channel->queue_declare("queueb", false, true, false, false); $channel->queue_bind($queue_name, 'exchangeb',"info"); echo ' [*] Waiting for messages. To exit press CTRL+C', "\n"; $message = $channel->basic_get("queueb",true) ; if(!empty($message)){ $key = $message->delivery_info['routing_key']; $a1 = $message->getBody(); var_dump($key); var_dump($a1); } $channel->close(); $connection->close(); } //消费者 public function actionDemo24(){ $connection = new AMQPStreamConnection('localhost', 5672, 'guest', 'guest'); $channel = $connection->channel(); $channel->exchange_declare("exchangeb","direct", false, false, false) ; list($queue_name, ,) = $channel->queue_declare("queueb", false, true, false, false); $channel->queue_bind($queue_name, 'exchangeb',"info"); $callback = function($msg){ echo ' [x] ', $msg->body, "\n"; }; $channel->basic_consume($queue_name, '', false, true, false, false, $callback); while(count($channel->callbacks)) { $channel->wait(); } $channel->close(); $connection->close(); }
相关文章推荐
- 几个PHP的静态方法的程序例子
- php调用c++程序例子
- php小偷程序原理和例子
- RPC框架Thrift例子-PHP调用C++后端程序
- 在浏览器中 编译php程序例子时,老是报NOTICE错误
- php调用c++程序例子
- linux中查找php***程序例子
- php输出标准xml,php访问mysql数据库简单例子(可以被asp等程序读取)
- linux中查找php***程序例子
- RPC框架Thrift例子-PHP调用C++后端程序
- 整合了一个PHP分页函数与smarty与程序显示的例子
- PHP作用域限定符::的几个程序例子
- php计算程序运行时间的简单例子分享
- php计算程序运行时间的简单例子分享
- php计算程序运行时间的简单例子分享
- Easy Form Generation Using FuelPHP(fuelphp的例子程序)
- PHP作用域限定符::的几个程序例子
- FLEX FOR PHP的博客以及例子程序
- RPC框架Thrift例子-PHP调用C++后端程序
- 自己写了一个通过smarty与php相互结合的例子,动态生成静态程序,写的很烂