微服务Spring Boot 整合 Redis 实现好友关注

超、凢脫俗 2024-05-01 04:36 10阅读 0赞

#### 文章目录 ####

*  ⛅引言
 *  一、Redis 实现好友关注 -- 关注与取消关注
 *  二、Redis 实现好友关注 -- 共同关注功能
 *  ⛵小结

## ⛅引言 ##

**本博文参考 黑马 程序员B站 Redis课程系列**

在点评项目中，有这样的需求，如何实现笔记的**好友关注、以及发布笔记后推送消息**功能？

> 使用Redis 的 **好友关注、以及发布笔记后推送消息功能**

## 一、Redis 实现好友关注 – 关注与取消关注 ##

需求：**针对用户的操作，可以对用户进行关注和取消关注功能。**

在探店图文的详情页面中，可以关注发布笔记的作者

![在这里插入图片描述][3687ecaa4f7d4bb1a3d7f6f0960a38f9.png_pic_center]

具体实现思路：基于该表数据结构，实现2个接口

*  关注和取关接口
 *  判断是否关注的接口

关注是用户之间的关系，是博主与粉丝的关系，数据表如下：

**tb\_follow**

CREATE TABLE `tb_follow` (
      `id` bigint(20) NOT NULL AUTO_INCREMENT COMMENT '主键',
      `user_id` bigint(20) unsigned NOT NULL COMMENT '用户id',
      `follow_user_id` bigint(20) unsigned NOT NULL COMMENT '关联的用户id',
      `create_time` timestamp NOT NULL DEFAULT CURRENT_TIMESTAMP COMMENT '创建时间',
      PRIMARY KEY (`id`) USING BTREE
    ) ENGINE=InnoDB AUTO_INCREMENT=9 DEFAULT CHARSET=utf8mb4 ROW_FORMAT=COMPACT;

**id为自增长，简化开发**

> **核心代码**

**FollowController**

//关注
    @PutMapping("/{id}/{isFollow}")
    public Result follow(@PathVariable("id") Long followUserId, @PathVariable("isFollow") Boolean isFollow) {
        
        return followService.follow(followUserId, isFollow);
    }
    //取消关注
    @GetMapping("/or/not/{id}")
    public Result isFollow(@PathVariable("id") Long followUserId) {
        
        return followService.isFollow(followUserId);
    }

**FollowService**

@Override
    public Result follow(Long followUserId, Boolean isFollow) {
        
        // 1.获取登录用户
        Long userId = UserHolder.getUser().getId();
        String key = "follows:" + userId;
        // 1.判断到底是关注还是取关
        if (isFollow) {
        
            // 2.关注，新增数据
            Follow follow = new Follow();
            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(new QueryWrapper<Follow>()
                                       .eq("user_id", userId).eq("follow_user_id", followUserId));
            if (isSuccess) {
        
                // 把关注用户的id从Redis集合中移除
                stringRedisTemplate.opsForSet().remove(key, followUserId.toString());
            }
        }
        return Result.ok();
    }
    
    @Override
    public Result isFollow(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.判断
        return Result.ok(count > 0);
    }

**代码编写完毕，进行测试**

> **代码测试**

**点击进行关注用户**

![在这里插入图片描述][203130178c4d40c38eecbc1faec65194.png_pic_center]

**关注成功**

**取消关注**

![在这里插入图片描述][2f23743ec3954204a1d21143642df548.png_pic_center]

**测试成功**

## 二、Redis 实现好友关注 – 共同关注功能 ##

实现共同关注好友功能，首先，需要进入博主发布的指定笔记页，然后点击博主的头像去查看详细信息

![在这里插入图片描述][c6864a0bd0d84c4db8b010f91ebc26f3.png_pic_center]

**核心代码如下**

**UserController**

// UserController 根据id查询用户
    @GetMapping("/{id}")
    public Result queryUserById(@PathVariable("id") Long userId){
        
        // 查询详情
        User user = userService.getById(userId);
        if (user == null) {
        
            return Result.ok();
        }
        UserDTO userDTO = BeanUtil.copyProperties(user, UserDTO.class);
        // 返回
        return Result.ok(userDTO);
    }

**BlogController**

@GetMapping("/of/user")
    public Result queryBlogByUserId(
        @RequestParam(value = "current", defaultValue = "1") Integer current,
        @RequestParam("id") Long id) {
        
        // 根据用户查询
        Page<Blog> page = blogService.query()
            .eq("user_id", id).page(new Page<>(current, SystemConstants.MAX_PAGE_SIZE));
        // 获取当前页数据
        List<Blog> records = page.getRecords();
        return Result.ok(records);
    }

**那么如何实现共同好友关注功能呢？**

需求：利用Redis中的数据结构，实现共同关注功能。 在博主个人页面展示出当前用户与博主的共同关注

**思路分析：** 使用Redis的Set集合实现，我们把两人关注的人分别放入到一个Set集合中，然后再通过API去查看两个Set集合中的交集数据

![在这里插入图片描述][885892dd69714de1959d913f26caf3ac.png_pic_center]

**改造核心代码**：

当用户关注某位用户后，需要将数据存入Redis集合中，方便后续进行共同关注的实现，同时取消关注时，需要删除Redis中的集合

**FlowServiceImpl**

@Override
    public Result follow(Long followUserId, Boolean isFollow) {
        
        // 1.获取登录用户
        Long userId = UserHolder.getUser().getId();
        String key = "follows:" + userId;
        // 1.判断到底是关注还是取关
        if (isFollow) {
        
            // 2.关注，新增数据
            Follow follow = new Follow();
            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(new QueryWrapper<Follow>()
                                       .eq("user_id", userId).eq("follow_user_id", followUserId));
            if (isSuccess) {
        
                // 把关注用户的id从Redis集合中移除
                stringRedisTemplate.opsForSet().remove(key, followUserId.toString());
            }
        }
        return Result.ok();
    }
    
    // 具体获取好友共同关注代码
    
    @Override
    public Result followCommons(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()) {
        
            // 无交集
            return Result.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());
        return Result.ok(users);
    }

**进行测试**

![在这里插入图片描述][775aaa9691904faa90d25c23171c54aa.png_pic_center]

## ⛵小结 ##

以上就是【**Bug 终结者**】对 **微服务Spring Boot 整合 Redis 实现 好友关注** 的简单介绍，**Redis 实现好友关注功能也是 利用Set集合、ZSet集合实现这样一个需求，同时，采用Redis来实现更加的快速，减少系统的消耗，更加快速的实现数据展示！ `下篇博文我们继续 关注 如何 使用Redis 实现推送消息到粉丝收件箱以及滚动分页查询！`**

> 如果这篇【文章】有帮助到你，希望可以给【**Bug 终结者**】点个赞👍，创作不易，如果有对【**后端技术**】、【**前端领域**】感兴趣的小可爱，也欢迎关注❤️❤️❤️ 【**Bug 终结者**】❤️❤️❤️，我将会给你带来巨大的【收获与惊喜】💝💝💝！

[3687ecaa4f7d4bb1a3d7f6f0960a38f9.png_pic_center]: https://image.dandelioncloud.cn/pgy_files/images/2024/05/01/cd2fa9867f644d258bef942ed3d84f07.png
[203130178c4d40c38eecbc1faec65194.png_pic_center]: https://image.dandelioncloud.cn/pgy_files/images/2024/05/01/c57abc6d3d5f41bc8bb90245ce1f461b.png
[2f23743ec3954204a1d21143642df548.png_pic_center]: https://image.dandelioncloud.cn/pgy_files/images/2024/05/01/85f7e75c22e643048cdfa8a01543e9ae.png
[c6864a0bd0d84c4db8b010f91ebc26f3.png_pic_center]: https://image.dandelioncloud.cn/pgy_files/images/2024/05/01/99f90a93ded64970a518a4dd863f308a.png
[885892dd69714de1959d913f26caf3ac.png_pic_center]: https://image.dandelioncloud.cn/pgy_files/images/2024/05/01/969c9be377d14908bf55076b14aea31f.png
[775aaa9691904faa90d25c23171c54aa.png_pic_center]: https://image.dandelioncloud.cn/pgy_files/images/2024/05/01/c50e6a9f29eb46ec9e44ec5e8414880e.png