SpringBoot+Redis實現(xiàn)點贊功能的緩存和定時持久化（附源碼）

0.前言

本文基于Springboot利用Redis實現(xiàn)點贊功能的緩存和定時持久化接口。

用戶對瀏覽內(nèi)容進行【點贊/取贊】，并發(fā)送【點贊/取贊】請求到后端，這些信息先存入Redis中緩存，再每隔兩小時將Redis中的內(nèi)容直接寫入數(shù)據(jù)庫持久化存儲。

1.項目目錄結(jié)構(gòu)

2.Redis緩存點贊消息

1.設(shè)計思路

用戶點贊一條數(shù)據(jù)，設(shè)置狀態(tài)為0，并且更新被點贊內(nèi)容的likeCount+1

用戶取消點贊一條數(shù)據(jù)，設(shè)置狀態(tài)為1，并且更新被點贊內(nèi)容的likeCount+0

1.1 Redis鍵值對設(shè)計

選用Hash（散列）存儲

點贊信息

• key: (String) 瀏覽信息id和點贊用戶id拼接而成, 分隔符為::
• value: (HashMap) 存儲點贊狀態(tài)(0: 點贊 1:取消點贊)和更新時間的時間戳
• key: "瀏覽信息id::點贊用戶id" value: {status: Integer, updateTime: long}

點贊數(shù)量

• key: (String) 瀏覽信息id
• value: (Integer) 點贊數(shù)量

1.2 點贊

• 用戶點贊信息，發(fā)送點贊請求到后端
• 后端判斷該點贊信息在Redis中的狀態(tài)
  • Redis不進行存儲，并提醒前端重復(fù)存儲。
  • 更新/新增點贊信息
  • 更新/新增點贊量
  • 【不存在（沒有對應(yīng)key) 】|| 【取消點贊（即取出的status為1）】
  • 【點贊（即取出的status為0，此時相當于重復(fù)點贊行為）】
• 一次點贊請求完畢

1.3 取消點贊

• 用戶取消點贊信息，發(fā)送取消點贊請求到后端
• 后端判斷該點贊信息在Redis中的狀態(tài)
  • 更新/新增點贊信息
  • 更新/新增點贊量
  • Redis不進行存儲，并提醒前端重復(fù)存儲。
  • 更新/新增點贊信息
  • 增加0條內(nèi)容點贊量
  • 【不存在（沒有對應(yīng)key) 】
  • 【取消點贊（即取出的status為1，此時相當于重復(fù)取消點贊行為）】
  • 【點贊（即取出的status為0）】
• 一次取消點贊請求完畢

2.核心代碼實現(xiàn)

2.1 Redis封裝

具體實現(xiàn)參考該博客，不在贅述。

• https://www.cnblogs.com/caizhaokai/p/11037610.html

2.2 工具類

1.時間戳轉(zhuǎn)化為LocalDateTime

importjava.time.Instant;
importjava.time.LocalDateTime;
importjava.time.ZoneId;

/**
*工具類：將時間戳轉(zhuǎn)化為LocalDateTime
*主要是因為redis不好存儲LocalDateTime，存儲timestamp方便一點，而且格式可以隨意改變
*/
publicclassLocalDateTimeConvertUtil{
publicstaticLocalDateTimegetDateTimeOfTimestamp(longtimestamp){
Instantinstant=Instant.ofEpochMilli(timestamp);
ZoneIdzone=ZoneId.systemDefault();
returnLocalDateTime.ofInstant(instant,zone);
}
}

2.RedisKey處理類

publicclassRedisKeyUtils{
/**
*
保存用戶點贊內(nèi)容數(shù)據(jù)的key
*@date2021/9/2614:44
*/
publicstaticfinalStringMAP_KEY_USER_LIKED="MAP_USER_LIKED";
/**
*
保存內(nèi)容被點贊數(shù)量的key
*@date2021/9/2614:44
*/
publicstaticfinalStringMAP_KEY_USER_LIKED_COUNT="MAP_USER_LIKED_COUNT";

/**
*拼接被點贊的內(nèi)容id和點贊的人的id作為key。格式222222::333333
*@paraminfoId被點贊的內(nèi)容id
*@paramlikeUserId點贊的人的id
*@return
*/
publicstaticStringgetLikedKey(StringinfoId,StringlikeUserId){
returninfoId+
"::"+
likeUserId;
}
}

2.3 DTO

//UserLikesDTO.java
@Data
@AllArgsConstructor
@NoArgsConstructor
publicclassUserLikesDTO{
privateStringinfoId;
privateStringlikeUserId;
privateIntegerstatus;
privateLocalDateTimeupdateTime;
}

//UserLikeCountDTO.java
@Data
@AllArgsConstructor
@NoArgsConstructor
publicclassUserLikeCountDTO{
privateStringinfoId;
privateIntegerlikeCount;
}

2.4 Service

1. interface

//RedisService.java

importcom.csu.edu.redisLikeDemo.domain.DTO.UserLikeCountDTO;
importcom.csu.edu.redisLikeDemo.domain.DTO.UserLikesDTO;

importjava.util.List;

/**
*負責(zé)將數(shù)據(jù)寫入Redis緩存
*/
publicinterfaceRedisService{
/**
*獲取點贊狀態(tài)
*@paraminfoId
*@paramlikeUserId
*/
IntegergetLikeStatus(StringinfoId,StringlikeUserId);
/**
*點贊。狀態(tài)為1
*@paraminfoId
*@paramlikeUserId
*/
voidsaveLiked2Redis(StringinfoId,StringlikeUserId);

/**
*取消點贊。將狀態(tài)改變?yōu)?
*@paraminfoId
*@paramlikeUserId
*/
voidunlikeFromRedis(StringinfoId,StringlikeUserId);

/**
*從Redis中刪除一條點贊數(shù)據(jù)
*@paraminfoId
*@paramlikeUserId
*/
voiddeleteLikedFromRedis(StringinfoId,StringlikeUserId);

/**
*該內(nèi)容的點贊數(shù)變化Δdelta
*@paraminfoId
*/
voidin_decrementLikedCount(StringinfoId,Integerdelta);

/**
*獲取Redis中存儲的所有點贊數(shù)據(jù)
*@return
*/
ListgetLikedDataFromRedis();

/**
*獲取Redis中存儲的所有點贊數(shù)量
*@return
*/
ListgetLikedCountFromRedis();
}

2. implement

importcom.csu.edu.redisLikeDemo.common.CONSTANT;
importcom.csu.edu.redisLikeDemo.domain.DTO.UserLikeCountDTO;
importcom.csu.edu.redisLikeDemo.domain.DTO.UserLikesDTO;
importcom.csu.edu.redisLikeDemo.service.RedisService;
importcom.csu.edu.redisLikeDemo.util.LocalDateTimeConvertUtil;
importcom.csu.edu.redisLikeDemo.util.RedisKeyUtils;
importlombok.extern.slf4j.Slf4j;
importorg.springframework.beans.factory.annotation.Autowired;
importorg.springframework.data.redis.core.Cursor;
importorg.springframework.data.redis.core.HashOperations;
importorg.springframework.data.redis.core.ScanOptions;
importorg.springframework.stereotype.Service;

importjava.time.LocalDateTime;
importjava.util.ArrayList;
importjava.util.HashMap;
importjava.util.List;
importjava.util.Map;

@Service("redisService")
@Slf4j
publicclassRedisServiceImplimplementsRedisService{

@Autowired
privateHashOperationsredisHash;//RedisHash

@Override
publicIntegergetLikeStatus(StringinfoId,StringlikeUserId){
if(redisHash.hasKey(RedisKeyUtils.MAP_KEY_USER_LIKED,RedisKeyUtils.getLikedKey(infoId,likeUserId))){
HashMapmap=(HashMap)redisHash.get(RedisKeyUtils.MAP_KEY_USER_LIKED,RedisKeyUtils.getLikedKey(infoId,likeUserId));
return(Integer)map.get("status");
}
returnCONSTANT.LikedStatusEum.NOT_EXIST.getCode();
}

@Override
publicvoidsaveLiked2Redis(StringinfoId,StringlikeUserId){
//生成key
Stringkey=RedisKeyUtils.getLikedKey(infoId,likeUserId);
//封裝value喜歡狀態(tài)更新時間
HashMapmap=newHashMap<>();
map.put("status",CONSTANT.LikedStatusEum.LIKE.getCode());
map.put("updateTime",System.currentTimeMillis());

redisHash.put(RedisKeyUtils.MAP_KEY_USER_LIKED,key,map);
}

@Override
publicvoidunlikeFromRedis(StringinfoId,StringlikeUserId){
//生成key
Stringkey=RedisKeyUtils.getLikedKey(infoId,likeUserId);
//封裝value喜歡狀態(tài)更新時間
HashMapmap=newHashMap<>();
map.put("status",CONSTANT.LikedStatusEum.UNLIKE.getCode());
map.put("updateTime",System.currentTimeMillis());//存入當前時間戳

redisHash.put(RedisKeyUtils.MAP_KEY_USER_LIKED,key,map);
}

@Override
publicvoiddeleteLikedFromRedis(StringinfoId,StringlikeUserId){
Stringkey=RedisKeyUtils.getLikedKey(infoId,likeUserId);
redisHash.delete(RedisKeyUtils.MAP_KEY_USER_LIKED,key);
}

@Override
publicvoidin_decrementLikedCount(StringinfoId,Integerdelta){
redisHash.increment(RedisKeyUtils.MAP_KEY_USER_LIKED_COUNT,infoId,delta);
}

@Override
publicListgetLikedDataFromRedis(){
//scan讀取數(shù)據(jù)，比key匹配優(yōu)雅
Cursor>cursor=redisHash.scan(RedisKeyUtils.MAP_KEY_USER_LIKED,ScanOptions.NONE);

Listlist=newArrayList<>();
while(cursor.hasNext()){
Map.Entryentry=cursor.next();
Stringkey=(String)entry.getKey();
//分離出infoId，likedPostId,解析value
String[]split=key.split("::");
StringinfoId=split[0];
StringlikeUserId=split[1];
HashMapmap=(HashMap)entry.getValue();
Integerstatus=(Integer)map.get("status");
longupdateTimeStamp=(long)map.get("updateTime");
LocalDateTimeupdateTime=LocalDateTimeConvertUtil.getDateTimeOfTimestamp(updateTimeStamp);//時間戳轉(zhuǎn)為LocalDateTime

//組裝成UserLike對象
UserLikesDTOuserLikesDTO=newUserLikesDTO(infoId,likeUserId,status,updateTime);
list.add(userLikesDTO);

//存到list后從Redis中清理緩存
redisHash.delete(RedisKeyUtils.MAP_KEY_USER_LIKED,key);
}
returnlist;
}

@Override
publicListgetLikedCountFromRedis(){
//scan讀取數(shù)據(jù)，比key匹配優(yōu)雅
Cursor>cursor=redisHash.scan(RedisKeyUtils.MAP_KEY_USER_LIKED_COUNT,ScanOptions.NONE);
Listlist=newArrayList<>();
while(cursor.hasNext()){
Map.Entrymap=cursor.next();
//將點贊數(shù)量存儲在LikedCountDT
Stringkey=(String)map.getKey();
UserLikeCountDTOdto=newUserLikeCountDTO(key,(Integer)map.getValue());
list.add(dto);
//從Redis中刪除這條記錄
redisHash.delete(RedisKeyUtils.MAP_KEY_USER_LIKED_COUNT,key);
}
returnlist;
}
}

2.5 controller & API

1. controller

importcom.csu.edu.redisLikeDemo.common.CommonResponse;
importcom.csu.edu.redisLikeDemo.service.LikeService;
importorg.springframework.beans.factory.annotation.Autowired;
importorg.springframework.web.bind.annotation.PostMapping;
importorg.springframework.web.bind.annotation.RequestMapping;
importorg.springframework.web.bind.annotation.RestController;

@RestController
@RequestMapping("/test/")
publicclassLikeController{
@Autowired
privateLikeServicelikeService;

@PostMapping("like")
publicCommonResponse