laravel使用redis集群_laravel redis集群

class RedisHash
{
    protected static $connections = [];

    /**
     * 初始化redis集群
     */
    protected static function init()
    {
        // 获取redis集群host
        $hosts = explode(',', env('REDIS_HA_HOSTS'));

        // 获取redis库
        $databases = explode(',', env('REDIS_HA_DATABASES'));

        foreach ($hosts as $index => $host) {
            $redisManage = new RedisManager(app(), config('database.redis.client'), [
                'default' => [
                    'host' => $host,
                    'password' => env('REDIS_PASSWORD', null),
                    'port' => env('REDIS_PORT', 6379),
                    'database' => $databases[$index],
                ]
            ]);

            self::$connections[$index] = $redisManage->connection();
        }
    }

    /**
     * 获取redis集群连接数
     * &
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31