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

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

转载作者：qq735679552 更新时间：2022-09-28 22:32:09

CFSDN坚持开源创造价值，我们致力于搭建一个资源共享平台，让每一个IT人在这里找到属于你的精彩世界.

这篇CFSDN的博客文章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框架的PHP程序设计有所帮助.

原文链接：http://www.cnblogs.com/szprg/articles/4592420.html 。

最后此篇关于Laravel框架实现redis集群的方法分析的文章就讲到这里了,如果你想了解更多关于Laravel框架实现redis集群的方法分析的内容请搜索CFSDN的文章或继续浏览相关文章，希望大家以后支持我的博客！。

文章推荐：社保卡和医保卡是一张吗社保卡里面的钱可以取出来吗

文章推荐：微博钱包借钱正规吗？微博钱包借钱好通过吗？

文章推荐：八闽健康码如何更换绑定的手机号八闽健康码手机号被别人注册了怎么办

文章推荐： ThinkPHP开发--使用七牛云储存

Ruby 方法() 方法
我想了解 Ruby 方法 methods() 是如何工作的。我尝试使用“ruby 方法”在 Google 上搜索，但这不是我需要的。我也看过 ruby-doc.org，但我没有找到这种方法。
VBS教程：方法-Test 方法
Test 方法对指定的字符串执行一个正则表达式搜索，并返回一个 Boolean 值指示是否找到匹配的模式。 object.Test(string) 参数 object 必选项。总是一个
VBS教程：方法-Replace 方法
Replace 方法替换在正则表达式查找中找到的文本。 object.Replace(string1, string2) 参数 object 必选项。总是一个 RegExp 对象的名称。
VBS教程：方法-Raise 方法
Raise 方法生成运行时错误 object.Raise(number, source, description, helpfile, helpcontext) 参数 object 应为
VBS教程：方法-Execute 方法
Execute 方法对指定的字符串执行正则表达式搜索。 object.Execute(string) 参数 object 必选项。总是一个 RegExp 对象的名称。 string
VBS教程：方法-Clear 方法
Clear 方法清除 Err 对象的所有属性设置。 object.Clear object 应为 Err 对象的名称。说明在错误处理后，使用 Clear 显式地清除 Err 对象。此
VBS教程：方法-CopyFile 方法
CopyFile 方法将一个或多个文件从某位置复制到另一位置。 object.CopyFile source, destination[, overwrite] 参数 object 必选
VBS教程：方法-Copy 方法
Copy 方法将指定的文件或文件夹从某位置复制到另一位置。 object.Copy destination[, overwrite] 参数 object 必选项。应为 File 或 F
VBS教程：方法-Close 方法
Close 方法关闭打开的 TextStream 文件。 object.Close object 应为 TextStream 对象的名称。说明下面例子举例说明如何使用 Close 方
VBS教程：方法-BuildPath 方法
BuildPath 方法向现有路径后添加名称。 object.BuildPath(path, name) 参数 object 必选项。应为 FileSystemObject 对象的名称
VBS教程：方法-GetFolder 方法
GetFolder 方法返回与指定的路径中某文件夹相应的 Folder 对象。 object.GetFolder(folderspec) 参数 object 必选项。应为 FileSy
VBS教程：方法-GetFileName 方法
GetFileName 方法返回指定路径（不是指定驱动器路径部分）的最后一个文件或文件夹。 object.GetFileName(pathspec) 参数 object 必选项。应为
VBS教程：方法-GetFile 方法
GetFile 方法返回与指定路径中某文件相应的 File 对象。 object.GetFile(filespec) 参数 object 必选项。应为 FileSystemObject
VBS教程：方法-GetExtensionName 方法
GetExtensionName 方法返回字符串，该字符串包含路径最后一个组成部分的扩展名。 object.GetExtensionName(path) 参数 object 必选项。应
VBS教程：方法-GetDriveName 方法
GetDriveName 方法返回包含指定路径中驱动器名的字符串。 object.GetDriveName(path) 参数 object 必选项。应为 FileSystemObjec
VBS教程：方法-GetDrive 方法
GetDrive 方法返回与指定的路径中驱动器相对应的 Drive 对象。 object.GetDrive drivespec 参数 object 必选项。应为 FileSystemO
VBS教程：方法-GetBaseName 方法
GetBaseName 方法返回字符串，其中包含文件的基本名 (不带扩展名), 或者提供的路径说明中的文件夹。 object.GetBaseName(path) 参数 object 必
VBS教程：方法-GetAbsolutePathName 方法
GetAbsolutePathName 方法从提供的指定路径中返回完整且含义明确的路径。 object.GetAbsolutePathName(pathspec) 参数 object
VBS教程：方法-FolderExists 方法
FolderExists 方法如果指定的文件夹存在，则返回 True；否则返回 False。 object.FolderExists(folderspec) 参数 object 必选项
VBS教程：方法-FileExists 方法
FileExists 方法如果指定的文件存在返回 True；否则返回 False。 object.FileExists(filespec) 参数 object 必选项。应为 FileS

qq735679552

个人简介

我是一名优秀的程序员,十分优秀！

作者热门文章

滴滴打车优惠券免费领取

全站热门文章

首页

博学

6Ren·AI

商城

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