摘要：關(guān)于主從服務(wù)器配置就略過了，以下基于你已經(jīng)配置好好，然后在環(huán)境下如何使用。配置使用的是擴(kuò)展主從從隊(duì)列用到命令參考注意看文檔需要將設(shè)置為使用具體參數(shù)含義查看日志可以看到使用的從服務(wù)器查看日志可以看到使用的主服務(wù)器

關(guān)于redis主從服務(wù)器配置就略過了，以下基于你已經(jīng)配置好好，然后在laravel環(huán)境下如何使用。

laravel 使用的是 predis 擴(kuò)展
composer require predis/predis
vi config/database.php

"redis"=>[
   "cluster" => false,
    "default" => [
        "tcp://" . env("REDIS_DEFAULT_HOST") . ":" . env("REDIS_DEFAULT_PORT") . "?database=0&alias=master",//主
        "tcp://" . env("REDIS_DEFAULT_HOST_R") . ":" . env("REDIS_DEFAULT_PORT_R") . "?database=0&alias=slave_1",//從
        "tcp://" . env("REDIS_DEFAULT_HOST_R2") . ":" . env("REDIS_DEFAULT_PORT_R2") . "?database=0&alias=slave_2",//從
    ],
     "test" => [ 
                "host" => "127.0.0.1",
                "port" => 6379,
                "database" => 1,
            ],//隊(duì)列用到multi命令
             "options" => [
                "replication" => true,
                "connections" =>[
                    "tcp" => "AppServicesRedis",
                ],
            ],
];

//master slave   vendor/predis/predis/src/Connection/Aggregate/SentinelReplication.php:189
public function add(NodeConnectionInterface $connection)
    {
        $alias = $connection->getParameters()->alias;

        if ($alias === "master") {
            $this->master = $connection;
        } else {
            $this->slaves[$alias ?: count($this->slaves)] = $connection;
        }

        $this->reset();
    }

vi app/services/redis.php
//參考 https://github.com/nrk/predis/blob/v1.1/examples/debuggable_connection.php
namespace AppServices;

use PredisCommandCommandInterface;
use PredisConnectionStreamConnection;

class Redis extends StreamConnection
{
    private $tstart = 0;
    private $debugBuffer = [];

    public function connect()
    {
        $this->tstart = microtime(true);

        parent::connect();
    }

    private function storeDebug(CommandInterface $command, $direction)
    {
        $firtsArg = $command->getArguments();
        $timestamp = (microtime(true) - $this->tstart) * 1000;
        $log = [];
        $log["cmd"] = $command->getId();
        $log["key"] = isset($firtsArg) ?  $firtsArg  : " ";
        $log["server"] = "$direction $this";
        $log["time"] = $timestamp;
        $data = ["server" => trim($log["server"]), "cmd" => $command->getId(), "key" => $log["key"],"time" => $timestamp, "msg" => ["host" => explode(":", trim($log["server"]))[0], "port" => explode(":", trim($log["server"]))[1]]]];
        openlog("syslog",LOG_PID|LOG_ODELAY,LOG_LOCAL7);
        syslog(LOG_INFO,json_encode($data));
        closelog();
        dump($log);
        $this->debugBuffer[] = $log;
    }

    public function writeRequest(CommandInterface $command)
    {
        parent::writeRequest($command);

//        $this->storeDebug($command, "->");
    }

    public function readResponse(CommandInterface $command)
    {
        $response = parent::readResponse($command);
        $this->storeDebug($command, "");

        return $response;
    }

    public function getDebugBuffer()
    {
        return $this->debugBuffer;
    }

    public static function debug()
    {
        $options = [
            "connections" =>[
                "tcp" => "AppServicesRedis",
            ],
        ];

        $client = new PredisClient(config("database.redis.default"), $options);
        $client->get("redis:test");
        print_r($client->getConnection());
    }
}

看文檔 https://github.com/nrk/predis 需要將 replication 設(shè)置為true

The basic configuration needed to use the client in replication mode requires one Redis server to be identified as the master (this can be done via connection parameters using the alias parameter set to master) and one or more servers acting as slaves:

//具體參數(shù)含義 vendor/predis/predis/src/Connection/ParametersInterface.php:16
$redis = new PredisClient([
                "scheme" => "tcp",
                "host"   => "127.0.0.1",
                "port"   => 6379,
                "read_write_timeout" => 0,
            ]);
        $redis = Redis::connection("default");
        $key = "master:test";
        $redis->set($key, 666);//tail -f /var/log/messages 查看Redis日志可以看到使用的從服務(wù)器 REDIS_DEFAULT_HOST_R
        dump($redis->get($key));    //查看Redis日志可以看到使用的主服務(wù)器 REDIS_DEFAULT_HOST