项目作者: Lansoweb

项目描述 :
PHP implementation of Circuit Breaker pattern
高级语言: PHP
项目地址: git://github.com/Lansoweb/cerberus.git
创建时间: 2019-06-24T16:16:27Z
项目社区:https://github.com/Lansoweb/cerberus

开源协议:BSD 2-Clause "Simplified" License

下载


Cerberus

Build Status Coverage Status Latest Stable Version Total Downloads

Introduction

This is a Circuit Breaker pattern implementation in PHP.

This library helps you to handle external services timeouts and outages.

Requirements

  • PHP >= 7.2
  • Any cache library implementing psr/simple-cache

Installation

  1. composer require los/cerberus:^1.0

Configuration

You can manually create a Cerberus instance or use a Factory

Factory

  1. 'factories' => [
  2. Los\Cerberus\Cerberus::class => Los\Cerberus\CerberusFactory::class
  3. ],

and copy the configuration file config/cerberus.global.php.dist to your config/autoload/cerberus.global.php and change to your needs.

  1. return [
  2. 'cerberus' => [
  3. 'max_failures' => 5,
  4. 'timeout' => 60,
  5. ]
  6. ];

The maxFailure parameter is the number of failures after which the circuit is opened and the service becomes not available.

When the timeout is reached, the circuit becomes half opened and one attempt is possible and the status is updated.

The factory pull the cache from the container using

  1. $container->get(\Psr\SimpleCache\CacheInterface::class)

so you need to have one implemented.

Manually

You can create a Cerberus instance manually:

  1. $storage = new Cache(); // Any psr/simple-cache implementation
  2. $cerberus = new Cerberus($storage, 5, 60);

Usage

The usage is simple. Each time you will access a remote resource (like an Web Service), check for its availability and report its success or failure:

  1. if ($cerberus->isAvailable()) {
  2. try {
  3. $http->makeRequest();
  4. $cerberus->reportSuccess();
  5. } catch (\Exception $ex) {
  6. $cerberus->reportFailure();
  7. }
  8. }

You can use Cerberus to control more than one service. In this scenario, use the methods passing a service name:

  1. if ($cerberus->isAvailable('service-one')) {
  2. try {
  3. $http->makeRequest();
  4. $cerberus->reportSuccess('service-one');
  5. } catch (\Exception $ex) {
  6. $cerberus->reportFailure('service-one');
  7. }
  8. }
  9. if ($cerberus->isAvailable('service-two')) {
  10. try {
  11. $http->makeRequest();
  12. $cerberus->reportSuccess('service-two');
  13. } catch (\Exception $ex) {
  14. $cerberus->reportFailure('service-two');
  15. }
  16. }