学了redis不会实战？看这篇就够了

适用人群：了解redis的指令，但不了解运用场景的人群。

本文会详细描绘各个场景的伪代码和对应的redis指令，至于为什么只是伪代码是由于每个语言操作redis的方式不一致，可是思维是一致的，只需求依据这个思维去找对应的api即可。

String 指令实战

String的指令主要是有三大运用场景：分别是分布式锁的运用，限流操作和事务缓存。

1.事务缓存

场景复现：某个活动即将在 11月11日开展。预期数据库的拜访压力陡增。

解决方案：运用Redis，提早将要被多次拜访的数据放入redis，做到“缓存预热”。让用户进入咱们活动页面的时分，先去搜索缓存，不直接拜访数据库，做到开释数据库的压力。

对应redis中的指令

set data "data"
​
get data

伪代码

void cacheData(){
    //1.从数据库中获取热门数据
    //2.将此类数据序列化
    //3.将 (data-data的id) 作为key，序列化的data作为value,运用string的set方法，存入redis。将活动的持续时刻作为TTL
  
}
​
void getData(id){
    //1.将data和id拼接作为key,依据key聪redis中依据string的get指令，进行查询。
    //2.1查询到，直接回来
    //2.2没有查询到，依据id去数据库中查找，假如有，就直接回来，并存入redis中。
}

2.分布式锁

场景复现：多个服务去争夺资源，有并发，线程安全问题。

解决方案：运用redis的set … nx指令，完成分布式锁的作用。

为什么它叫分布式锁呢？其实是由于多个服务都能够连接到一个redis中，相当于，水库里的水许多，可是总要从一个管道里流出一样，这个管道就相当于操控，同一时刻内，只要一部分水能够流出。

对应redis中的指令

set key value NX

当方针key不存在的时分，才答应写入这个key，假如key已经存在，这个key就写不进去

伪代码

void tryLock(id){
    //1.不断抢锁直到抢到
    while(true){
        //1.1.把 (update+传入的id)作为key,当时线程的称号作为value,运用nx指令，设置5s的过期时刻(避免由于体系原因未能开释，则导致锁无法开释，这是兜底办法)
        //1.2.1.假如1.1过程失利，阐明抢锁失利，进入下一次循环，继续抢锁。
        //1.2.2.假如成功，就break，结束循环    
    }
    //2.履行事务逻辑
    //3.删去 (update+传入的id)的key的值，相当于开释锁。
}

3.限流

场景复现：高并发场景下，抢购，秒杀等，流量峰值很高，可是后端事务的资源很有限。

解决方案：假如后端资源只够1000qps，那么咱们可能就得对高于这个值的qps做限流，高于它的部分可能就得做降级处理了。

对应redis中的指令

set age 25
//回来：OK
INCR age
//回来：26

伪代码

void limit(){
    //1.取到当时的时刻戳
    Long now = currentTimeMilles()
    //2.将当时服务名+now做为key,每打过来一个恳求，就把这个value运用INCR指令+1。
    //3.假如当时value > 1000 qps,那么就直接回来“恳求限流”
    //4.假如 value < 1000 qps,那么履行恳求。
}

List 指令实战

List指令主要是有三大运用场景：音讯行列，提示功用和热门列表。

可是由于音讯行列的音讯丢掉问题很难处理，因此咱们主要讲提示功用和热门列表。

1.提示功用

尽管说Redis的list能够完成音讯行列的作用，可是运用Redis的list完成音讯行列时分，在音讯弹出，可是顾客没有消费前，顾客假如宕机，此条音讯就会直接丢掉。所以说，除非你的场景里，音讯是能够接受丢掉的，例如咱们要说的提示功用，否则尽量不要用它作为音讯行列。

场景复现：我是一个作者，当有掘友给我点赞的时分，我需求接纳到点赞信息，而且给予反馈。

解决方案：后端在接受点赞音讯后，将点赞人push到点赞List中，当我（作者）登录网站的时分，前端给后端恳求点赞的list。

对应Redis中的指令

//从右侧push
RPUSH 调集称号 调集元素
//从左边遍历 下标1到下标2的一切元素
LRANGE 调集称号 下标1 下标2
//从左边截断，下标1之前的一切元素，回来下标1到下标2的一切元素
LTRIM 调集称号 下标1 下标2

伪代码

void likeList(){
​
    String listName = "like-" + articleId
//开启一个线程，模仿用户端点赞,此时有10000人
    for(int i=0;i<10000;i++){
        //将listName作为list的key,用户id作为value,运用rpush指令，参加list
    }   
//再开启一个线程，模仿作者端
    while(true){
        //1.运用LRANGE指令，拉取前1000个人的点赞。
        //2.读取，而且展示。
        //3.展示完成后，运用LTRIM指令，把第一步回来的userId的size大小作为下标1，-1作为下标2，履行该指令。相当于把前1000个userIds截断掉
    }
}

2.热门列表

其实上述的提示功用的实质便是对list里边的音讯进行消费，便是音讯行列里的生产者和顾客形式。

List还有一个常见的形式便是热门列表，或许是微博上的话题列表等。

对应Redis中的指令

//从右侧push
RPUSH 调集称号 调集元素
//从左边数下标，设置该下标对应的值
LSET 调集称号 下标 值
//从左边遍历 下标1到下标2的一切元素
LRANGE 调集称号 下标1 下标2

伪代码

//守时任务更新热门列表
void updateHotList(){
	//1.从数据库中计算得出最炽热的20条数据
	//2.运用lset指令，依据下标更新当时李彪数据
}
        //客户端拉取热门列表
	//1.依据lrange指令找到一切的热门，回来

Hash 指令实战

hash的数据结构咱们知道，适用于存储键值比照较多的调集。下面咱们以两个实战来讲解，分别是用户资料缓存和购物车的存储。

1.用户资料缓存

场景复现：咱们知道，在复杂的体系中，c端用户的信息是十分多的，可能有几十个字段用来描绘这个用户。且该信息拜访的次数也是许多。

解决方案：放弃将用户信息序列化成字符串的方式，该用Hash方式进行存储。咱们用手机电话作为key，用户信息方针作为value进行存储。而且对活跃用户进redis缓存，非活跃用户留在mysql中。

对应redis中的指令

//获取key下的一切hash键值对
hgetall key
//设置key ，hash的键值对
hset key k1 v1 k2 v2 k3 v3

伪代码

void login(mobile){
	//1.获取key
	String key = "login:" + mobile
	//2.依据hgetall指令获取该用户的一切信息
	//3.1.假如回来的信息不为空
	//3.1.1.假如value里没有标识符，直接回来脱敏后的用户信息
	//3.1.2.假如value里有标识符，阐明这个人没有注册却一直在登录，有想让咱们缓存击穿的嫌疑，直接回来“未注册”即可
	//3.2.假如为空
	//3.2.1.从数据库中获取登录方针
	//3.2.1.1.假如数据库回来是空，阐明没有注册，将该key存入redis,value给一个标识符，标识它未注册（避免缓存击穿）。
	//3.2.1.2.假如数据库回来不是空，就把这个用户数据运用Hallset指令，存入redis，阐明他是热门用户。回来当时用户数据
}

什么是缓存击穿？

很多数据打入热门key，此时key失效，数据直接打入数据库，让数据库压力剧增

2.购物车实战

场景复现：比较咱们都用过淘宝吧，淘宝里有购物车功用。便是当用户选好产品，会先放入购物车，能够到达一同支付的作用。

问题解决：其实这个场景有两种解决思路。第一是购物车的数据存入前端。但前端做不到在用户挑选产品到购物车的时分，就做好了库存查看的此类操作，需求提交购物车的时分，后端回来。用户体会有缺失的。因此，咱们能够用后端对购物车进行存储。这个需求依据场景进行衡量。

对应redis中的指令

//获取key下的一切hash键值对
hgetall key
//设置key ，hash的键值对
hset key k1 v1 k2 v2 k3 v3
//删去该key对应的hash结构里的k1 k2 k3
hdel key k1 k2 k3

伪代码

static CART_PREFIX = "cart:"
void add(userId，productId,prodNum){
	String key = CART_PREFIX + userId
	//运用hset把CART_PREFIX + userId作为key，productId作为k1,prodNum作为value进行存储
}
void remove(userId，productId){
	String key = CART_PREFIX + userId
	//运用hdel把CART_PREFIX + userId作为key，productId作为k1进行删去
}
void submitOrder(userId){
	String key = CART_PREFIX + userId
	//运用hgetall进行购物车内容的获取
}

Set指令实战

Set指令的对应实战场景主要有俩，分别是标签体系和自适应是非名单体系。

1.标签体系

场景复现：在文章宣布的过程中，需求给文章贴上标签【”java”,”后端”】。你的个人资料里可能也有标签，比如说，你是学什么的，你的才能等，这些都是你的标签。咱们可能需求依据你的个人信息里的标签，给你引荐合适你的文章。

对应redis中的指令

//将set1中增加"a"元素
SADD set1 "a"
//从set1,set2,set3中找到交集并回来
SINTER set1 set2 set3

伪代码

productTag(){
	String articleTagKey = "tag_a_" + articleId
	//将这几个标签参加这个文章中
	sadd(articleTagKey,"java","后端","设计形式","数据库")
	String userTagKey = "tag_u_" + userId
	//
	sadd(userTagKey,"程序员","java");
	//将用户标签调集和一切的文章标签调集，运用sinter指令做交集，假如交集数量大于一个值，就做引荐。
}

除了这种最基本的标签匹配的引荐体系之外。像微博会有共同重视的功用，底层也是基于这个思维的引荐体系。例如张三和我有类似的标签，假如他喜欢的东西，重视的东西，可能也会引荐给我，由于咱们是一类人。

包括像qq里边的老友引荐功用，有的陌生老友，下方显现，和你有多少相同的老友，也基本是能够基于sinter指令来完成的。

2.自适应是非名单体系

场景复现：某个用户异地登录，或许账户被盗，或许突然下单很多不感兴趣的产品，被风控检测。

问题解决：能够在检测到之后，把userId放入set黑名单中，运用一些安全框架，对这些黑名单做接口约束，前端也需求约束，除非他同意做人脸辨认或许短信验证的安全认证，做完之后，能够从黑名单中移除。

对应redis中的指令

//将set1中增加"a"元素
SADD set1 "a"
//查看a是否在set1中
SISMEMBER set1 "a"
//将a从set1中删去
SREM set1 "a"

伪代码

boolean addProduct(userId,productId){
	//1.运用SISMEMBER指令检测是否在黑名单中，假如是就直接如人脸验证，或许短信验证
	//2.假如没有就答应恳求
}
void faceCheck(userId){
	//1.人脸检测
	//2.检测完成
	//3.运用HREM指令删去黑名单
}

Sorted Set指令实战

Sorted Set又名Zset。主要有两种运用场景，分别是积分排名和延时音讯。

1.积分排名

场景复现：比如，lol中的rank排行榜，在峡谷之巅第一名是恶魔波刚，第二名是jjking，第三名是菠萝剑姬。这样的体系怎么完成呢？

问题解决：运用Sorted Set解决。

对应redis中的指令

//往myzset参加两个值。分数-玩家名的键值对
ZADD myzset 100 jjking 90 恶魔波冈
//查询方针的score值
ZSCORE myzset jjking
//批量查询方针的score值
ZSCORE myzset jjking 恶魔波刚
//增加指定元素的score值
ZINCREBY myzset 20 jjking
回来："120"
//将myzset中140分-80分的数据带着score逆序且约束2条回来
ZRANGE myzset 140 80 BYSCORE REV WITHSCORES limit 2

伪代码

//玩家胜利后，加分
addScore(){
	String rankKey = "rank_"
	//给指定玩家加分，运用ZINCREBY指令
	zaddIncr(rankKey,point,playerId)
}
//取前2名
getRankList(){
	//依据上述对应redis指令：ZRANGE myzset BYSCORE REV WITHSCORES limit 2
}

2.延时音讯

场景复现：有些分布式任务体系中，任务是有优先级的，体系需求触发高优先级的任务，再触发低优先级的任务。

对应redis中的指令

//往myzset参加两个值。分数-玩家名的键值对
ZADD myzset 100 jjking 90 恶魔波冈
//计数数某个规模内的值
ZCOUNT myzset 70 110
回来：2
//将最小元素pop出来，数字是pop出来的数量
ZPOPMIN myzset 1

伪代码

//增加延时信息
addDelayMessage(){
    //获取当时时刻
    int current = currentTimeMillis()
    //在10000之后开端
    int startTime = current + 10000
    //运用zadd指令增加         zadd("delayMsgCenter",startTime ,"task_" + taskId);
  
}
​
//消费延时音讯
consumeDelayMessage(){
    //1.运用zcount和 0到current的规模进行搜索回来。
    //2.1假如回来的数值小于0，阐明没有延时音讯。
    //2.2假如回来的数值大于0，阐明有延时音讯，那就把这个延时行列里的最小值，运用ZPOPMIN的方式，弹出，消费
    //2.2.1履行消费
}