mirror of
https://github.com/predis/predis.git
synced 2026-08-23 02:20:56 +00:00
Daniele Alessandri
09895f27bf
We also changed our wording to indentify this kind of abstraction so instead of using "scripted commands" (kind of broken English) we now use "scriptable commands".
84 lines
2.6 KiB
PHP
84 lines
2.6 KiB
PHP
<?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 for replication.
|
|
// This works for both EVAL and EVALSHA and also for the client-side abstraction
|
|
// built upon them (Predis\Command\ScriptCommand). This example shows a slightly
|
|
// more complex configuration that injects a new script 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\ScriptCommand;
|
|
use Predis\Connection\MasterSlaveReplication;
|
|
use Predis\Replication\ReplicationStrategy;
|
|
|
|
// ------------------------------------------------------------------------- //
|
|
|
|
// Define a new script command that returns all the fields of a variable number
|
|
// of hashes with a single roundtrip.
|
|
|
|
class HashMultipleGetAll extends ScriptCommand {
|
|
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);
|