A component helping you gracefully handle outages and timeouts of external services (usually remote, 3rd party services).
It is a library providing extremely easy to use circuit breaker component. It does not require external dependencies and it has default storage implementations for APC and Memcached but can be extended multiple ways.
This library does not require any particular PHP framework, all you need is PHP 5.4 or higher.
If you are using Symfony 2 framework you should use php-circuit-breaker-bundle. It is a bundle i have created to wrap up php-circuit-breaker and integrate it with Symfony 2 components and Dependency Injection.
If you are using other frameworks and you would like to use php-circuit-breaker please let me know and we can try to build up an open source integration just like the one for Symfony 2.
- Allow application to detect failures and adapt its behaviour without human intervention.
- Increase robustness of services by addinf fail-safe functionality into modules.
You can download sources and use them with your autoloader or you can use composer in which case all you nees is a require like this:
"require": {
"ejsmont-artur/php-circuit-breaker": "*"
},
After that you should update composer dependencies and you are good to go.
- Your application has an Non-Critical Feature like: user tracking, stats, recommendations etc
- The optional feature uses remote service that causes outages of your application.
- You want to keep applicaton and core processes available when "Non-Critical Feature" fails.
Code of your application could look something like:
$factory = new Ejsmont\CircuitBreaker\Factory();
$circuitBreaker = $factory->getSingleApcInstance(30, 300);
$userProfile = null;
if( $circuitBreaker->isAvailable("UserProfileService") ){
try{
$userProfile = $userProfileService->loadProfileOrWhatever();
$circuitBreaker->reportSuccess("UserProfileService");
}catch( UserProfileServiceConnectionException $e ){
// network failed - report it as failure
$circuitBreaker->reportFailure("UserProfileService");
}catch( Exception $e ){
// something went wrong but it is not service's fault, dont report as failure
}
}
if( $userProfile === null ){
// for example, show 'System maintenance, you cant login now.' message
// but still let people buy as logged out customers.
}
- Web application depends on third party service (for example a payment gateway).
- Web application needs to keep track when 3rd party service is unavailable.
- Application can not become slow/unavailable, it has to tell user that features are limited or just hide them.
- Application uses circuit breaker before checkout page rendering and if particular payment gateway is unavailable payment option is hidden from the user.
As you can see that is a very powerful concept of selectively disabling feautres at runtime but still allowing the core business processes to be uninterrupted.
Backend talking to the payment service could look like this:
$factory = new Ejsmont\CircuitBreaker\Factory();
$circuitBreaker = $factory->getSingleApcInstance(30, 300);
try{
// try to process the payment
// then tell circuit breaker that it went well
$circuitBreaker->reportSuccess("PaymentOptionOne");
}catch( SomePaymentConnectionException $e ){
// If you get network error report it as failure
$circuitBreaker->reportFailure("PaymentOptionOne");
}catch( Exception $e ){
// in case of your own error handle it however it makes sense but
// dont tell circuit breaker it was 3rd party service failure
}
Since you are recording failed and successful operations you can now use them in the front end as well to hide payment options that are failing.
Frontend rendering the available payment options could look like this:
$factory = new Ejsmont\CircuitBreaker\Factory();
$circuitBreaker = $factory->getSingleApcInstance(30, 300);
if ($circuitBreaker->isAvailable("PaymentOptionOne")) {
// display the option
}
In order to easily wrap a service class and protect it with circuit breaker there is a factory class:
$client = new Predis\Client("tcp://127.0.0.1:6379?read_write_timeout=0");
$factory = new Ejsmont\CircuitBreaker\Factory();
$cb = $factory->getRedisInstance($client, 30, 3600);
$proxy = CircuitBreakerProxyFactory::create('SomeSlowService', $circuitBreaker, ["constructor", "arguments"]);
$proxy->remoteCalls(); // the call is protected by the circuit breaker
the default wrapping functionality is as follows:
$oldTimeout = ini_get("default_socket_timeout"); // as we are talking about remote calls, we get the old timeout
if ($this->circuitBreaker->isAvailable($this->serviceName)) { // we are checking if the service is available
try {
ini_set("default_socket_timeout", $this->timeout); // override the timeout
$returnValue = $method->invokeArgs($proxy, $args); // the original methodcall
$this->circuitBreaker->reportSuccess($this->serviceName); // at the happy path we report the success
} catch(\Exception $e) {
$this->circuitBreaker->reportFailure($this->serviceName); // or we report the error
}
}
ini_set("default_socket_timeout", $oldTimeout); // and set the timeout to the original value
You may override this by providing a 4th parameter to the create factory method:
$proxy = CircuitBreakerProxyFactory::create('SomeSlowService', $circuitBreaker, ["constructor", "arguments"], $ownMethodHook);
The 4th parameter must implement the 'guymers\proxy\MethodHook' interface.
- Track multiple services through a single Circuit Breaker instance.
- Pluggable backend adapters, provided APC, Redis and Memcached by default.
- Customisable service thresholds. You can define how many failures are necessary for service to be considered down.
- Customisable retry timeout. You do not want to disable the service forever. After provided timeout circuit breaker will allow a single process to attempt
- Create a dynamic proxy wrapping around a service class with circuit breaker.
Overhead of the Circuit Breaker is negligible.
APC implementation takes roughly 0.0002s to perform isAvailable() and then reportSuccess() or reportFailure().
Memcache adapter is in range of 0.0005s when talking to the local memcached process.
Redis adapter is in range of 0.0002s when talking to the local Redis.
The only potential performance impact is network connection time. If you chose to use remote memcached server or implement your own custom StorageAdapter.
The proxy creation takes roughly 0.0007s. The further calls have no performance impact.
- Tests are run via PHPUnit It is assumed to be installed via PEAR.
- Tests can be ran using phpunit alone or via ant build targets.
- The "ci" target generate code coverage repor, "phpunit" target does not.
You can run all tests by any of the following:
ant
ant phpunit
ant ci
You can run selected test case by running:
cd tests
phpunit Unit/Ejsmont/CircuitBreaker/Storage/Adapter/DummyAdapterTest.php
Before documentation gets updated you can read more on the concept of circuit breaker and its implementation on my blog http://artur.ejsmont.org/blog/circuit-breaker
Some implementation details has changed but the core logic is still the same.
- Artur Esjmont (https://github.com/ejsmont-artur) via http://artur.ejsmont.org
- Krisztian Papp (https://github.com/letscodehu) via https://www.letscode.hu