Redis筆記點贊排行榜的實現示例
更新時間：2023年01月29日 15:50:02 作者：卒獲有所聞
探店筆記類似點評網站的評價，本文主要介紹了Redis筆記點贊排行榜的實現示例，文中通過示例代碼介紹的非常詳細，對大家的學習或者工作具有一定的參考學習價值，需要的朋友們下面隨著小編來一起學習學習吧
一、發(fā)布探店筆記
探店筆記類似點評網站的評價，往往是圖文結合。對應的表有兩個
- 探店筆記表（主鍵、商戶id、用戶id、標題、文字、圖片、探店文字描述、點贊數量、評論數量）
- 評價表（筆記的評價）
先上傳圖片請求一次保存圖片接口，再點發(fā)布請求發(fā)布接口。這兩個接口已經寫好
二、實現查看筆記接口
BlogController
@RestController
@RequestMapping("/blog")
public class BlogController {
@Resource
private IBlogService blogService;
@GetMapping("/hot")
public Result queryHotBlog(@RequestParam(value = "current", defaultValue = "1") Integer current) {
return blogService.queryHotBlog(current);
}
@GetMapping("/{id}")
public Result queryBlogById(@PathVariable("id") String id){
return blogService.queryBlogById(id);
}
}IBlogService
public interface IBlogService extends IService<Blog> {
Result queryBlogById(String id);
Result queryHotBlog(Integer current);
}BlogServiceImpl
@Service
public class BlogServiceImpl extends ServiceImpl<BlogMapper, Blog> implements IBlogService {
@Autowired
private IUserService userService;
@Override
public Result queryHotBlog(Integer current) {
// 根據用戶查詢
Page<Blog> page = query()
.orderByDesc("liked")
.page(new Page<>(current, SystemConstants.MAX_PAGE_SIZE));
// 獲取當前頁數據
List<Blog> records = page.getRecords();
// 查詢用戶
records.forEach(this::queryBlogUser);
return Result.ok(records);
}
private void queryBlogUser(Blog blog) {
Long userId = blog.getUserId();
User user = userService.getById(userId);
blog.setName(user.getNickName());
blog.setIcon(user.getIcon());
}
@Override
public Result queryBlogById(String id) {
Blog blog = getById(id);
if(blog == null){
return Result.fail("筆記不存在！");
}
queryBlogUser(blog);
return Result.ok(blog);
}
}三、點贊功能
現在已經寫好的點贊接口
問題：這樣寫接口，可以一直按點贊重復點贊
需求
- 同一個用戶只能點贊一次，再次點贊則取消點贊
- 如果當前用戶已經點贊，則點贊按鈕高亮顯（前端已經實現，判斷blog類的isLike屬性）
實現步驟
- 給Blog類中添加一個isLike字段，表示是否被當前用戶點贊
- 修改點贊功能，利用redis的set集合判斷用戶是否贊過，未贊則點贊數+1，贊過則-1
- 修改根據id查詢blog的業(yè)務，判斷當前用戶是否點贊過，賦值給isLike字段
- 修改分頁查詢blog業(yè)務，判斷當前用戶是否贊過，賦值isLike字段
業(yè)務實現
@RestController
@RequestMapping("/blog")
public class BlogController {
@Resource
private IBlogService blogService;
@PutMapping("/like/{id}")
public Result likeBlog(@PathVariable("id") Long id) {
return blogService.likeBlog(id);
}
@GetMapping("/hot")
public Result queryHotBlog(@RequestParam(value = "current", defaultValue = "1") Integer current) {
return blogService.queryHotBlog(current);
}
@GetMapping("/{id}")
public Result queryBlogById(@PathVariable("id") String id){
return blogService.queryBlogById(id);
}
}編寫完點贊操作的接口后還要修改之前的查詢接口，增加查詢是否已經點贊
@Service
public class BlogServiceImpl extends ServiceImpl<BlogMapper, Blog> implements IBlogService {
@Autowired
private IUserService userService;
@Autowired
private StringRedisTemplate stringRedisTemplate;
@Override
public Result queryHotBlog(Integer current) {
// 根據用戶查詢
Page<Blog> page = query()
.orderByDesc("liked")
.page(new Page<>(current, SystemConstants.MAX_PAGE_SIZE));
// 獲取當前頁數據
List<Blog> records = page.getRecords();
// 查詢用戶
records.forEach(blog -> {
this.queryBlogUser(blog);
this.isBlogLiked(blog);
});
return Result.ok(records);
}
@Override
public Result likeBlog(Long id) {
// 1、獲取登錄用戶
UserDTO user = UserHolder.getUser();
// 2、判斷當前登錄用戶是否已經點贊
Boolean isMember = stringRedisTemplate.opsForSet().isMember(RedisConstants.BLOG_LIKED_KEY + id, user.getId().toString());
if(BooleanUtil.isFalse(isMember)) {
// 3、如果未點贊，可以點贊
// 3.1、數據庫點贊數 +1
boolean isSuccess = update().setSql("liked = liked+1").eq("id", id).update();
// 3.2、保存用戶到 Redis 的 set 集合
if(isSuccess){
stringRedisTemplate.opsForSet().add(RedisConstants.BLOG_LIKED_KEY + id, user.getId().toString());
}
} else {
// 4、如果已點贊，取消點贊
// 4.1、數據庫點贊數 -1
boolean isSuccess = update().setSql("liked = liked - 1").eq("id", id).update();
// 4.2、把用戶從 Redis 的 set 集合移除
if(isSuccess){
stringRedisTemplate.opsForSet().remove(RedisConstants.BLOG_LIKED_KEY + id, user.getId().toString());
}
}
return Result.ok();
}
private void queryBlogUser(Blog blog) {
Long userId = blog.getUserId();
User user = userService.getById(userId);
blog.setName(user.getNickName());
blog.setIcon(user.getIcon());
}
@Override
public Result queryBlogById(String id) {
Blog blog = getById(id);
if(blog == null){
return Result.fail("筆記不存在！");
}
queryBlogUser(blog);
// 查詢 Blog 是否被點贊
isBlogLiked(blog);
return Result.ok(blog);
}
private void isBlogLiked(Blog blog) {
Long userId = blog.getUserId();
String key = RedisConstants.BLOG_LIKED_KEY + blog.getId();
Boolean isMember = stringRedisTemplate.opsForSet().isMember(key, userId.toString());
blog.setIsLike(BooleanUtil.isTrue(isMember));
}
}四、點贊排行榜
查出給這個筆記點贊的人，類似微信朋友圈的點贊，可以展示誰點贊了，而且我們要進行排序
所以我們得用SortedSet這種數據類型
1、修改點贊邏輯
把原本存入set改為存入zset多加個分數，分數就是時間戳
@Override
public Result likeBlog(Long id) {
// 1、獲取登錄用戶
UserDTO user = UserHolder.getUser();
// 2、判斷當前登錄用戶是否已經點贊
Double score = stringRedisTemplate.opsForZSet().score(RedisConstants.BLOG_LIKED_KEY + id, user.getId().toString());
if(score == null) {
// 3、如果未點贊，可以點贊
// 3.1、數據庫點贊數 +1
boolean isSuccess = update().setSql("liked = liked+1").eq("id", id).update();
// 3.2、保存用戶到 Redis 的 set 集合
if(isSuccess){
// 時間作為 key 的 score
stringRedisTemplate.opsForZSet().add(RedisConstants.BLOG_LIKED_KEY + id, user.getId().toString(), System.currentTimeMillis());
}
} else {
// 4、如果已點贊，取消點贊
// 4.1、數據庫點贊數 -1
boolean isSuccess = update().setSql("liked = liked - 1").eq("id", id).update();
// 4.2、把用戶從 Redis 的 set 集合移除
if(isSuccess){
stringRedisTemplate.opsForZSet().remove(RedisConstants.BLOG_LIKED_KEY + id, user.getId().toString());
}
}
return Result.ok();
}然后是否被點贊的方法也要修改，根據key取出分數，分數不為null就是點贊過了
private void isBlogLiked(Blog blog) {
UserDTO user = UserHolder.getUser();
if(user == null){
return;
}
Long userId = user.getId();
String key = RedisConstants.BLOG_LIKED_KEY + blog.getId();
Double score = stringRedisTemplate.opsForZSet().score(key, userId.toString());
blog.setIsLike(score != null);
}2、點贊排行榜功能
需求：實現前五個點贊的用戶返回
我們先用動態(tài)id去redis中查詢出前五個點贊用戶的id
然后根據id去數據庫中查詢信息封裝到dto再返回
@GetMapping("/likes/{id}")
public Result queryBlogLikes(@PathVariable("id") String id) {
return blogService.queryBlogLikes(id);
} @Override
public Result queryBlogLikes(String id) {
String key = RedisConstants.BLOG_LIKED_KEY + id;
// 查詢 top5 的點贊用戶
Set<String> top5 = stringRedisTemplate.opsForZSet().range(key, 0, 4);
if(top5 == null){
return Result.ok(Collections.emptyList());
}
// 解析出其中的用戶id
List<Long> ids = top5.stream().map(Long::valueOf).collect(Collectors.toList());
String join = StrUtil.join(",", ids);
// 根據用戶id查詢用戶
List<UserDTO> userDTOS = userService.query().in("id", ids).last("order by filed(id, "+join+")").list()
.stream()
.map(user -> BeanUtil.copyProperties(user, UserDTO.class))
.collect(Collectors.toList());
return Result.ok(userDTOS);
}注意：如果我們mp直接用in來查詢根本不能保證點贊的順序，因為in查詢出來的是按照id順序返回的，沒有排序，我們要按照查詢id的順序來查，order by field(id,5,1)這樣
到此這篇關于Redis筆記點贊排行榜的實現示例的文章就介紹到這了,更多相關Redis筆記點贊內容請搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關文章希望大家以后多多支持腳本之家！
相關文章
這篇文章主要介紹了redis配置文件redis.conf中文版（基于2.4）,對英文不好的朋友是非常好的參考,需要的朋友可以參考下2014-06-06
這篇文章主要為大家介紹了Redis處理高并發(fā)之布隆過濾器詳解，有需要的朋友可以借鑒參考下，希望能夠有所幫助，祝大家多多進步，早日升職加薪2022-12-12
前段時間，做了一個世界杯競猜積分排行榜。對世界杯64場球賽勝負平進行猜測，猜對+1分，錯誤+0分，一人一場只能猜一次。下面通過本文給大家分享基于redis實現世界杯排行榜功能項目實戰(zhàn)，感興趣的朋友一起看看吧2018-10-10
這篇文章主要給大家介紹了關于redis的2種持久化方案的相關資料，文中通過示例代碼介紹的非常詳細，對大家學習或者使用redis具有一定的參考學習價值，需要的朋友們下面來一起學習學習吧2019-05-05
這篇文章主要給大家介紹了關于如何利用Redis實現訪問次數限流的相關資料,文中通過實例代碼介紹的非常詳細,對大家的學習或者工作具有一定的參考學習價值,需要的朋友可以參考下2022-02-02
很多人都遇到過這么一道面試題：Redis是單線程還是多線程？這個問題既簡單又復雜,說他簡單是因為大多數人都知道Redis是單線程,說復雜是因為這個答案其實并不準確,本文就給大家講講Redis單線程架構的優(yōu)勢與不足,需要的朋友可以參考下2024-02-02
網上都說jedis實例是非線程安全的，常常通過JedisPool連接池去管理實例，在多線程情況下讓每個線程有自己獨立的jedis實例，但都沒有具體說明為啥jedis實例時非線程安全的，本文就來和大家詳細說說2022-12-12
這篇文章主要介紹了詳解Redis實現限流的三種方式，文中通過示例代碼介紹的非常詳細，對大家的學習或者工作具有一定的參考學習價值，需要的朋友們下面隨著小編來一起學習學習吧2021-04-04
這篇文章給大家整理了在操作Redis列表類型中的常用命令，文章總結的很全面，對大家學習Redis具有一定的參考借鑒價值，下面來一起看看吧。2016-09-09
Redis是一款內存高速緩存數據庫，可以滿足我們對海量數據的讀寫需求，本文重點給大家介紹Windows下Redis?x64的安裝與使用教程，感興趣的朋友一起看看吧2022-03-03