源码网商城,靠谱的源码在线交易网站 我的订单 购物车 帮助

源码网商城

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

  • 时间:2022-11-20 03:03 编辑: 来源: 阅读:
  • 扫一扫,手机访问
摘要: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);

实际的执行流程是这样的:
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 后者又将请求转发给[code]$this->app['cache']->driver($driver) [/code]…… 经过一系列代码追查,存储类为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命令 [code]get ok[/code] 会将ok作crc32运算得到一个hash值 所有服务器按一定算法放到一个长度默认为128的数组中,每个服务器在其中占几项,由以下决定: 权重/总权重*总的服务器数量*128,可参考[code]PredisClusterDistributionHashRing::addNodeToRing[/code]方法 每一项的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相关内容感兴趣的读者可查看本站专题:《[url=http://www.1sucai.cn/Special/583.htm]Laravel框架入门与进阶教程[/url]》、《[url=http://www.1sucai.cn/Special/155.htm]php优秀开发框架总结[/url]》、《[url=http://www.1sucai.cn/Special/43.htm]php面向对象程序设计入门教程[/url]》、《[url=http://www.1sucai.cn/Special/84.htm]php+mysql数据库操作入门教程[/url]》及《[url=http://www.1sucai.cn/Special/231.htm]php常见数据库操作技巧汇总[/url]》 希望本文所述对大家基于Laravel框架的PHP程序设计有所帮助。
  • 全部评论(0)
联系客服
客服电话:
400-000-3129
微信版

扫一扫进微信版
返回顶部