Gecko [ edgpens.lpkmn.gov.my ]

Name	Size	Permission
CustomDistributionStrategy.php	2.31 KB	-rw-rw-rw-
DispatcherLoop.php	2 KB	-rw-rw-rw-
KeyPrefixes.php	959 B	-rw-rw-rw-
MasterSlaveReplication.php	1.7 KB	-rw-rw-rw-
MasterSlaveReplicationComplex....	2.58 KB	-rw-rw-rw-
MonitorContext.php	1.52 KB	-rw-rw-rw-
MultiBulkReplyIterators.php	1.77 KB	-rw-rw-rw-
MultipleSetAndGet.php	762 B	-rw-rw-rw-
PipelineContext.php	925 B	-rw-rw-rw-
PubSubContext.php	1.91 KB	-rw-rw-rw-
RedisCollectionsIterators.php	2.74 KB	-rw-rw-rw-
ServerSideScripting.php	1.57 KB	-rw-rw-rw-
SessionHandler.php	1.62 KB	-rw-rw-rw-
SharedConfigurations.php	681 B	-rw-rw-rw-
SimpleDebuggableConnection.php	2.06 KB	-rw-rw-rw-
SimpleSetAndGet.php	479 B	-rw-rw-rw-
TransactionWithCAS.php	1.47 KB	-rw-rw-rw-

Code Editor : MasterSlaveReplicationComplex.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 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);

${this.title}

Code Editor : MasterSlaveReplicationComplex.php