php-resque

php-resque (pronounced like "rescue") is a Redis-backed library for creating background jobs, placing those jobs on multiple queues, and processing them later.

---

Contents

• Background
• Requirements
• Getting Started
• Jobs
  • Defining Jobs
  • Queueing Jobs
  • Delaying Jobs
  • Job Statuses
• Workers
  • Signals
  • Forking
  • Autoload Job Classes
• Commands & Options
• Logging
• Event/Hook System
• Configuration Options
• Redis
• Contributing
• Contributors

---

Background

This version of php-resque is based on the work originally done by chrisboulton where he ported the ruby version of the same name that was created by GitHub.

The reasoning behind rewriting the previous work is to add better support for horizontal scaling of worker servers and to improve job failure tolerance to create a very highly available system. Integration with Monolog means that very verbose logging is achievable which makes it far easier to solve bugs across distributed systems. And an extensive events/hooks system enables deeper integration and stats gathering.

This version provides features such as:

• Workers can be distributed between multiple machines.
• Resilient to memory leaks (jobs are run on forked processes).
• Expects and logs failure.
• Logging uses Monolog.
• Ability to push Closures to queues.
• Job status and output tracking.
• Jobs will fail cleanly if out of memory or if maximum execution time is reached.
• Will mark a job as failed, if a forked child running a job does not exit with a status code of 0.
• Has a built-in event system to enable hooks for deep integration.
• Support for priorities (queues).

This version is not a direct port of Github's Resque and therefore is not compatible with it, or their web interface. A Resque web interface built with Symfony 3.x for this version can be found on GitHub.

Requirements

You must have the following installed to run php-resque:

• Redis
• PHP 7.2+
• PCNTL PHP extension
• Composer

Optional:

• Phpiredis

---

Getting Started

The easiest way to work with php-resque is when it's installed as a Composer package inside your project.

Add php-resque to your application by running:

composer require mjphaynes/php-resque

If you haven't already, add the Composer autoloader to your project's bootstrap:

require 'vendor/autoload.php';

Jobs

Defining Jobs

Each job should be in its class, and php-resque has a blueprint for building them.

use Resque\Blueprint\Job as JobBlueprint;
use Resque\Job;

class MyJob extends JobBlueprint
{
    /**
     * Runs any required logic before the job is performed.
     *
     * @param Job $job Current job instance
     */
    public function setUp(Job $job): void
    {
    }

    /**
     * Actual job logic.
     *
     * @param array $args Arguments passed to the job
     * @param Job   $job  Current job instance
     */
    public function perform(array $args, Job $job): void
    {
        // Do some work
    }

    /**
     * Runs after the job is performed.
     *
     * @param Job $job Current job instance
     */
    public function tearDown(Job $job): void
    {
    }
}

When the job is run, the class will be instantiated and any arguments will be sent as arguments to the perform method. The current job instance (Resque\Job) is passed to the perform method as the second argument.

Any exception thrown by a job will result in the job failing - be careful here and make sure you handle the exceptions that shouldn't result in a job failing. If you want to cancel a job (instead of having it fail) then you can throw a Resque\Exception\Cancel exception and the job will be marked as canceled.

Jobs can also have setUp and tearDown methods. If a setUp method is defined, it will be called before the perform method is run. The tearDown method if defined, will be called after the job finishes. If an exception is thrown in the setUp method the perform method will not be run. This is useful for cases where you have different jobs that require the same bootstrap, for instance, a database connection.

Queueing Jobs

To add a new job to the queue use the Resque::push method.

$job = Resque::push(MyJob::class, ['arg1' => true, 'arg2']);

The first argument is the fully resolved classname for your job class (if you're wondering how php-resque knows about your job classes see autoloading job classes). The second argument is an array of any arguments you want to pass through to the job class.

It is also possible to push a Closure onto the queue. This is very convenient for quick, simple tasks that need to be queued. When pushing Closures onto the queue, the __DIR__ and __FILE__ constants should not be used.

$job = Resque::push(function ($job) {
    echo "This is a inline job {$job->getId()}!";
});

It is possible to push a job onto another queue (the default queue is called default) by passing through a third parameter to the Resque::push method which contains the queue name.

$job = Resque::push(SendEmail::class, [], 'email');

Delaying Jobs

It is possible to schedule a job to run at a specified time in the future using the Resque::later method. You can do this by either passing through an int or a DateTime object.

$job = Resque::later(60, MyJob::class);
$job = Resque::later(1398643990, MyJob::class);
$job = Resque::later(new \DateTime('+2 mins'), MyJob::class);
$job = Resque::later(new \DateTime('2014-07-08 11:14:15'), MyJob::class);

If you pass through an integer and it is smaller than 94608000 seconds (3 years) php-resque will assume you want a time relative to the current time (I mean, who delays jobs for more than 3 years anyway??). Note that you must have a worker running at the specified time for the job to run.

Job Statuses

php-resque tracks the status of a job. The status information will allow you to check if a job is in the queue, currently being run, failed, etc. To track the status of a job you must capture the job id of a pushed job.

$job = Resque::push(MyJob::class);
$jobId = $job->getId();

To fetch the status of a job:

$job = Job::load($jobId);
$status = $job->getStatus();

Job statuses are defined as constants in the Job class. Valid statuses are:

• Job::STATUS_WAITING - The job is still queued
• Job::STATUS_DELAYED - Job is delayed
• Job::STATUS_RUNNING - The job is currently running
• Job::STATUS_COMPLETE - Job is complete
• Job::STATUS_CANCELLED - The job has been canceled
• Job::STATUS_FAILED - Job has failed
• false - Failed to fetch the status - is the id valid?

Statuses are available for up to 7 days after a job has been completed or failed, and are then automatically expired. This timeout can be changed in the configuration file.

Workers

To start a worker navigate to your project root and run:

$ vendor/bin/resque worker:start

Note that once this worker has started, it will continue to run until it is manually stopped. You may use a process monitor such as Supervisor to run the worker as a background process and to ensure that the worker does not stop running.

If the worker is a background task you can stop, pause & restart the worker with the following commands:

$ vendor/bin/resque worker:stop
$ vendor/bin/resque worker:pause
$ vendor/bin/resque worker:resume

The commands take inline configuration options as well as reading from a configuration file.

For instance, to specify that the worker only processes jobs on the queues named high and low, as well as allowing a maximum of 30MB of memory for the jobs, you can run the following:

$ vendor/bin/resque worker:start --queue=high,low --memory=30 -vvv

Note that this will check the high queue first and then the low queue, so it is possible to facilitate job queue priorities using this. To run all queues use * - this is the default value. The -vvv enables very verbose logging. To silence any logging the -q flag is used.

For more commands and the full list of options please see the commands documentation.

In addition, if the workers are running on a different host, you may trigger a graceful shutdown of a worker remotely via the data in Redis. For example:

foreach(Worker::allWorkers() as $worker) {
    $worker->shutdown();
}

Signals

Signals work on supported platforms. Signals sent to workers will have the following effect:

• QUIT - Wait for the child to finish processing then exit
• TERM / INT - Immediately kill child then exit
• USR1 - Immediately kill the child but don't exit
• USR2 - Pause worker, no new jobs will be processed
• CONT - Resume worker

Forking

When php-resque runs a job it first forks the process to a child process. This is so that if the job fails the worker can detect that the job failed and will continue to run. The forked child will always exit as soon as the job finishes.

The PECL module (http://php.net/manual/en/book.pcntl.php) must be installed to use php-resque.

Autoload Job Classes

Getting your application underway also requires telling the worker about your job classes, using either an autoloader or including them. If you're using Composer then it will be relatively straightforward to add your job classes there.

Alternatively, you can do so in the resque.yml file or by setting the include argument:

$ vendor/bin/resque worker:start --include=/path/to/your/include/file.php

There is an example of how this all works in the examples/ folder in this project.

Commands & Options

For the full list of php-resque commands and their associated arguments, please see the commands documentation.

Logging

php-resque is integrated with Monolog which enables extensive logging abilities. For full documentation please see the logging documentation.

Event/Hook System

php-resque has an extensive events/hook system to allow developers deep integration with the library without having to modify any core files. For full documentation and a list of all events please see the hooks documentation.

Configuration Options

For a complete list of all configuration options, please see the configuration documentation.

Redis

You can either set the Redis connection details inline or in the configuration file. To set when running a command:

$ vendor/bin/resque [command] --host=<hostname> --port=<port>

Contributing

PHP-Resque v4 is for PHP 7.2 or higher, new code must work with PHP 7.2. Please follow the PSR-12 coding style where possible. New features should come with tests.

---

Contributors

Contributing to the project would be a massive help in maintaining and extending the script. If you're interested in contributing, issue a pull request on GitHub.

• mjphaynes
• chrisboulton (original port)
• Project contributors