YIIRedisConnection.php
2.39 KB
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
<?php
namespace common\components\redis;
use common\components\redis\transaction\MultiExec as MultiExecTransaction;
/**
* 兼容 "yii-redis"扩展的类 运行 yii 的 "composer require yiisoft/yii2-redis" 集成
* Class YIIRedisConnection
* @package common\components\redis
*/
class YIIRedisConnection extends BaseConnection
{
/**
* @var float 使用redis socket 读和写操作的超时时间. 如果没有被设置，那么PHP的默认设置:Socket连接超时间将会被启用.
*/
public $dataTimeout;
public function init()
{
if (!class_exists('\yii\redis\Connection')) {
throw new \Exception('the extension yii\redis\Connection does not exist ,you need it to operate redis ,you can run "composer require yiisoft/yii2-redis" to gei it!');
}
if (null === $this->connection) {
$this->connection = \Yii::createObject([
'class' => 'yii\redis\Connection',
'hostname' => $this->hostname,
'password' => $this->password,
'port' => $this->port,
'database' => $this->database,
'connectionTimeout' => $this->connectionTimeout,
'dataTimeout' => $this->dataTimeout
]);
}
}
/**
* 当前驱动器名称，yii redis 和 php redis 两种，一个是yii2的redis扩展，一个是PHP的C扩展
* @return string 当前驱动器名称
*/
public function getDriverName()
{
return 'yii redis';
}
/**
* 打开一个REDIS连接
* 如果已经打开过了，直接返回，什么都不做。
* @throws Exception 连接失败
*/
public function getIsActive()
{
return $this->connection->getIsActive();
}
/**
* 打开一个REDIS连接
* It does nothing if a DB connection has already been established.
* @throws Exception if connection fails
*/
public function open()
{
$this->connection->open();
}
/**
* 关闭当前REDIS连接
*/
public function close()
{
$this->connection->close();
}
/**
* 代理 yii\redis\Connection 对应的方法
* @param $name
* @param $params
* @return mixed
*/
protected function call($name, $params)
{
$name = strtoupper($name);
return call_user_func_array([$this->connection, $name], $params);
}
}