0.前言
本文基于Springboot利用Redis實現點贊功能的緩存和定時持久化接口。
用戶對瀏覽內容進行【點贊/取贊】，并發送【點贊/取贊】請求到后端，這些信息先存入Redis中緩存，再每隔兩小時將Redis中的內容直接寫入數據庫持久化存儲。
1.項目目錄結構
2.Redis緩存點贊消息
1.設計思路
用戶點贊一條數據，設置狀態為0，并且更新被點贊內容的likeCount+1
用戶取消點贊一條數據，設置狀態為1，并且更新被點贊內容的likeCount+0
1.1 Redis鍵值對設計
選用Hash（散列）存儲
點贊信息
-
key: (String) 瀏覽信息id和點贊用戶id拼接而成, 分隔符為::
-
value: (HashMap) 存儲點贊狀態(0: 點贊 1:取消點贊)和更新時間的時間戳
-
key: "瀏覽信息id::點贊用戶id" value:
{status: Integer, updateTime: long}
點贊數量
-
key: (String) 瀏覽信息id
-
value: (Integer) 點贊數量
1.2 點贊
-
用戶點贊信息，發送點贊請求到后端
-
后端判斷該點贊信息在Redis中的狀態
-
Redis不進行存儲，并提醒前端重復存儲。
-
更新/新增點贊信息
-
更新/新增點贊量
-
【不存在（沒有對應key) 】|| 【取消點贊（即取出的status為1）】
-
【點贊（即取出的status為0，此時相當于重復點贊行為）】
-
一次點贊請求完畢
1.3 取消點贊
-
用戶取消點贊信息，發送取消點贊請求到后端
-
后端判斷該點贊信息在Redis中的狀態
-
更新/新增點贊信息
-
更新/新增點贊量
-
Redis不進行存儲，并提醒前端重復存儲。
-
更新/新增點贊信息
-
增加0條內容點贊量
-
【不存在（沒有對應key) 】
-
【取消點贊（即取出的status為1，此時相當于重復取消點贊行為）】
-
【點贊（即取出的status為0）】
-
一次取消點贊請求完畢
2.核心代碼實現
2.1 Redis封裝
具體實現參考該博客，不在贅述。
-
https://www.cnblogs.com/caizhaokai/p/11037610.html
2.2 工具類
1.時間戳轉化為LocalDateTime
importjava.time.Instant;
importjava.time.LocalDateTime;
importjava.time.ZoneId;
/**
*工具類：將時間戳轉化為LocalDateTime
*主要是因為redis不好存儲LocalDateTime，存儲timestamp方便一點，而且格式可以隨意改變
*/
publicclassLocalDateTimeConvertUtil{
publicstaticLocalDateTimegetDateTimeOfTimestamp(longtimestamp){
Instantinstant=Instant.ofEpochMilli(timestamp);
ZoneIdzone=ZoneId.systemDefault();
returnLocalDateTime.ofInstant(instant,zone);
}
}
2.RedisKey處理類
publicclassRedisKeyUtils{
/**
*
保存用戶點贊內容數據的key
*@date2021/9/2614:44
*/
publicstaticfinalStringMAP_KEY_USER_LIKED="MAP_USER_LIKED";
/**
*
保存內容被點贊數量的key
*@date2021/9/2614:44
*/
publicstaticfinalStringMAP_KEY_USER_LIKED_COUNT="MAP_USER_LIKED_COUNT";
/**
*拼接被點贊的內容id和點贊的人的id作為key。格式222222::333333
*@paraminfoId被點贊的內容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
-
interface
//RedisService.java
importcom.csu.edu.redisLikeDemo.domain.DTO.UserLikeCountDTO;
importcom.csu.edu.redisLikeDemo.domain.DTO.UserLikesDTO;
importjava.util.List;
/**
*負責將數據寫入Redis緩存
*/
publicinterfaceRedisService{
/**
*獲取點贊狀態
*@paraminfoId
*@paramlikeUserId
*/
IntegergetLikeStatus(StringinfoId,StringlikeUserId);
/**
*點贊。狀態為1
*@paraminfoId
*@paramlikeUserId
*/
voidsaveLiked2Redis(StringinfoId,StringlikeUserId);
/**
*取消點贊。將狀態改變為0
*@paraminfoId
*@paramlikeUserId
*/
voidunlikeFromRedis(StringinfoId,StringlikeUserId);
/**
*從Redis中刪除一條點贊數據
*@paraminfoId
*@paramlikeUserId
*/
voiddeleteLikedFromRedis(StringinfoId,StringlikeUserId);
/**
*該內容的點贊數變化Δdelta
*@paraminfoId
*/
voidin_decrementLikedCount(StringinfoId,Integerdelta);
/**
*獲取Redis中存儲的所有點贊數據
*@return
*/
ListgetLikedDataFromRedis();
/**
*獲取Redis中存儲的所有點贊數量
*@return
*/
ListgetLikedCountFromRedis();
}
-
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喜歡狀態更新時間
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喜歡狀態更新時間
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讀取數據，比key匹配優雅
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);//時間戳轉為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讀取數據，比key匹配優雅
Cursor>cursor=redisHash.scan(RedisKeyUtils.MAP_KEY_USER_LIKED_COUNT,ScanOptions.NONE);
Listlist=newArrayList<>();
while(cursor.hasNext()){
Map.Entrymap=cursor.next();
//將點贊數量存儲在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
-
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
