【项目】仿牛客网社区开发第4章 Redis 一站式高性能存储方案 5 关注、取消关注

爱被打了一巴掌 2024-03-22 15:24 19阅读 0赞

### 【项目】仿牛客网社区开发 ###

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

*   *  【项目】仿牛客网社区开发
     *   *  第4章 Redis 一站式高性能存储方案
         *   *  5 关注、取消关注

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

#### 第4章 Redis 一站式高性能存储方案 ####

##### 5 关注、取消关注 #####

*  需求
    
     *  开发关注、取消关注功能。
     *  统计用户的关注数、粉丝数。
 *  关键
    
     *  若A关注了B，则A是B的Follower（粉丝），B是A的Followee（目标）。
     *  关注的目标可以是用户、帖子、题目等，在实现时将这些目标抽象为实体。

同样，第一步先修改key 工具类

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

两种新的key

新建业务

package com.nowcoder.community.service;
    
    import com.nowcoder.community.util.RedisKeyUtil;
    import org.springframework.beans.factory.annotation.Autowired;
    import org.springframework.dao.DataAccessException;
    import org.springframework.data.redis.core.RedisOperations;
    import org.springframework.data.redis.core.RedisTemplate;
    import org.springframework.data.redis.core.SessionCallback;
    import org.springframework.stereotype.Service;
    
    /**
     * @Projectname: community
     * @Classname: FollowService
     * @Author: Ding Jiaxiong
     * @Date:2023/4/21 21:11
     */
    
    @Service
    public class FollowService {
        
    
        @Autowired
        private RedisTemplate redisTemplate;
    
        public void follow(int userId, int entityType, int entityId) {
        
            redisTemplate.execute(new SessionCallback() {
        
                @Override
                public Object execute(RedisOperations operations) throws DataAccessException {
        
                    String followeeKey = RedisKeyUtil.getFolloweeKey(userId, entityType);
                    String followerKey = RedisKeyUtil.getFollowerKey(entityType, entityId);
    
                    operations.multi();
    
                    operations.opsForZSet().add(followeeKey, entityId, System.currentTimeMillis());
                    operations.opsForZSet().add(followerKey, userId, System.currentTimeMillis());
    
                    return operations.exec();
                }
            });
        }
    
        public void unfollow(int userId, int entityType, int entityId) {
        
            redisTemplate.execute(new SessionCallback() {
        
                @Override
                public Object execute(RedisOperations operations) throws DataAccessException {
        
                    String followeeKey = RedisKeyUtil.getFolloweeKey(userId, entityType);
                    String followerKey = RedisKeyUtil.getFollowerKey(entityType, entityId);
    
                    operations.multi();
    
                    operations.opsForZSet().remove(followeeKey, entityId);
                    operations.opsForZSet().remove(followerKey, userId);
    
                    return operations.exec();
                }
            });
        }
    
        // 查询关注的实体的数量
        public long findFolloweeCount(int userId, int entityType) {
        
            String followeeKey = RedisKeyUtil.getFolloweeKey(userId, entityType);
            return redisTemplate.opsForZSet().zCard(followeeKey);
        }
    
        // 查询实体的粉丝的数量
        public long findFollowerCount(int entityType, int entityId) {
        
            String followerKey = RedisKeyUtil.getFollowerKey(entityType, entityId);
            return redisTemplate.opsForZSet().zCard(followerKey);
        }
    
        // 查询当前用户是否已关注该实体
        public boolean hasFollowed(int userId, int entityType, int entityId) {
        
            String followeeKey = RedisKeyUtil.getFolloweeKey(userId, entityType);
            return redisTemplate.opsForZSet().score(followeeKey, entityId) != null;
        }
    
    }

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

下面是表现层，先是控制器

package com.nowcoder.community.controller;
    
    import com.nowcoder.community.entity.User;
    import com.nowcoder.community.service.FollowService;
    import com.nowcoder.community.util.CommunityUtil;
    import com.nowcoder.community.util.HostHolder;
    import org.springframework.beans.factory.annotation.Autowired;
    import org.springframework.stereotype.Controller;
    import org.springframework.web.bind.annotation.RequestMapping;
    import org.springframework.web.bind.annotation.RequestMethod;
    import org.springframework.web.bind.annotation.ResponseBody;
    
    /**
     * @Projectname: community
     * @Classname: FollowController
     * @Author: Ding Jiaxiong
     * @Date:2023/4/21 21:15
     */
    
    @Controller
    public class FollowController {
        
    
        @Autowired
        private FollowService followService;
    
        @Autowired
        private HostHolder hostHolder;
    
        @RequestMapping(path = "/follow", method = RequestMethod.POST)
        @ResponseBody
        public String follow(int entityType, int entityId) {
        
            User user = hostHolder.getUser();
    
            followService.follow(user.getId(), entityType, entityId);
    
            return CommunityUtil.getJSONString(0, "已关注!");
        }
    
        @RequestMapping(path = "/unfollow", method = RequestMethod.POST)
        @ResponseBody
        public String unfollow(int entityType, int entityId) {
        
            User user = hostHolder.getUser();
    
            followService.unfollow(user.getId(), entityType, entityId);
    
            return CommunityUtil.getJSONString(0, "已取消关注!");
        }
    
    }

关注和取关两种操作

然后是在获取个人信息的时候，应该同时查到这些信息

@Autowired
        private FollowService followService;
    
        // 个人主页
        @RequestMapping(path = "/profile/{userId}", method = RequestMethod.GET)
        public String getProfilePage(@PathVariable("userId") int userId, Model model) {
        
            User user = userService.findUserById(userId);
            if (user == null) {
        
                throw new RuntimeException("该用户不存在!");
            }
    
            // 用户
            model.addAttribute("user", user);
            // 点赞数量
            int likeCount = likeService.findUserLikeCount(userId);
            model.addAttribute("likeCount", likeCount);
    
            // 关注数量
            long followeeCount = followService.findFolloweeCount(userId, ENTITY_TYPE_USER);
            model.addAttribute("followeeCount", followeeCount);
            // 粉丝数量
            long followerCount = followService.findFollowerCount(ENTITY_TYPE_USER, userId);
            model.addAttribute("followerCount", followerCount);
            // 是否已关注
            boolean hasFollowed = false;
            if (hostHolder.getUser() != null) {
        
                hasFollowed = followService.hasFollowed(hostHolder.getUser().getId(), ENTITY_TYPE_USER, userId);
            }
            model.addAttribute("hasFollowed", hasFollowed);
    
            return "/site/profile";
        }

修改页面模板【个人主页那儿】【小tips：如果打开的个人主页是自己的，那不要显示“关注TA” 这个按钮】

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

修改js处理函数

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

直接启动服务器

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

当然aaa 这个人的关注者数量是0，关注了也是0，我现在关注ta

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

而且我自己现在的关注了

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

没问题，取消关注

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

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

[f7c81b221d17469292804bf3e0937f57.png_pic_center]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/18/dbae0883d35c431a8647e6608834f916.png
[901076b8d2e44fcb9bd709d10744f1c9.png_pic_center]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/18/6b6a69630f9a4f58a0237fa6aae85cd5.png
[62eca4f46d7648fc98883048c6c7de1a.png_pic_center]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/18/0af0077cb1a948ecb6a2458778ed50f5.png
[62ea0c9d67fa43acaaf0456459d09319.png_pic_center]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/18/cb0dd45da91b43e08e00c822e1b0e90e.png
[e3d8422fa7354624bd184da877f1a5d9.png_pic_center]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/18/d54a0a42fce94da7bd200e160cce8801.png
[cd8018d710f34f4c9c3cdccd7f8346dc.png_pic_center]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/18/537b5408c2e14cfc80d979ce199dedcc.png
[fce2f4a19f1149c0bde9e55b5ec75d3d.png_pic_center]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/18/01ac581834ce4e1b8f878a45caab6771.png
[907d77ebb4654d63a080866d0e59eb0a.png_pic_center]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/18/8c3c821290764717bff21a3041522cbd.png
[82d810927c4e47208acdc3f35f278a7b.png_pic_center]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/18/26091c687f7b4f37bb8d895b25fcaac8.png
[e1b090cac9764d4c9149e9a7d17f368d.png_pic_center]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/18/830d407a8ee14324998a7e9f3106efd2.png