文章目录
⛅引言
本博文参考 黑马 程序员B站 Redis课程系列
在点评项目中,有这样的需求,如何实现笔记的好友关注、以及发布笔记后推送消息功能?
使用Redis 的 好友关注、以及发布笔记后推送消息功能
一、Redis 实现好友关注 – 关注与取消关注
需求:针对用户的操作,可以对用户进行关注和取消关注功能。
在探店图文的详情页面中,可以关注发布笔记的作者
具体实现思路:基于该表数据结构,实现2个接口
- 关注和取关接口
- 判断是否关注的接口
关注是用户之间的关系,是博主与粉丝的关系,数据表如下:
tb_follow
CREATETABLE`tb_follow`(`id`bigint(20)NOTNULLAUTO_INCREMENTCOMMENT'主键',`user_id`bigint(20)unsignedNOTNULLCOMMENT'用户id',`follow_user_id`bigint(20)unsignedNOTNULLCOMMENT'关联的用户id',`create_time`timestampNOTNULLDEFAULTCURRENT_TIMESTAMPCOMMENT'创建时间',PRIMARYKEY(`id`)USINGBTREE)ENGINE=InnoDBAUTO_INCREMENT=9DEFAULTCHARSET=utf8mb4 ROW_FORMAT=COMPACT;
id为自增长,简化开发
核心代码
FollowController
//关注@PutMapping("/{id}/{isFollow}")publicResultfollow(@PathVariable("id")Long followUserId,@PathVariable("isFollow")Boolean isFollow){return followService.follow(followUserId, isFollow);}//取消关注@GetMapping("/or/not/{id}")publicResultisFollow(@PathVariable("id")Long followUserId){return followService.isFollow(followUserId);}
FollowService
@OverridepublicResultfollow(Long followUserId,Boolean isFollow){// 1.获取登录用户Long userId =UserHolder.getUser().getId();String key ="follows:"+ userId;// 1.判断到底是关注还是取关if(isFollow){// 2.关注,新增数据Follow follow =newFollow();
follow.setUserId(userId);
follow.setFollowUserId(followUserId);boolean isSuccess =save(follow);if(isSuccess){
stringRedisTemplate.opsForSet().add(key, followUserId.toString());}}else{// 3.取关,删除 delete from tb_follow where user_id = ? and follow_user_id = ?boolean isSuccess =remove(newQueryWrapper<Follow>().eq("user_id", userId).eq("follow_user_id", followUserId));if(isSuccess){// 把关注用户的id从Redis集合中移除
stringRedisTemplate.opsForSet().remove(key, followUserId.toString());}}returnResult.ok();}@OverridepublicResultisFollow(Long followUserId){// 1.获取登录用户Long userId =UserHolder.getUser().getId();// 2.查询是否关注 select count(*) from tb_follow where user_id = ? and follow_user_id = ?Integer count =query().eq("user_id", userId).eq("follow_user_id", followUserId).count();// 3.判断returnResult.ok(count >0);}
代码编写完毕,进行测试
代码测试
点击进行关注用户
关注成功
取消关注
测试成功
二、Redis 实现好友关注 – 共同关注功能
实现共同关注好友功能,首先,需要进入博主发布的指定笔记页,然后点击博主的头像去查看详细信息
核心代码如下
UserController
// UserController 根据id查询用户@GetMapping("/{id}")publicResultqueryUserById(@PathVariable("id")Long userId){// 查询详情User user = userService.getById(userId);if(user ==null){returnResult.ok();}UserDTO userDTO =BeanUtil.copyProperties(user,UserDTO.class);// 返回returnResult.ok(userDTO);}
BlogController
@GetMapping("/of/user")publicResultqueryBlogByUserId(@RequestParam(value ="current", defaultValue ="1")Integer current,@RequestParam("id")Long id){// 根据用户查询Page<Blog> page = blogService.query().eq("user_id", id).page(newPage<>(current,SystemConstants.MAX_PAGE_SIZE));// 获取当前页数据List<Blog> records = page.getRecords();returnResult.ok(records);}
那么如何实现共同好友关注功能呢?
需求:利用Redis中的数据结构,实现共同关注功能。 在博主个人页面展示出当前用户与博主的共同关注
思路分析: 使用Redis的Set集合实现,我们把两人关注的人分别放入到一个Set集合中,然后再通过API去查看两个Set集合中的交集数据
改造核心代码:
当用户关注某位用户后,需要将数据存入Redis集合中,方便后续进行共同关注的实现,同时取消关注时,需要删除Redis中的集合
FlowServiceImpl
@OverridepublicResultfollow(Long followUserId,Boolean isFollow){// 1.获取登录用户Long userId =UserHolder.getUser().getId();String key ="follows:"+ userId;// 1.判断到底是关注还是取关if(isFollow){// 2.关注,新增数据Follow follow =newFollow();
follow.setUserId(userId);
follow.setFollowUserId(followUserId);boolean isSuccess =save(follow);if(isSuccess){
stringRedisTemplate.opsForSet().add(key, followUserId.toString());}}else{// 3.取关,删除 delete from tb_follow where user_id = ? and follow_user_id = ?boolean isSuccess =remove(newQueryWrapper<Follow>().eq("user_id", userId).eq("follow_user_id", followUserId));if(isSuccess){// 把关注用户的id从Redis集合中移除
stringRedisTemplate.opsForSet().remove(key, followUserId.toString());}}returnResult.ok();}// 具体获取好友共同关注代码@OverridepublicResultfollowCommons(Long id){// 1.获取当前用户Long userId =UserHolder.getUser().getId();String key ="follows:"+ userId;// 2.求交集String key2 ="follows:"+ id;Set<String> intersect = stringRedisTemplate.opsForSet().intersect(key, key2);if(intersect ==null|| intersect.isEmpty()){// 无交集returnResult.ok(Collections.emptyList());}// 3.解析id集合List<Long> ids = intersect.stream().map(Long::valueOf).collect(Collectors.toList());// 4.查询用户List<UserDTO> users = userService.listByIds(ids).stream().map(user ->BeanUtil.copyProperties(user,UserDTO.class)).collect(Collectors.toList());returnResult.ok(users);}
进行测试
⛵小结
以上就是【Bug 终结者】对 微服务Spring Boot 整合 Redis 实现 好友关注 的简单介绍,**Redis 实现好友关注功能也是 利用Set集合、ZSet集合实现这样一个需求,同时,采用Redis来实现更加的快速,减少系统的消耗,更加快速的实现数据展示!
下篇博文我们继续 关注 如何 使用Redis 实现推送消息到粉丝收件箱以及滚动分页查询!
**
如果这篇【文章】有帮助到你,希望可以给【Bug 终结者】点个赞👍,创作不易,如果有对【后端技术】、【前端领域】感兴趣的小可爱,也欢迎关注❤️❤️❤️ 【Bug 终结者】❤️❤️❤️,我将会给你带来巨大的【收获与惊喜】💝💝💝!
版权归原作者 Bug 终结者 所有, 如有侵权,请联系我们删除。