diff --git a/examples/MasterSlaveReplicationComplex.php b/examples/MasterSlaveReplicationComplex.php new file mode 100644 index 00000000..392f061d --- /dev/null +++ b/examples/MasterSlaveReplicationComplex.php @@ -0,0 +1,81 @@ + + * + * For the full copyright and license information, please view the LICENSE + * file that was distributed with this source code. + */ + +require 'SharedConfigurations.php'; + +// Predis allows to set Lua scripts as read-only operations in the context of +// replication. This works for both EVAL and EVALSHA and also for the client-side +// abstraction built upon them (Predis\Commands\ScriptedCommand). This example +// shows a slightly more complex configuration that injects a new scripted command +// in the server profile used by the new client instance and marks it marks it as +// a read-only operation for replication so that it will be executed on slaves. + +use Predis\Profiles\ServerProfile; +use Predis\Commands\ScriptedCommand; +use Predis\Network\MasterSlaveReplication; + +// ------------------------------------------------------------------------- // + +// Define a new scripted command that returns all the fields +// of a variable number of hashes with a single roundtrip. + +class HashMultipleGetAll extends ScriptedCommand { + const BODY = << function($options) { + $profile = ServerProfile::get('dev'); + $profile->defineCommand('hmgetall', 'HashMultipleGetAll'); + + return $profile; + }, + 'replication' => function($options) { + $replication = new MasterSlaveReplication(); + $replication->setScriptReadOnly(HashMultipleGetAll::BODY); + + return $replication; + }, +); + +// ------------------------------------------------------------------------- // + +$client = new Predis\Client($parameters, $options); + +// Execute the following commands on the master server using redis-cli: +// $ ./redis-cli HMSET metavars foo bar hoge piyo +// $ ./redis-cli HMSET servers master host1 slave host2 + +$hashes = $client->hmgetall('metavars', 'servers'); + +$replication = $client->getConnection(); +$stillOnSlave = $replication->getCurrent() === $replication->getConnectionById('slave'); + +echo "Is still on slave? ", $stillOnSlave ? 'YES' : 'NO', "!\n"; +var_export($hashes);