laravel框架实现redis分布式集群原理

71 阅读 0 评论 47 点赞

我是靠谱客的博主无奈芹菜，最近开发中收集的这篇文章主要介绍laravel框架实现redis分布式集群原理，觉得挺不错的，现在分享给大家，希望可以做个参考。

概述

在app/config/database.php中配置如下：

'redis' => array(
        'cluster' => true,
        'default' => array(
            'host' => '172.21.107.247',
            'port' => 6379,
        ),
        'redis1' => array(
            'host' => '172.21.107.248',
            'port' => 6379,
        ),
)

其中cluster选择为true，接下来就可以作集群使用了;
如果把session的driver设置为redis，则可以使用其集群功能了：
我们来看下session的实现，当我们在代码中这样写：

Session::put('test', 124);

实际的执行流程是这样的：

IlluminateSupportFacadesSession
IlluminateSupportFacadesFacade
IlluminateSessionFacade::app['session']->put

IlluminateSessionFacade::app['session']为IlluminateSessionSessionManager
IlluminateSupportManager::__call

Session会根据返回创建driver
$this->app['config']['session.driver']
即配置文件中配置的，这里我们配置为redis

IlluminateSessionSessionManager::IlluminateSessionSessionManager
最终由IlluminateSessionStore来负责put的调用

而Store类负责存储的类是IlluminateSessionCacheBasedSessionHandler
后者又将请求转发给$this->app['cache']->driver($driver)

……
经过一系列代码追查，存储类为PredisClientDatabase,看其构造函数：

public function __construct(array $servers = array())
    {
        if (isset($servers['cluster']) && $servers['cluster'])
        {
            $this->clients = $this->createAggregateClient($servers);
        }
        else
        {
            $this->clients = $this->createSingleClients($servers);
        }
    }

如果设置为集群，则调用createAggregateClient方法

protected function createAggregateClient(array $servers)
    {
        $servers = array_except($servers, array('cluster'));
        return array('default' => new Client(array_values($servers)));
    }

这里会把所有服务器放在default组中
实际存数据的类是PredisClient，这里有根据配置创建服务器的代码，具体可以自己看下；

PredisClusterPredisClusterHashStrategy类负责计算key的hash，关键函数：
getHash
getKeyFromFirstArgument

而PredisClusterDistributionHashRing负责服务器环的维护，关键函数
addNodeToRing
get
hash

大概原理是这样，如执行以下redis命令
get ok
会将ok作crc32运算得到一个hash值
所有服务器按一定算法放到一个长度默认为128的数组中，每个服务器在其中占几项，由以下决定：
权重/总权重*总的服务器数量*128，可参考PredisClusterDistributionHashRing::addNodeToRing方法

每一项的hash值是按服务器ip:端口的格式，作crc32计算的

protected function addNodeToRing(&$ring, $node, $totalNodes, $replicas, $weightRatio)
    {
        $nodeObject = $node['object'];
        $nodeHash = $this->getNodeHash($nodeObject);
        $replicas = (int) round($weightRatio * $totalNodes * $replicas);

        for ($i = 0; $i < $replicas; $i++) {
            $key = crc32("$nodeHash:$i");
            $ring[$key] = $nodeObject;
        }
    }