Async Redis client implementation built on top of React PHP.
Redis is an open source, advanced, in-memory key-value database. It offers a set of simple, atomic operations in order to work with its primitive data types. Its lightweight design and fast operation makes it an ideal candidate for modern application stacks. This library provides you a simple API to work with your Redis database from within PHP. It enables you to set and query its data or use its PubSub topics to react to incoming events.
- Async execution of Commands - Send any number commands to Redis in parallel (automatic pipeline) and process their responses as soon as results come in. The Promise-based design provides a sane interface to working with async responses.
- Event-driven core - Register your event handler callbacks to react to incoming events, such as an incoming PubSub message or a MONITOR event.
- Lightweight, SOLID design - Provides a thin abstraction that is just good enough and does not get in your way. Future or custom commands and events require no changes to be supported.
- Good test coverage - Comes with an automated tests suite and is regularly tested against versions as old as Redis v2.6+
Note: This project is in beta stage! Feel free to report any issues you encounter.
Once installed, you can use the following code to connect to your local Redis server and send some requests:
$loop = React\EventLoop\Factory::create();
$factory = new Factory($loop);
$factory->createClient()->then(function (Client $client) use ($loop) {
$client->SET('greeting', 'Hello world');
$client->APPEND('greeting', '!');
$client->GET('greeting')->then(function ($greeting) {
echo $greeting . PHP_EOL;
});
$client->INCR('invocation')->then(function ($n) {
echo 'count: ' . $n . PHP_EOL;
});
// end connection once all pending requests have been resolved
$client->end();
});
$loop->run();See also the examples.
The Factory is responsible for creating your Client instance.
It also registers everything with the main EventLoop.
$loop = \React\EventLoop\Factory::create();
$factory = new Factory($loop);The createClient($redisUri) method can be used to create a new Client.
It helps with establishing a plain TCP/IP connection to Redis
and optionally authenticating (AUTH) and selecting the right database (SELECT).
$factory->createClient('localhost')->then(
function (Client $client) {
// client connected and authenticated
},
function (Exception $e) {
// an error occured while trying to connect or authorize client
}
);Note: The given $redisUri can include a scheme, password, host, port and database definition.
tcp://auth@localhost:6379/2
The Client is responsible for exchanging messages with Redis
and keeps track of pending commands.
All Redis commands are automatically available as public methods (via the magic __call() method) like this:
$client->get($key);
$client->set($key, $value);
$client->exists($key);
$client->expire($key, $seconds);
$client->mget($key1, $key2, $key3);
$client->multi();
$client->exec();
$client->publish($channel, $payload);
$client->subscribe($channel);
$client->ping();
$client->select($database);Listing all available commands is out of scope here, please refer to the Redis command reference.
Sending commands is async (non-blocking), so you can actually send multiple commands in parallel. Redis will respond to each command request with a response message, pending commands will be pipelined automatically. Sending commands uses a Promise-based interface that makes it easy to react to when a command is fulfilled (i.e. either successfully resolved or rejected with an error):
$client->set('hello', 'world');
$client->get('hello')->then(function ($response) {
// response received for GET command
echo 'hello ' . $response;
});The on($eventName, $eventHandler) method can be used to register a new event handler.
Incoming events and errors will be forwarded to registered event handler callbacks:
// global events:
$client->on('data', function (MessageInterface $message) {
// process an incoming message (raw message object)
});
$client->on('close', function () {
// the connection to Redis just closed
});
$client->on('error', function (Exception $e) {
// and error has just been detected, the connection will terminate...
});
// pubsub events:
$client->on('message', function ($channel, $payload) {
// pubsub message received on given $channel
});
$client->on('pmessage', function ($pattern, $payload) {
// pubsub message received matching given $pattern
});
$client->on('subscribe', function ($channel, $total) {
// subscribed to given $channel
});
$client->on('psubscribe', function ($pattern, $total) {
// subscribed to matching given $pattern
});
$client->on('unsubscribe', function ($channel, $total) {
// unsubscribed from given $channel
});
$client->on('punsubscribe', function ($pattern, $total) {
// unsubscribed from matching given $pattern
});
// monitor events:
$client->on('monitor', function (StatusReply $message) {
// somebody executed a command
});The close() method can be used to force-close the Redis connection and reject all pending commands.
The end() method can be used to soft-close the Redis connection once all pending commands are completed.
The recommended way to install this library is through composer. New to composer?
{
"require": {
"clue/redis-react": "~0.5.0"
}
}MIT