## 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