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 在 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 许可证