Laravel框架实现redis集群的方法分析

本文实例讲述了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);

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

illuminate\support\facades\session
illuminate\support\facades\facade
illuminate\session\facade::app['session']->put
illuminate\session\facade::app['session']为illuminate\session\sessionmanager
illuminate\support\manager::__call

session会根据返回创建driver

$this->app['config']['session.driver']

即配置文件中配置的，这里我们配置为redis

illuminate\session\sessionmanager::illuminate\session\sessionmanager

最终由illuminate\session\store来负责put的调用

而store类负责存储的类是illuminate\session\cachebasedsessionhandler

后者又将请求转发给$this->app['cache']->driver($driver)
……
经过一系列代码追查，存储类为predis\client\database,看其构造函数：

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组中

实际存数据的类是predis\client，这里有根据配置创建服务器的代码，具体可以自己看下；

predis\cluster\predisclusterhashstrategy类负责计算key的hash，关键函数：

gethash

getkeyfromfirstargument

而predis\cluster\distribution\hashring负责服务器环的维护，关键函数

addnodetoring

get

hash

大概原理是这样，如执行以下redis命令

get ok

会将ok作crc32运算得到一个hash值

所有服务器按一定算法放到一个长度默认为128的数组中，每个服务器在其中占几项，由以下决定：

权重/总权重*总的服务器数量*128，可参考predis\cluster\distribution\hashring::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;
    }
}

key的hash值也有了，服务器环也计算好了，剩下的就是查找了，二分法能较快的查找相应的服务器节点

更多关于laravel相关内容感兴趣的读者可查看本站专题：《laravel框架入门与进阶教程》、《php优秀开发框架总结》、《php面向对象程序设计入门教程》、《php+mysql数据库操作入门教程》及《php常见数据库操作技巧汇总》

希望本文所述对大家基于laravel框架的php程序设计有所帮助。