Bug如山勤为径代码似海苦作舟。友友们好这里是苦瓜大王。今天学习的是黑马点评项目实战篇——好友关注部分的学习今天也是相对轻松的章节今天我们将完成好友关注功能。笔记如下后续会一直更新黑马点评学习过程中的笔记、问题等请多多支持哦文章目录一、关注和取关二、共同关注1.先把查看用户主页功能做了才能查看共同关注2.改造关注功能三、关注推送1.Feed流的模式(1)~~拉模式~~(2)推模式(3)推拉结合模式2.基于推模式实现关注推送功能(1)改造保存博文,推送到粉丝收件箱(2)实现滚动分页查询1~定义一个滚动分页的DTO2~查询用户所关注的人的最新博文一、关注和取关这个功能需要实现两个接口基本代码如下后续会改造FollowController代码-------------------------------------FollowController------------------------------------ResourceprivateIFollowServicefollowService;/** * 关注或取关 * param followUserId * param isFollow * return */PutMapping(/{id}/{isFollow})publicResultfollow(PathVariable(id)LongfollowUserId,PathVariable(isFollow)BooleanisFollow){returnfollowService.follow(followUserId,isFollow);}/** * 查询是否关注 * param followUserId * return */GetMapping(/or/not/{id})publicResultisFollow(PathVariable(id)LongfollowUserId){returnfollowService.isFollow(followUserId);}FollowServiceImpl代码/** * 关注或取关 * param followUserId * param isFollow * return */publicResultfollow(LongfollowUserId,BooleanisFollow){//1.获取当前登录用户idLonguserIdUserHolder.getUser().getId();//2.判断关注还是取关if(isFollow){//3.关注FollowfollownewFollow().setUserId(userId).setFollowUserId(followUserId);save(follow);}else{//4.取关remove(newQueryWrapperFollow().eq(user_id,userId).eq(follow_user_id,followUserId));}returnResult.ok();}/** * 查询是否关注 * param followUserId * return */publicResultisFollow(LongfollowUserId){//1.获取当前登录用户idLonguserIdUserHolder.getUser().getId();//2.查询是否关注Integercountquery().eq(user_id,userId).eq(follow_user_id,followUserId).count();//3.大于0代表关注returnResult.ok(count0);}二、共同关注1.先把查看用户主页功能做了才能查看共同关注都是增删改查不细讲2.改造关注功能FollowServiceImpl代码-----------------------------------FollowServiceImpl-------------------------------------ResourceprivateStringRedisTemplatestringRedisTemplate;/** * 关注或取关 * param followUserId * param isFollow * return */publicResultfollow(LongfollowUserId,BooleanisFollow){//1.获取当前登录用户idLonguserIdUserHolder.getUser().getId();//2.判断关注还是取关if(isFollow){//3.关注FollowfollownewFollow().setUserId(userId).setFollowUserId(followUserId);booleanisSuccesssave(follow);if(isSuccess){StringkeyFOLLOW_KEYuserId;stringRedisTemplate.opsForSet().add(key,followUserId.toString());}}else{//4.取关booleanisSuccessremove(newQueryWrapperFollow().eq(user_id,userId).eq(follow_user_id,followUserId));if(isSuccess){stringRedisTemplate.opsForSet().remove(FOLLOW_KEYuserId,followUserId.toString());}}returnResult.ok();}代码/** * 查询共同关注 * param id * return */GetMapping(/common/{id})publicResultfollowCommons(PathVariable(id)Longid){returnfollowService.followCommons(id);}/** * 查询共同关注 * param id * return */publicResultfollowCommons(Longid){//1.获取当前用户idLonguserIdUserHolder.getUser().getId();Stringkey1FOLLOW_KEYuserId;Stringkey2FOLLOW_KEYid;//2.求交集SetStringcommonstringRedisTemplate.opsForSet().intersect(key1,key2);//3.转成long型解析出idif(commonnull||common.isEmpty())returnResult.ok(Collections.emptyList());ListLongcommonIdscommon.stream().map(Long::valueOf).collect(Collectors.toList());//查询用户ListUserDTOusersuserService.listByIds(commonIds).stream().map(user-BeanUtil.copyProperties(user,UserDTO.class)).collect(Collectors.toList());returnResult.ok(users);}三、关注推送1.Feed流的模式(1)拉模式有延迟(2)推模式内存占用比较高(3)推拉结合模式用户量在千万以下都可以用推模式本节我们使用推模式2.基于推模式实现关注推送功能Feed流不能采用传统分页使用不依赖角标的滚动查询而List不支持滚动分页使用sortedSet做滚动分页(1)改造保存博文,推送到粉丝收件箱在保存完探店笔记后获得到当前博主的粉丝然后把数据推送到粉丝的redis中去注意这里是粉丝列表而之前存在redis里的是关注列表ResourceprivateIFollowServicefollowService;/** * 保存博文并推送 * param blog * return */publicResultsaveBlog(Blogblog){//1.获取登录用户UserDTOuserUserHolder.getUser();blog.setUserId(user.getId());//2.保存探店笔记booleanisSuccesssave(blog);if(!isSuccess)returnResult.fail(新增笔记失败);//3.查询笔记作者的所有粉丝ListFollowfollowsfollowService.query().eq(follow_user_id,user.getId()).list();//4.推送笔记id给所有粉丝for(Followfollow:follows){//4.1获取粉丝idLonguserIdfollow.getUserId();//4.2推送给每个粉丝StringkeyFEED_KEYuserId;stringRedisTemplate.opsForZSet().add(key,blog.getId().toString(),System.currentTimeMillis());}returnResult.ok(blog.getId());}(2)实现滚动分页查询需求在个人主页的“关注”卡片中查询并展示推送的Blog信息具体操作如下1、每次查询完成后我们要分析出查询出数据的最小时间戳这个值会作为下一次查询的条件2、我们需要找到与上一次查询相同的查询个数作为偏移量下次查询时跳过这些查询过的数据拿到我们需要的数据综上我们的请求参数中就需要携带 lastId上一次查询的最小时间戳 和偏移量这两个参数。这两个参数第一次会由前端来指定以后的查询就根据后台结果作为条件再次传递到后台。滚动查询每一次查询都记住上一次查询的是谁滚动分页查询参数与上次查询结果中最小值一样的元素都要跳过命令实例1~定义一个滚动分页的DTODatapublicclassScrollResult{privateList?list;privateLongminTime;privateIntegeroffset;}2~查询用户所关注的人的最新博文上一次查询的最小时间是本次查询的最大时间BlogController代码RequestParam 表示接受url地址栏传参的注解当方法上参数的名称和url地址栏不相同时可以通过RequestParam 来进行指定--------------------------------------BlogController-------------------------------------GetMapping(/of/follow)publicResultqueryBlogOfFollow(RequestParam(lastId)Longmax,RequestParam(valueoffset,defaultValue0)Integeroffset){returnblogService.queryBlogOfFollow(max,offset);}BlogServiceImpl代码/** * 查询指定用户所关注的人的最新博文 * param max * param offset * return */publicResultqueryBlogOfFollow(Longmax,Integeroffset){// 1.获取当前用户LonguserIdUserHolder.getUser().getId();// 2.查询收件箱 ZREVRANGEBYSCORE key Max Min LIMIT offset count String key FEED_KEY userId;SetZSetOperations.TypedTupleStringtypedTuplesstringRedisTemplate.opsForZSet().reverseRangeByScoreWithScores(key,0,max,offset,2);// 3.非空判断if(typedTuplesnull||typedTuples.isEmpty()){returnResult.ok();}// 4.解析数据blogId、minTime时间戳、offsetListLongidsnewArrayList(typedTuples.size());longminTime0;// 2intos1;// 2for(ZSetOperations.TypedTupleStringtuple:typedTuples){// 5 4 4 2 2// 4.1.获取idids.add(Long.valueOf(tuple.getValue()));// 4.2.获取分数(时间戳longtimetuple.getScore().longValue();if(timeminTime){os;}else{minTimetime;os1;}}osminTimemax?os:osoffset;// 5.根据id查询blogStringidStrStrUtil.join(,,ids);ListBlogblogsquery().in(id,ids).last(ORDER BY FIELD(id,idStr)).list();for(Blogblog:blogs){// 5.1.查询blog有关的用户queryBlogUser(blog);// 5.2.查询blog是否被点赞isLikedBlog(blog);}// 6.封装并返回ScrollResultrnewScrollResult();r.setList(blogs);r.setOffset(os);r.setMinTime(minTime);returnResult.ok(r);}listByIds底层是MySQL的IN语句所以无法保证顺序要自己写查询逻辑并且不要忘记封装是否点赞过字段以上就是黑马点评实战篇——好友关注部分的学习笔记仅供参考多多支持