Skip to content

This is an implementation of a Circuit Breaker for PHP projects (https://martinfowler.com/bliki/CircuitBreaker.html), which can be used on your services.

License

Notifications You must be signed in to change notification settings

gabrielanhaia/php-circuit-breaker

Folders and files

NameName
Last commit message
Last commit date

Latest commit

 

History

55 Commits
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 

Repository files navigation

Build Status Code Coverage Licence Package Stars

PHP Circuit Breaker

Description

PHP Circuit Breaker was developed based on the book "Release It!: Design and Deploy Production-Ready Software (Pragmatic Programmers)", written by Michael T. Nygard. In this book, Michael popularized the Circuit Breaker.

When we work with microservices, it is sometimes common to call these systems, and they are not available, which ends up causing problems in our application. To prevent any problem on our side, and guarantee that a service will not be called loads of times, we should use a Circuit Breaker.

You can find more information about Circuit Breakers here.

Requirements

  • PHP 7
  • Redis
  • Redis PHP extension enabled
  • Composer

Installation

You can install PHP Circuit Breaker by composer running: # composer require gabrielanhaia/php-circuit-breaker


How do I use it?

I strongly recommend that you use a service container (dependency injection container) to deal with the objects and their dependencies, so you will be able to use it efficiently (It will not be necessary to create instances everywhere).

  1. The first thing you can do is to define the Settings:
$settings = [
    'exceptions_on' => false, // Define if exceptions will be thrown when the circuit is open.
    'time_window' => 20, // Time window in which errors accumulate (Are being accounted for in total).
    'time_out_open' => 30, // Time window that the circuit will be opened (If opened).
    'time_out_half_open' => 20, // Time out that the circuit will be half-open.
    'total_failures' => 5 // Number of failures necessary to open the circuit.
];

Note: It is not necessary to define these settings (they are the default values), they will be defined automatically.

  1. Instantiating a driver (Only Redis driver is available at the moment) and Redis client:
$redis = new \Redis;
$redis->connect('localhost');
$redisCircuitBreakerDriver = new GabrielAnhaia\PhpCircuitBreaker\Adapter\Redis\RedisCircuitBreaker($redis);
  1. Instantiating the PHP Circuit Breaker class:
$circuitBreaker = new GabrielAnhaia\PhpCircuitBreaker\CircuitBreaker($redisCircuitBreakerDriver, $settings)

Note: The second parameter is optional.

  1. Validating if the circuit is open:
if ($circuitBreaker->canPass($serviceName) !== true) {
    return;
}

You can use the function canPass in any way you want. It will always return true when the Circuit is CLOSED or HALF_OPEN. After that, you should call your service, and depending on the response, you can call the following methods to update the circuit control variables.

If Success:

$circuitBreaker->succeed($serviceName);

If failure:

$circuitBreaker->failed($serviceName);

With these three simple methods, you can control the flow of your application in execution time.


Recap

Let's say that you are using the following settings:

$settings = [
    'exceptions_on' => false, // Define if exceptions will be thrown when the circuit is open.
    'time_window' => 20, // Time window in which errors accumulate (Are being accounted for in total).
    'time_out_open' => 30, // Time window that the circuit will be opened (If opened).
    'time_out_half_open' => 60, // Time out that the circuit will be half-open.
    'total_failures' => 5 // Number of failures necessary to open the circuit.
];

One of your services is a Payment Gateway, and you try to call it in an interval of each 2 seconds for some reason. The first time you call the Gateway, it responds with a 200 (HTTP status code), and after you call the method "succeed" with a service identifier (You can create one for each service).

On the second, third, fourth, fifth, and sixth call, the Gateway is unavailable, so you call the method "failed" again.

The total of failers was 5, now the next time you call the method "canPass" it will return "false" and the service will not be called again. At this moment the circuit is open, it will stay "OPEN" for 30 seconds (time_out_open), and then it will change the state to "HALF_OPEN" at this moment you can try to call the service again, and if it fails it will be "OPEN" for more 30 seconds.

What happens if the first four attempts fail and the fifth is succeeded? Then, the counter will be reset.

What is the setting "time_window" for? Each failure is stored on Redis and has an expiration date. If the first failure happened exaclty at 12:00:10 and the "time_window" is 30 seconds, so, after 12:00:40 this failure will not be counted in the total of failures considered to open the circuit. In short, to open the circuit, you must have X (total_failures) in an interval of Y (time_window) seconds.


Created by: Gabriel Anhaia - https://www.linkedin.com/in/gabrielanhaia