要約: laravelでのredisクラスターのアプリケーションのこの部分では、laravel5.2でのredisクラスターの構成を共有したいと思います(公式Webサイトにもredisクラスターの構成の説明がありますが、バージョン 5.2 はまだ少し不十分です。クラスターの構成についてのみ説明しています。項目は true に設定されていますが、そのようなオプションだけでは、初心者が Redis セットを直接使用できることを意味するわけではありません...
Redis クラスターのアプリケーションlaravel
今回は、laravel5.2におけるredisクラスターの構成について共有したいと思います(公式サイトにもredisクラスターの構成の説明が載っていますが、バージョン5.2ではまだ少し足りない。としか書いてありません)クラスター構成項目を true に設定しますが、このオプションだけでは初心者が redis クラスターを直接使用できることを意味するわけではありません。そのため、predis クライアントのソース コード分析も後ほど共有します。クラスター構築: Easy Building Redis-cluster (Reidsクラスターを簡単に構築)
システムソフトウェアリスト:
laravelバージョン: 5.2-
redisバージョン:>=3.0 最新バージョンをダウンロードするだけ-
predis:>=1.0 ダウンロード アドレス-
設定ファイル: config/database.php
'redis' => [ 'cluster' => env('REDIS_CLUSTER', true),
**'options'=>['cluster'=>'redis']**, //官网没说这个,这是必须的！！后面会讲为什么这么配?
'default' => [ 'host' => env('REDIS_HOST', '127.0.0.1'), //任选一个master节点
'port' => env('REDIS_PORT',6379), 'database' => 0, 'timeout'=>15, 'read_write_timeout'=>1800 //redis客户端连接以后的读写超时时间(默认是60s)
], 'extra'=>[
'host'=>env('REDIS_EXTRA_HOST','127.0.0.1'), //任意一个集群中的节点即可
'port'=>env('REDIS_EXTRA_PORT',7001)
]
]ログイン後にコピー
、上記の手順を完了すると、redis クラスターを使用できるようになります。
ビジネス ニーズに応じて、redis クラスターを使用するための特定のアプリケーション シナリオが多数あります。クラスタリングとしてセッションなどを保存します。
app('request')->session()->put('key','value');
predis の基礎となる実装に保存します。 redis クラスター
わかりました、構成ファイル内のパラメーターを理解したい場合は、ソース コード、そしてもちろん predis のコードを確認する必要があります。
Illuminate\Support\ServiceProvider\RedisServiceProvider； public function register()
{ $this->app->singleton('redis', function ($app) { return new Database($app['config']['database.redis']);
});
}
Illuminate\Redis\Database;
public function __construct(array $servers = [])
{
$cluster = Arr::pull($servers, 'cluster'); //获取'cluster'的键值
$options = (array) Arr::pull($servers, 'options'); //options 就是database.php中'options'的键值,是一个数组(但官网没有提到，是个坑.)
if ($cluster) {
$this->clients = $this->createAggregateClient($servers, $options); //集群模式'cluster=true'
} else {
$this->clients = $this->createSingleClients($servers, $options); //单机模式 'cluster=false'
}
} protected function createAggregateClient(array $servers, array $options = [])
{
return ['default' => new Client(array_values($servers), $options)]; //predis的Client类
}
----------
注意：这里提醒一下各参数的值:
此时$servers=[
[ 'host' => env('REDIS_HOST', '127.0.0.1'), 'port' => env('REDIS_PORT',6379), 'database' => 0, 'timeout'=>15, 'read_write_timeout'=>1800
],
[ 'host'=>env('REDIS_EXTRA_HOST','127.0.0.1'), 'port'=>env('REDIS_EXTRA_PORT',7001)
]
]
$options = ['cluster'=>'redis']
其实到这儿，就可以解释在database.php中增加options选项，而且是必选项，因为底层代码需要判断数据切片的方式.
除了看源码，
predis的包文档也做了解释.https://packagist.org/packages/predis/predis-------ログイン後にコピー
次に、これらの基礎となるクラスを見てみましょう。
Predis\Client; public function __construct($parameters = null, $options = null)
{ $this->options = $this->createOptions($options ?: array()); #$this->connection = $this->createConnection($parameters ?: array());
#$this->profile = $this->options->profile;
}
protected function createOptions($options)
{ if (is_array($options)) { return new Options($options); //如你所见,实例化Options类
} if ($options instanceof OptionsInterface) { return $options;
} throw new \InvalidArgumentException('Invalid type for client options.');
}
public function __construct(array $options = array())
{ $this->input = $options; $this->options = array(); $this->handlers = $this->getHandlers();
}ログイン後にコピー
$this->connection = $this->createConnection($parameters?: array())
Predis\Client 文件
protected function createConnection($parameters)
{
# if ($parameters instanceof ConnectionInterface) {
# return $parameters;
# }
# if ($parameters instanceof ParametersInterface || is_string($parameters)) {
# return $this->options->connections->create($parameters);
# }
# if (is_array($parameters)) {
# if (!isset($parameters[0])) {
# return $this->options->connections->create($parameters);
# } $options = $this->options;
# if ($options->defined('aggregate')) {
# $initializer = $this->getConnectionInitializerWrapper($options->aggregate);
# $connection = $initializer($parameters, $options);
# } else {
# if ($options->defined('replication') && $replication = $options->replication) {
# $connection = $replication;
# } else {
$connection = $options->cluster; //
# } $options->connections->aggregate($connection, $parameters);
# }
return $connection;
# }
# if (is_callable($parameters)) {
# $initializer = $this->getConnectionInitializerWrapper($parameters);
# $connection = $initializer($this->options);
# return $connection;
# }
# throw new \InvalidArgumentException('Invalid type for connection parameters.');
}
Predis\Configuration\Options;
protected function getHandlers()
{
return array( 'cluster' => 'Predis\Configuration\ClusterOption', 'connections' => 'Predis\Configuration\ConnectionFactoryOption',
#'exceptions' => 'Predis\Configuration\ExceptionsOption',
#'prefix' => 'Predis\Configuration\PrefixOption',
#'profile' => 'Predis\Configuration\ProfileOption',
#'replication' => 'Predis\Configuration\ReplicationOption',
);
}
public function __get($option)
{
#if (isset($this->options[$option]) || array_key_exists($option, $this->options)) {
# return $this->options[$option];
#} if (isset($this->input[$option]) || array_key_exists($option, $this->input)) { $value = $this->input[$option];
unset($this->input[$option]);
# if (is_object($value) && method_exists($value, '__invoke'){
# $value = $value($this, $option);
# } if (isset($this->handlers[$option])) { $handler = $this->handlers[$option]; $handler = new $handler(); //会实例化Predis\Configuration\ClusterOption类
$value = $handler->filter($this, $value);
}
return $this->options[$option] = $value;
}
# if (isset($this->handlers[$option])) {
# return $this->options[$option] = $this->getDefault($option);
# }
# return;
}
Predis\Configuration\ClusterOption文件
public function filter(OptionsInterface $options, $value)
{ if (is_string($value)) { $value = $this->createByDescription($options, $value);
}
# if (!$value instanceof ClusterInterface) {
# throw new \InvalidArgumentException(
# "An instance of type 'Predis\Connection\Aggregate\ClusterInterface' was expected."
# );
# }
return $value;
}
protected function createByDescription(OptionsInterface $options, $id)
{
switch ($id) {
* Abstraction for a cluster of aggregate connections to various Redis servers
* implementing client-side sharding based on pluggable distribution strategies.
# case 'predis':
# case 'predis-cluster':
# return new PredisCluster();
//这个模式是客户端通过CRC16算法在客户端进行数据切片,
显然这种模式的集群是脆弱的,如果一个master节点挂了，
那其备节点若也挂了，那么获取数据就成问题了;
再有这种模式扩展性很差,维护成本高,
因此这个模式不推荐.当然用最新predis不存在这个问题.
我这边predis,1.0算比较老了.
case 'redis':
case 'redis-cluster':
return new RedisCluster($options->connections); //这种模式是基于服务端的数据切片，相较于第一种模式，优点也显而易见,维护成本低,扩展性好等.
default:
return;
}
}
public function __get($option)
{
#if (isset($this->options[$option]) || array_key_exists($option, $this->options)) {
# return $this->options[$option];
#}
# if (isset($this->input[$option]) || array_key_exists($option, $this->input)) {
# $value = $this->input[$option];
# unset($this->input[$option]);
# if (is_object($value) && method_exists($value, '__invoke'){
# $value = $value($this, $option);
# }
# if (isset($this->handlers[$option])) {
# $handler = $this->handlers[$option];
# $handler = new $handler();
# $value = $handler->filter($this, $value);
# }
# return $this->options[$option] = $value;
#} if (isset($this->handlers[$option])) { //$options='connections'
return $this->options[$option] = $this->getDefault($option);
# }
# return;
}
public function getDefault($option)
{ if (isset($this->handlers[$option])) { $handler = $this->handlers[$option]; //$handler = 'Predis\Configuration\ConnectionFactoryOption';
$handler = new $handler();
return $handler->getDefault($this);
}
}
Predis\Configuration\ConnectionFactoryOption文件
public function getDefault(OptionsInterface $options)
{
return new Factory(); //最后实例化了一个'工厂'类
}ログイン後にコピー
$this->profile = $this->options->profile;
Predis\Configuration\ProfileOption文件
public function __get($option)
{
#if (isset($this->options[$option]) || array_key_exists($option, $this->options)) {
# return $this->options[$option];
#}
# if (isset($this->input[$option]) || array_key_exists($option, $this->input)) {
# $value = $this->input[$option];
# unset($this->input[$option]);
# if (is_object($value) && method_exists($value, '__invoke'){
# $value = $value($this, $option);
# }
# if (isset($this->handlers[$option])) {
# $handler = $this->handlers[$option];
# $handler = new $handler();
# $value = $handler->filter($this, $value);
# }
# return $this->options[$option] = $value;
#} if (isset($this->handlers[$option])) { //$options='profile'
return $this->options[$option] = $this->getDefault($option);
# }
# return;
}
public function getDefault($option)
{ if (isset($this->handlers[$option])) { $handler = $this->handlers[$option]; //$handler = 'Predis\Configuration\ProfileOption';
$handler = new $handler();
return $handler->getDefault($this);
}
}
Predis\Configuration\ProfileOption文件
public function getDefault(OptionsInterface $options)
{ $profile = Factory::getDefault(); //实例化了Predis\Profile\RedisVersion300类
$this->setProcessors($options, $profile);
return $profile;
}ログイン後にコピー
以上がlaravel5.2とredis_cluster設定の概要の詳細内容です。詳細については、PHP 中国語 Web サイトの他の関連記事を参照してください。
![[Web フロントエンド] Node.js クイック スタート](https://img.php.cn/upload/course/000/000/067/662b5d34ba7c0227.png)
