文章详情

短信预约-IT技能 免费直播动态提醒

请输入下面的图形验证码

提交验证

短信预约提醒成功

微服务Spring Boot 整合 Redis 实现好友关注 – Feed流实现推送到粉丝收件箱

2023-08-18 09:58

关注

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

在点评项目中,有这样的需求,如何 Redis 实现好友关注 – Feed流实现推送到粉丝收件箱 功能?

采用 Feed流实现推送到粉丝收件箱

Redis 如此强大!

⛅Feed 流实现方案

假设我们关注了用户,这个用户发布了动态,那么就应该把当前用户发布的动态推送给他的粉丝,如何实现呢,这个我们把它叫做Feed流,关注推送也叫做 Feed流 ,直译为投喂,为用户持续的提供 ”沉浸式“ 的体验,通过五险下拉刷新获取新的信息。

传统模式是我们需要用户去通过搜索引擎或者是其它的方式去解锁想要看的内容

在这里插入图片描述

新型的Feed流: 不需要用户再去推送消息,而是系统分析用户到底想要什么,然后直接把内容推送给用户,从而使用户能够更加的节约时间,不用主动寻找。

Feed流主要分为两种实现方式

TimeLine: 不做内容筛选,简单的按照内容发布时间排序,常用于好友或关注。例如朋友圈

智能排序:利用智能算法屏蔽掉违规的、用户不感兴趣的内容。推送用户感兴趣信息来吸引用户

本次实现的功能中,是基于好友 来做Feed流,因此采用 TimeLine 模式。 该模式的实现方案分为三种

拉模式:也叫做读扩散

该模式的核心含义就是:当张三和李四和王五发了消息后,都会保存在自己的邮箱中,假设赵六要读取信息,那么他会从读取他自己的收件箱,此时系统会从他关注的人群中,把他关注人的信息全部都进行拉取,然后在进行排序

优点:比较节省空间,因为用户在读取信息时,并没有重复读取,而是读取完后可以把他的收件箱进行清除

缺点:比较延迟,当用户读取数据时才去关注的用户的人里面读取数据,假设用户关注了大量的用户,那么此时就会拉取海量的数据内容,对服务器压力比较大。

在这里插入图片描述

推模式:也叫做写扩散

推模式是没有写邮箱的,当张三写了一个内容,此时会主动的把张三写的内容发送到他的粉丝收件箱中去,假设此时李四再来读取,就不用再去临时拉取

优点:时效快,不用临时拉取

缺点:内存压力大,假设一个大V写信息,很多人关注他,就会写很多的数据到粉丝收件箱,加大服务器压力

在这里插入图片描述

推拉结合模式:也叫做读写混合,兼具推和拉两种模式的优点

推拉模式是一个折中的方案,站在发件人这一段,如果是个普通的人,那么我们采用写扩散的方式,直接把数据写入到他的粉丝中去,因为普通的人他的粉丝关注量比较小,所以这样做没有压力,如果是大V,那么他是直接将数据先写入到一份到发件箱里边去,然后再直接写一份到活跃粉丝收件箱里边去,现在站在收件人这端来看,如果是活跃粉丝,那么大V和普通的人发的都会直接写入到自己收件箱里边来,而如果是普通的粉丝,由于他们上线不是很频繁,所以等他们上线时,再从发件箱里边去拉信息。

在这里插入图片描述

⚡推送到粉丝收件箱

需求:

核心:当我们保存完笔记后,获取当前用户的粉丝,然后把数据推送到粉丝的Redis中。

@Overridepublic Result saveBlog(Blog blog) {    // 1.获取登录用户    UserDTO user = UserHolder.getUser();    blog.setUserId(user.getId());    // 2.保存探店笔记    boolean isSuccess = save(blog);    if(!isSuccess){        return Result.fail("新增笔记失败!");    }    // 3.查询笔记作者的所有粉丝 select * from tb_follow where follow_user_id = ?    List follows = followService.query().eq("follow_user_id", user.getId()).list();    // 4.推送笔记id给所有粉丝    for (Follow follow : follows) {        // 4.1.获取粉丝id        Long userId = follow.getUserId();        // 4.2.推送        String key = FEED_KEY + userId;        stringRedisTemplate.opsForZSet().add(key, blog.getId().toString(), System.currentTimeMillis());    }    // 5.返回id    return Result.ok(blog.getId());}

进行测试

发布笔记

在这里插入图片描述

查看粉丝收件箱

在这里插入图片描述

滚动分页查询思路分析

Feed流中的数据会不断更新,所以数据的角标也在变化,因此不能采用传统的分页模式。

传统了分页在feed流是不适用的,因为我们的数据会随时发生变化

假设在t1 时刻,我们去读取第一页,此时page = 1 ,size = 5 ,那么我们拿到的就是10~6 这几条记录,假设现在t2时候又发布了一条记录,此时t3 时刻,我们来读取第二页,读取第二页传入的参数是page=2 ,size=5 ,那么此时读取到的第二页实际上是从6 开始,然后是6~2 ,那么我们就读取到了重复的数据,所以feed流的分页,不能采用原始方案来做。

在这里插入图片描述

Feed流的滚动分页

我们需要记录每次操作的最后一条,然后从这个位置开始去读取数据

举个例子:我们从t1时刻开始,拿第一页数据,拿到了10~6,然后记录下当前最后一次拿取的记录,就是6,t2时刻发布了新的记录,此时这个11放到最顶上,但是不会影响我们之前记录的6,此时t3时刻来拿第二页,第二页这个时候拿数据,还是从6后一点的5去拿,就拿到了5-1的记录。我们这个地方可以采用sortedSet来做,可以进行范围查询,并且还可以记录当前获取数据时间戳最小值,就可以实现滚动分页了

在这里插入图片描述

实现滚动分页查询

需求:

具体操作

每次查询完成后,我们要分析出查询数据的最小时间戳,这个值会作为下一次的查询条件

我们需要找到与上一次查询相同的查询个数作为偏移量,下次查询后,跳过这些查询过的数据,拿到需要的数据

核心: 我们的请求参数中 就需要携带 lastId,上一次查询的 最小时间戳偏移量 这两个参数

这两个参数第一次由前端来指定,以后的查询就根据后台结果作为条件,再次传递给后台。

在这里插入图片描述

核心源码

一、定义出 具体的 返回实体类

@Datapublic class ScrollResult {    private List list;    private Long minTime;    private Integer offset;}

BlogController

RequestParam 表示接受url地址栏传参的注解,当方法上参数的名称和url地址栏不相同时,可以通过RequestParam 来进行指定

@GetMapping("/of/follow")public Result queryBlogOfFollow(@RequestParam("lastId") Long max, @RequestParam(value = "offset", defaultValue = "0")    Integer offset) {    return blogService.queryBlogOfFollow(max, offset);}

BlogServiceImpl

@Overridepublic Result queryBlogOfFollow(Long max, Integer offset) {    // 1.获取当前用户    Long userId = UserHolder.getUser().getId();    // 2.查询收件箱 ZREVRANGEBYSCORE key Max Min LIMIT offset count    String key = RedisConstants.FEED_KEY + userId;    Set> typedTuples = stringRedisTemplate.opsForZSet()        .reverseRangeByScoreWithScores(key, 0, max, offset, 2);    // 3.非空判断    if (typedTuples == null || typedTuples.isEmpty()) {        return Result.ok();    }    // 4.解析数据:blogId、minTime(时间戳)、offset    List ids = new ArrayList<>(typedTuples.size());    long minTime = 0; // 2    int os = 1; // 2    for (ZSetOperations.TypedTuple tuple : typedTuples) { // 5 4 4 2 2        // 4.1.获取id        ids.add(Long.valueOf(tuple.getValue()));        // 4.2.获取分数(时间戳)        long time = tuple.getScore().longValue();        if(time == minTime){            os++;        }else{            minTime = time;            os = 1;        }    }    os = minTime == max ? os : os + offset;    // 5.根据id查询blog    String idStr = StrUtil.join(",", ids);    List blogs = query().in("id", ids).last("ORDER BY FIELD(id," + idStr + ")").list();    for (Blog blog : blogs) {        // 5.1.查询blog有关的用户        queryBlogUser(blog);        // 5.2.查询blog是否被点赞        isBlogLiked(blog);    }    // 6.封装并返回    ScrollResult r = new ScrollResult();    r.setList(blogs);    r.setOffset(os);    r.setMinTime(minTime);    return Result.ok(r);}

结果测试

在这里插入图片描述

以上就是【Bug 终结者】对 微服务Spring Boot 整合 Redis 实现好友关注 – Feed流实现推送到粉丝收件箱 的简单介绍,微服务Spring Boot 整合 Redis 实现好友关注 – Feed流实现推送到粉丝收件箱功能也是 利用Set集合、ZSet集合实现这样一个需求,同时,采用Redis来实现更加的快速,减少系统的消耗,更加快速的实现数据展示!

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

来源地址:https://blog.csdn.net/weixin_45526437/article/details/128322385

阅读原文内容投诉

免责声明:

① 本站未注明“稿件来源”的信息均来自网络整理。其文字、图片和音视频稿件的所属权归原作者所有。本站收集整理出于非商业性的教育和科研之目的,并不意味着本站赞同其观点或证实其内容的真实性。仅作为临时的测试数据,供内部测试之用。本站并未授权任何人以任何方式主动获取本站任何信息。

② 本站未注明“稿件来源”的临时测试数据将在测试完成后最终做删除处理。有问题或投稿请发送至: 邮箱/279061341@qq.com QQ/279061341

软考中级精品资料免费领

  • 历年真题答案解析
  • 备考技巧名师总结
  • 高频考点精准押题
  • 2024年上半年信息系统项目管理师第二批次真题及答案解析(完整版)

    难度     813人已做
    查看
  • 【考后总结】2024年5月26日信息系统项目管理师第2批次考情分析

    难度     354人已做
    查看
  • 【考后总结】2024年5月25日信息系统项目管理师第1批次考情分析

    难度     318人已做
    查看
  • 2024年上半年软考高项第一、二批次真题考点汇总(完整版)

    难度     435人已做
    查看
  • 2024年上半年系统架构设计师考试综合知识真题

    难度     224人已做
    查看

相关文章

发现更多好内容

猜你喜欢

AI推送时光机
位置:首页-资讯-后端开发
咦!没有更多了?去看看其它编程学习网 内容吧
首页课程
资料下载
问答资讯