## 1 pub sub
### 1.1 sub 端
~~~
public static function redisSub(){
/**
* redis sub(消息订阅端)
*/
$redis = new Redis();
$res = $redis->pconnect('127.0.0.1', 6379,0);
$redis->auth('XXX');//密码
$redis->setOption(Redis::OPT_READ_TIMEOUT, -1);//超时时间
$redis->subscribe(array('exampleTopic'), 'callback');
}
// 回调函数,自己的处理逻辑
public static function callback($instance, $channelName, $message)
{
switch ($channelName) {
case 'exampleTopic'://调用自定义的接口,执行业务逻辑
Post('https://xxx.com/Xxx/Xx/xx');
break;
default:
}
}
~~~
### 1.2 pub 端
~~~
//redis发布端
public static function RedisPub(){
$redis = new Redis();
$res = $redis->pconnect('127.0.0.1', 6379,0);
// ... 业务了逻辑
//业务逻辑结束 发布订阅消息
$redis->PUBLISH('exampleTopic ', '消息');
}
~~~
## 2 、counter
~~~
public static function redisCounter(){
$value = Mod::app()->redis->incr('website_visitors');
Mod::app()->redis->expire('website_visitors', 1);
echo "Total website visitors: " . $value . ".";
}
~~~
## 3 、 set
~~~
public static function RedisS(){
Mod::app()->redis->delete('s');
Mod::app()->redis->sAdd('s', 5);
Mod::app()->redis->sAdd('s', 4);
Mod::app()->redis->sAdd('s', 2);
Mod::app()->redis->sAdd('s', 1);
Mod::app()->redis->sAdd('s', 3);
var_dump(Mod::app()->redis->sort('s')); // 1,2,3,4,5
var_dump(Mod::app()->redis->sort('s', array('sort' => 'desc'))); // 5,4,3,2,1
var_dump(Mod::app()->redis->sort('s', array('sort' => 'desc', 'store' => 'out'))); // (int)5
// SISMEMBER "1" 1是否在s里
}
~~~
## 4、hash
~~~
public static function RedisH(){
Mod::app()->redis->delete('h');
Mod::app()->redis->hSet('h', 'key1', 'hello'); /* 1, 'key1' => 'hello' in the hash at "h" */
Mod::app()->redis->hGet('h', 'key1'); /* returns "hello" */
Mod::app()->redis->hSet('h', 'key1', 'plop'); /* 0, value was replaced. */
Mod::app()->redis->hGet('h', 'key1'); /* returns "plop" */
}
~~~
## 5 list
~~~
public static function RedisList(){
/* Non blocking feature */
Mod::app()->redis->lPush('key1', 'A');
Mod::app()->redis->delete('key2');
Mod::app()->redis->blPop('key1', 'key2', 10); /* array('key1', 'A') */
/* OR */
Mod::app()->redis->blPop(array('key1', 'key2'), 10); /* array('key1', 'A') */
Mod::app()->redis->brPop('key1', 'key2', 10); /* array('key1', 'A') */
/* OR */
Mod::app()->redis->brPop(array('key1', 'key2'), 10); /* array('key1', 'A') */
/* Blocking feature */
/* process 1 */
Mod::app()->redis->delete('key1');
Mod::app()->redis->blPop('key1', 10);
/* blocking for 10 seconds */
/* process 2 */
Mod::app()->redis->lPush('key1', 'A');
/* process 1 */
/* array('key1', 'A') is returned*/
}
~~~
### Redis和Memcached的区别
~~~
* Redis和Memcache都是将数据存放在内存中,都是内存数据库。但是Memcache还可以缓存其他东西,比如图片、视频
*
* Redis不只支持简单的k/v类型的数据,同时还提供list、set、hash等数据结构的存储
*
* 虚拟内存,当物理内存用完时Redis可以将一些很久没有用到的value交换到磁盘
*
*
过期策略,memcache在set时就指定,例如`set key1 0 0 8`即永不过期,redis可以通过expire设定,例如:`expire name 10`
*
*
分布式,设定memcache集群,利用magent做一主多从;redis也可以做一主多从。
*
*
存储安全,memcache挂掉后,数据没了;redis可以定期保存在磁盘(持久化)
*
*
灾难恢复,memcache挂掉后数据不可恢复;redis数据丢失后可以通过aof恢复
*
*
redis支持数据的备份,即master-slave模式的数据备份
*
*
应用场景不同:redis除了可以做nosql数据库之外,还能做消息队列、数据堆栈和数据缓存等。memcache适合于缓存sql语句、数据集、用户临时性数据、延迟查询数据和session等
~~~
### redis有哪些数据结构
* String
~~~
字符串类型是redis最基础的数据结构,首先键是字符串类型,而且其他几种结构都是在字符串类型基础上构建的
字符串类型实际上可以是字符串、数字、二进制(图片、音频),单最大不能超过512M
~~~
使用场景:
~~~
1. 缓存
字符串最经典的使用场景,redis作为缓存层,mysql作为存储层,绝大部分请求数据都是redis中获取,由于redis具有支撑高并发特性,所以缓存通常能起到加速读写和降低后端压力的作用
2. 计数器
许多应用都会使用redis作为技术的基础工具,它可以实现快速技术、查询缓存的功能。
3. 共享session
处于负载均衡的考虑,分布式服务会将用户信息的访问均衡到不同服务器,用户刷新一次访问可讷讷个会需要重新登录,为了避免这个问题可以使用redis将用户session集中管理,在这种模式下只要保证redis的高可用和扩展性,每次获取用户更新或查询登录信息都直接从redis中集中获取
4. 限速
出于安全考虑,每次进行登录时让用户输入手机验证码,为了短信接口不被频繁访问,会限制用户每分钟获取验证码的频率
~~~
* Hash
在redis中哈希类型是指键本身又是一种键值对结构,如`value = {{field1,value1}...{fieldn,valuen}}`
使用场景:
1. 哈希结构相对于字符串序列化缓存信息更加直观,并且在更新操作上更加便捷。
* list
~~~
列表类型是用来存储多个有序的字符串,列表的每个字符串成为一个元素,一个列表最多可以存储2的32次方减1个元素。在redis中,可以对列表插入(push)和弹出(pop),还可以获取指定范围的元素列表。列表是一种比较灵活的数据结构,它可以充当栈和队列的角色。
~~~
使用场景:
1. 消息队列
redis的`lpush+brpop`命令组合就可以实现阻塞队列,生产者客户端是用`lpush`从列表左侧插入元素,多个消费者客户端使用`brpop`命令阻塞式的抢列表尾部的元素,多个客户端保证了消费的负载均衡的高可用性。
2. 使用技巧列表
~~~
lpush+lpop=Stack(栈)
lpush+rpop=Queue(队列)
lpush+ltrim=Capped Collection(有限集合)
lpush+brpop=Message Queue(消息队列)
~~~
* set
* sortedset