Merge branch 'master' of https://git.oschina.net/dogstar/PhalApi-Library

Author: dogstarTest

RabbitMQ/Lite.php

@@ -0,0 +1,65 @@
+<?php
+
+require_once __DIR__ . '/vendor/autoload.php';
+use PhpAmqpLib\Connection\AMQPStreamConnection;
+use PhpAmqpLib\Message\AMQPMessage;
+
+
+
+class RabbitMQ_Lite{
+
+ private $connection;
+ private $channel;
+
+ /**
+ * RabbitMQ_Lite constructor.
+ * 建立连接
+ * @param $config
+ */
+ function __construct(array $config) {
+ $this->connection = new AMQPStreamConnection($config['host'], $config['port'], $config['user'], $config['password'], $config['vhost']);
+ $this->channel = $this->connection->channel();
+
+ }
+
+ /**
+ * 消息入队列
+ * @param mixed $msg 消息
+ * @param string $queue 队列名称
+ */
+ function push($msg, $queue){
+ $msg = serialize($msg);
+ $message = new AMQPMessage($msg, array('delivery_mode' => AMQPMessage::DELIVERY_MODE_PERSISTENT));
+ $this->channel->basic_publish($message, '', $queue);
+ }
+
+ /**
+ * 消息出队列
+ * @param string $queue 队列名称
+ * @param $callback 处理消息的回调函数
+ */
+ function pop($queue, $callback){
+ $this->channel->basic_qos(null, 1, null);
+ $this->channel->basic_consume($queue, '', false, false, false, false, $callback);
+
+ while(count($this->channel->callbacks)) {
+ $this->channel->wait();
+ }
+ }
+
+ /**
+ * 声明队列，不存在会去创建
+ */
+ public function queue_declare($queue){
+ $this->channel->queue_declare($queue, false, true, false, false);
+ }
+
+ /**
+ * 关闭连接
+ */
+ function close(){
+ $this->channel->close();
+ $this->connection->close();
+ }
+}
+

RabbitMQ/README.md

@@ -0,0 +1,65 @@
+# PhalApi-RabbitMQ基于PhalApi专业队列拓展
+
+![](http://webtools.qiniudn.com/master-LOGO-20150410_50.jpg)
+
+## 前言
+
+RabbitMQ一直都是队列中的标杆,这次有幸PhalApi也能啃上RabbitMQ真是一件大好事,感谢**@牧鱼人**提供基于php-amqplib/php-amqplib封装的PhalApi-RabbitMQ扩展
+
+**关于RabbitMQ相关的安装集群配置可以参考笔者博客的MQ模块**
+
+附上:
+
+官网地址:[http://www.phalapi.net/](http://www.phalapi.net/ "PhalApi官网")
+
+开源中国Git地址:[http://git.oschina.net/dogstar/PhalApi/tree/release](http://git.oschina.net/dogstar/PhalApi/tree/release "开源中国Git地址")
+
+开源中国拓展Git地址:[http://git.oschina.net/dogstar/PhalApi-Library](http://git.oschina.net/dogstar/PhalApi-Library "开源中国Git地址")
+
+
+## 1.安装
+
+使用PhalApi-RabbitMQ扩展和使用其他扩展也是一样简单,只需要把目录存放到Library即可进行使用
+
+在Config中创建文件rabbitmq.php配置文件格式如下:
+
+```
+return array(
+ 'servers' => array(
+ 'host' => '127.0.0.1',
+ 'port' => '5672',
+ 'user' => 'admin',
+ 'password' => 'admin',
+ 'vhost' => '/',
+ )
+)
+```
+
+## 2.使用RabbitMQ写入和处理消息
+
+然后就可以进行实例化使用了:
+
+```
+// 实例化RabbitMQ实例
+$rm = RabbitMQ_Lite(DI()->config->get('rabbitmq.servers'));
+
+// 检查test队列是否存在,如果不存在则创建,频繁调用会带来较大性能消耗
+// 建议在出队列脚本处进行调用,写入队列不进行调用
+$rm->queue_declare("test");
+
+// 向队列写入一条消息
+$rm->push("测试消息","test");
+
+// 定义处理消息的方法
+$func = function ($msg){
+ echo $msg;
+ };
+// 处理任务(会阻塞进行)
+$rm->pop("test",$func);
+
+```
+
+
+注:笔者能力有限有说的不对的地方希望大家能够指出,也希望多多交流!
+
+**官网QQ交流群:①群:421032344 ②群:459352221 欢迎大家的加入!**

RabbitMQ/composer.json

@@ -0,0 +1,5 @@
+{
+ "require": {
+ "php-amqplib/php-amqplib": "2.6.*"
+ }
+}

RabbitMQ/composer.lock

@@ -0,0 +1,7 @@
+<?php
+
+// autoload.php @generated by Composer
+
+require_once __DIR__ . '/composer' . '/autoload_real.php';
+
+return ComposerAutoloaderInit291f5189b6fe349844454037aa66032b::getLoader();