lightster/hodor

此包已被废弃且不再维护。未建议替代包。

基于PHP和rabbitmq的工作队列

v0.2.1 2017-11-08 23:55 UTC

README

Build Status Test Coverage Code Climate

一个正在从工作队列向作业队列演化的工作队列

要求

  • PHP >= 5.5.18
  • Composer
  • Supervisord
  • Postgres >= 9.3
  • RabbitMQ

配置

通过composer在你的应用程序中安装Hodor

composer require lightster/hodor:^0.2.0

在你的Postgres服务器上创建一个数据库以与Hodor实例一起使用

CREATE DATABASE hodor;

将Hodor分布配置复制到你的应用程序配置保存位置

cp vendor/lightster/hodor/config/dist/config.dist.php config/hodor.php

在配置文件中更新Postgres和RabbitMQ凭证。

在配置文件的job_runner键中编写你的作业运行器引导。这里定义的方法将在任何工作者接收到作业消息时被调用。此方法不应超过几行——任何超过的部分都应该转移到引导包含脚本或类中。一个示例作业运行器可能如下所示

<?php
return [
    'job_runner' => function($name, $params) {
        $container = require_once __DIR__ . '/../bootstrap.php';
        $job_runner = $container['job_runner'];
        $job_runner->runJob($name, $params);
    },
];

在配置数据库凭证后运行数据库迁移

bin/hodor.php database:migrate config/hodor.php

然后设置supervisord来管理你的作业队列进程

sudo php bin/hodor.php daemon:generate-config config/hodor.php
sudo service supervisord reload

使用方法

use Hodor\JobQueue\JobQueue;

$job_queue = new JobQueue();
$job_queue->setConfigFile(__DIR__ . '/../../../config/hodor.php');
$job_queue->push(
    'Vendor\Project\SomeJob',           // job_name
    ['number' => 123, 'name' => 'Bob'], // job_params
    ['queue_name' => 'default']         // job_options
);