# Redis
[TOC]
SD提供了Redis异步连接池,连接池的使用和正常Redis扩展一样。
## 创建Redis连接池
在SD的initAsynPools方法中已经创建好了redis和mysql默认的连接池。
```
/**
* 初始化各种连接池
* @param $workerId
*/
public function initAsynPools($workerId)
{
$this->asynPools = [];
if ($this->config->get('redis.enable', true)) {
$this->asynPools['redisPool'] = new RedisAsynPool($this->config, $this->config->get('redis.active'));
}
if ($this->config->get('mysql.enable', true)) {
$this->asynPools['mysqlPool'] = new MysqlAsynPool($this->config, $this->config->get('mysql.active'));
}
$this->redis_pool = $this->asynPools['redisPool'] ?? null;
$this->mysql_pool = $this->asynPools['mysqlPool'] ?? null;
}
```
如果你想创建多个Redis连接池可以仿照上面的方法。
```
$this->addAsynPool('redisPool2', new RedisAsynPool($this->config, ‘redis2’);
```
## 获取Redis连接池
在Controller,Model,Task共同的基类CoreBase中默认获取了RedisPool。
```
/**
* 当被loader时会调用这个方法进行初始化
* @param $context
*/
public function initialization(&$context)
{
$this->setContext($context);
$this->redis = $this->loader->redis("redisPool");
$this->db = $this->loader->mysql("mysqlPool",$this);
}
```
## 使用方法
Redis的使用方法和PhpRedis扩展一致,可以参考ServerRedisTest,这是关于Redis的测试用例。
```
$value = $this->redis->set('test', 'testRedis');
```
## Redis-LUA
SD支持Redis-LUA,根目录下有个名为lua的文件夹,这里的lua脚本都会自动被SD加载进Redis中。
```
public function http_testRedisLua()
{
$value = $this->redis->evalSha(getLuaSha1('sadd_from_count'), ['testlua', 100], 2, [1, 2, 3]);
$this->http_output->end($value);
}
```
通过evalSha和getLuaSha1方法配合我们可以非常容易的使用Redis-LUA功能。其中sadd_from_count是lua文件夹某一个lua脚本的文件名。
在SD启动时我们也能看到加载了哪些lua脚本,如果redis服务器不支持lua也会有相应的提示。
![](https://box.kancloud.cn/6aa55e3de0a42ad861f98374ab792608_512x148.png)
## 同步Redis
```
$redisSync = $this->redis_pool->getSync();
```
通过getSync返回一个同步的redis连接。
- SD3.X简介
- 捐赠SD项目
- VIP服务
- 基础篇
- 搭建环境
- 使用Composer安装/更新SD框架
- 启动命令
- 开发注意事项
- 框架配置
- 配置文件夹
- server.php
- ports.php
- business.php
- mysql.php
- redis.php
- timerTask.php
- log.php
- consul.php
- catCache.php
- client.php
- 自定义配置
- 框架入口
- MVC架构
- 加载器-Loader
- 控制器-Controller
- 模型-Model
- 视图-View
- 同步任务-Task
- 封装器
- Swoole编程指南-EOF协议
- Swoole编程指南-固定包头协议
- 封装器-Pack
- 路由器
- TCP相关
- 绑定UID
- Send系列
- Sub/Pub
- 获取服务器信息
- Http相关
- HttpInput
- HttpOutput
- 默认路由规则
- WebSocket相关
- 使用SSL
- 公共函数
- 进阶篇
- 内核优化
- 封装器路由器原理剖析
- 对象池
- 上下文-Context
- 中间件
- 进程管理
- 创建自定义进程
- 进程间RPC
- 自定义进程如何使用连接池
- 异步连接池
- Redis
- Mysql
- Mqtt
- HttpClient
- Client
- AMQP
- RPC
- 日志工具-GrayLog
- 微服务-Consul
- Consul基础
- 搭建Consul服务器
- SD中Consul配置
- 微服务
- 选举-Leader
- Consul动态配置定时任务
- 熔断与降级
- 集群-Cluster
- 高速缓存-CatCache
- 万物-Actor
- Actor原型
- Actor的创建
- Actor间的通讯
- 消息派发-EventDispatcher
- 延迟队列-TimerCallBack
- 协程
- 订阅与发布
- MQTT简易服务器
- AMQP异步任务调度
- 自定义命令-Console
- 调试工具Channel
- 特别注意事项
- 日常问题总结
- 实践案例
- 物联网自定义协议
- Actor在游戏的应用
- Mongodb以及一些同步扩展的使用
- 自定义进程使用MQTT客户端
- 开发者工具
- SDHelper