Download the PHP package zwilias/beanie without Composer

Beanie

A clean, lean PHP beanstalkd client library

Core features

• Support for connection pools
• Clean distinction between concerns: Producers, Workers and Managers
• Clean interface. Want to touch a Job? $job->touch();
• Full support for the beanstalk protocol as documented at the time of writing

Quickstart

Requirements:

• PHP 5.5, 5.6 or 7.x
• beanstalkd 1.3 or higher
• PHP socket_* functions must not be disabled

Producer

A Producer exposes the necessary commands to produce jobs on the queue. It operates on an entire Pool, and will create its jobs on random connections from that pool, as a means of randomly distributing load to the workers.

Worker

A Worker exposes the commands needed to consume jobs from the queue. Rather than operating on the entire Pool - like the Producers do - it only operates on a single connection. The idea behind this is to ensure, on an architectural level, that each beanstalk queue requires as least on Worker to operate, and you won't have one queue filling up because all your workers are waiting for a job from a different queue.

Manager

The Managers do exactly what it says on the package. They're your go-to class for writing code to get a view on how your beanstalk instances are performing, or occasionally kicking buried jobs on to the queue again. They expose statistics on every connection and every tube on every connection.

Installation

Installation is recommended to happen through composer.

Architecture

Use case

Each producer writes to random connections on the pool. Each worker handles a single connection -- which doesn't preclude the possibility of having multiple workers for each queue, of course.

This is a PHP library, and as such, is optimized for the most common use case - short lived producers which create jobs during page generation and offload them to longer lived workers.

However: using the Worker::reserveOath method which returns a JobOath object, one could poll multiple workers for a Job. The reserveOath method writes the blocking reserve command to the beanstalk connection, but does not enter the blocking read call until the invoke method is called on the returned JobOath object. The JobOath object also exposes the raw socket resource, so using socket_select or something like and \EvIo watcher could enable a use-case like so:

The above use case is implemented in QMan, check it out!

Class map

Classes a "casual" user would come into contact with are highlighted in green.

Contributing

Pull requests are appreciated. Make sure code-quality (according to scrutinizer) doesn't suffer too badly. Make sure you add thorough white-box unit tests and, if applicable, black-box integration tests.

Running the tests locally:

Note: Some of the integration tests depend on a locally running beanstalkd. These tests are excluded in the default phpunit.xml.dist file. In order to include them, run phpunit with the --group __nogroup__,beanstalk flag. If you want the tests to connect to a server other than localhost:11300, set the BEANSTALK_HOST and BEANSTALK_PORT environment variables.

License

Copyright (c) 2015 Ilias Van Peer

Released under the MIT License, see the enclosed LICENSE file.