home
/
zktecojo
/
public_html
/
vendor
/
predis
/
predis
/
examples
➕ New
📤 Upload
✎ Editing:
MasterSlaveReplicationComplex.php
← Back
<?php /* * This file is part of the Predis package. * * (c) Daniele Alessandri <suppakilla@gmail.com> * * 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\Command\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\Command\ScriptedCommand; use Predis\Connection\MasterSlaveReplication; use Predis\Replication\ReplicationStrategy; // ------------------------------------------------------------------------- // // 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 = <<<EOS local hashes = {} for _, key in pairs(KEYS) do table.insert(hashes, key) table.insert(hashes, redis.call('hgetall', key)) end return hashes EOS; public function getScript() { return self::BODY; } } // ------------------------------------------------------------------------- // $parameters = array( 'tcp://127.0.0.1:6379/?alias=master', 'tcp://127.0.0.1:6380/?alias=slave', ); $options = array( 'profile' => function ($options, $option) { $profile = $options->getDefault($option); $profile->defineCommand('hmgetall', 'HashMultipleGetAll'); return $profile; }, 'replication' => function ($options) { $strategy = new ReplicationStrategy(); $strategy->setScriptReadOnly(HashMultipleGetAll::BODY); $replication = new MasterSlaveReplication($strategy); 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);
💾 Save Changes
Cancel
📤 Upload File
×
Select File
Upload
Cancel
➕ Create New
×
Type
📄 File
📁 Folder
Name
Create
Cancel
✎ Rename Item
×
Current Name
New Name
Rename
Cancel
🔐 Change Permissions
×
Target File
Permission (e.g., 0755, 0644)
0755
0644
0777
Apply
Cancel