telkins / laravel-job-funneling-middleware
A middleware that can funnel jobs.
Installs: 4 622
Dependents: 0
Suggesters: 0
Security: 0
Stars: 5
Watchers: 1
Forks: 2
Open Issues: 0
Requires
- php: ^7.3|^8.0
- illuminate/redis: ^6.0|^7.0|^8.0|^9.0
Requires (Dev)
- orchestra/testbench: ^4.0|^5.0|^6.0|^7.0
- phpunit/phpunit: ^9.0|^9.3
- symfony/var-dumper: ^4.0|^5.0
README
This package contains a job middleware that can funnel jobs in Laravel apps.
Special Credits
Permission was granted by Freek Van der Herten to copy Spatie's laravel-rate-limited-job-middleware, rename it, and maintain it on my own. As such, the vast bulk of this package is built on theirs. Thanks...! :-)
Installation
You can install the package via composer:
composer require telkins/laravel-job-funneling-middleware
This package requires Redis to be set up in your Laravel app.
Usage
By default, the middleware will only allow 1 job to be executed at a time. Any jobs that are not allowed will be released for 5 seconds.
To apply the middleware just add the Telkins\JobFunnelingMiddleware\Funneled
to the middlewares of your job.
namespace App\Jobs; use Illuminate\Bus\Queueable; use Illuminate\Queue\InteractsWithQueue; use Illuminate\Contracts\Queue\ShouldQueue; use Illuminate\Foundation\Bus\Dispatchable; use Telkins\JobFunnelingMiddleware\Funneled; class TestJob implements ShouldQueue { use Dispatchable, InteractsWithQueue, Queueable; public function handle() { // your job logic } public function middleware() { return [new Funneled()]; } }
Configuring attempts
When using rate limiting, including funneling, the number of attempts of your job may be hard to predict. Instead of using a fixed number of attempts, it's better to use time based attempts.
You can add this to your job class:
/* * Determine the time at which the job should timeout. * */ public function retryUntil() : \DateTime { return now()->addDay(); }
Customizing the behavior
You can customize all the behavior. Here's an example where the middleware allows a maximum of 3 jobs to be performed at a time. Jobs that are not allowed will be released for 90 seconds.
// in your job public function middleware() { $funneledMiddleware = (new Funneled()) ->limit(3) ->releaseAfterSeconds(90); return [$funneledMiddleware]; }
Customizing Redis
By default, the middleware will use the default Redis connection.
The default key that will be used in redis will be the name of the class that created the instance of the middleware. In most cases this will be name of the job in which the middleware is applied. If this is not what you expect, you can use the key
method to customize it.
Here's an example where a custom connection and custom key is used.
// in your job public function middleware() { $funneledMiddleware = (new Funneled()) ->connection('my-custom-connection') ->key('my-custom-key'); return [$funneledMiddleware]; }
Conditionally applying the middleware
If you want to conditionally apply the middleware you can use the enabled
method. It accepts a boolean that determines if the middleware should funnel your job or not.
You can also pass a Closure
to enabled
. If it evaluates to a truthy value the middleware will be enabled.
Here's a silly example where the funneling is only activated in January.
// in your job public function middleware() { $shouldFunnelJobs = Carbon::now()->month === 1; $funneledMiddleware = (new Funneled()) ->enabled($shouldFunnelJobs); return [$funneledMiddleware]; }
Available methods.
These methods are available to be called on the middleware. Their names should be self-explanatory.
limit(int $limitedNumberOfJobs)
releaseAfterOneSecond()
releaseAfterSeconds(int $releaseInSeconds)
releaseAfterOneMinute()
releaseAfterMinutes(int $releaseInMinutes)
releaseAfterRandomSeconds(int $min = 1, int $max = 10)
Testing
composer test
Changelog
Please see CHANGELOG for more information on what has changed recently.
Contributing
Please see CONTRIBUTING for details.
Security
If you discover any security related issues, please email travis.elkins+github@gmail.com instead of using the issue tracker.
Credits
This code is heavily based on the funneling example found in the Laravel docs.
License
The MIT License (MIT). Please see License File for more information.