romeoz/rock-mq

消息队列服务的统一API

0.10.0 2015-06-12 22:02 UTC

This package is not auto-updated.

Last update: 2024-09-28 16:36:22 UTC


README

Latest Stable Version Total Downloads Build Status Coverage Status License

Rock MQ on Packagist

特性

  • 后台发送
  • 发布/订阅
  • 非阻塞
  • Rock Framework模块 Rock Framework

安装

通过命令行

composer require romeoz/rock-mq:*@dev

在您的composer.json中

{
    "require": {
        "romeoz/rock-mq": "*@dev"
    }
}

快速入门

运行代理

php tests/data/mq/rabbit/simple_server.php &

代码

use rock\mq\RabbitQueue;

$rabbit = new RabbitQueue();
$rabbit->send('test'); // result: "Hi! I am server: test"

// or background

$rabbit->sendBackground('test');

####发布/订阅

运行代理

php tests/data/mq/rabbit/pub_server.php &

代码

use rock\mq\RabbitQueue;

$rabbit = new RabbitQueue();
$rabbit->blocking = false;
$rabbit->type = 'direct';
$rabbit->exchange = 'direct_test';

$rabbit->subscribe('foo'); // result: "Hi! I am server: foo"

要求

  • PHP 5.4+
  • Gearman 应已安装 apt-get install libgearman7。同时,还应安装 PHP 扩展 apt-get install php5-gearman
  • RabbitMQ 应已安装 apt-get install rabbitmq-server
  • ZeroMQ 应已安装 apt-get install libzmq3。同时,还应安装 PHP 扩展 apt-get install php-zmq

注意:如果您在安装过程中遇到问题,请参阅配置 .travis

许可

消息队列API是开源软件,许可协议为MIT 许可证