szado/reactphp-connection-pool [UNSTABLE]

Async and flexible pool for any type of connections built on top of ReactPHP.

Connection pooling allows you to easily manage range of connections with some remote service (e.g. a database server). You can define how many connections your app can estabilish or how to react when all connections are busy at the same time.

• Flexible - manage any type of connections by implementing your own ConnectionAdapter and specify how connections are to be selected for use by passing proper ConnectionSelector.
• Lightweight and simple - in assumptions it is a simple component that can be freely extended according to your preferences.

Requirements

• PHP >= 8.1 (fibers, enums)

Examples

class MyConnectionAdapter implements Szado\React\ConnectionPool\ConnectionAdapters\ConnectionAdapterInterface
{
  // Implementation of adapter for your connection.
}

$pool = new Szado\React\ConnectionPool\ConnectionPool(fn () => new MyConnectionAdapter());
$adapter = React\Async\await($pool->get());
$connection = $adapter->getConnection();
// `$connection` is ready to use :)

Additional Configuration

You can pass additional parameters to pool constructor:

• connectionSelectorClass - define algorithm used for selecting connections (by default simple UsageConnectionSelector is used).
• connectionsLimit - maximum number of connections that can be created (null for unlimited).
• retryLimit - how many times try to search for an active connection before rejecting (null for unlimited, 0 for immediately rejection if none at the moment).
• retryEverySec - check for available connections every how many seconds (only if $retryLimit is enabled).
• loop - instance of React\EventLoop\LoopInterface to use.

Todo

• Built-in adapters (clue/reactphp-redis, friends-of-reactphp/mysql).
• Connection selector based on Round Robin algorithm.

At the end...

• Run tests: ./vendor/bin/phpunit
• Feel free to submit your PR
• Licence: MIT