springboot项目浏览次数增加实现方案

本文涉及的产品
云数据库 Tair(兼容Redis),内存型 2GB
Redis 开源版,标准版 2GB
推荐场景:
搭建游戏排行榜
简介: 在现实开发工作中,一定会遇到过类似于浏览量统计的需求,关于实现方案有很多,下面结合业务实际场景说下实现方案以及处理过程,希望对有同样需求的同学可以作为参考、有所帮助。

1.背景说明


   在现实开发工作中,一定会遇到过类似于浏览量统计的需求,关于实现方案有很多,下面结合业务实际场景说下实现方案以及处理过程,希望对有同样需求的同学可以作为参考、有所帮助。

   简单交代一下业务场景:

   现在有自研的招聘平台,招聘端发布岗位之后求职端可以实时查看,现在需要统计每个岗位的浏览次数,只要进入到岗位详情页就算一次有效的浏览。


2.实现方案分析


   这类需求最简单的实现方式就是进入到页面之后,调用岗位查询接口,接口中除了返回岗位详情信息之外,再进行浏览次数加一的入表逻辑即可。实现起来是简单了但是考虑一下这种方式有什么弊端?由于岗位详情查看这个动作触发的次数会很多,频繁的调用接口务必会给服务器带来很大的压力,另外浏览量增加这种数据对于主要业务岗位详情查询来讲并不是必要的,架构上可以考虑进行业务分离,降低耦合度之后后期维护也会方便。不进行过多铺垫了,直接说自己的实现方案:

   aop进行业务分离,降低耦合

   redis代替数据库频繁写入缓解服务器压力

   定期缓存处理,批量写入,保证数据同步;


3.处理过程


   下面按照实现思路进行代码实现:

   aop进行业务分离,降低耦合;

自定义切面BrowCountAspect :


@Component
@Aspect
@Slf4j
public class BrowCountAspect {
    @Autowired
    private RedisTemplate redisTemplate;
    // add by txm 2022/12/17 仅对findPostDetailInfoVo方法进行拦截
    @Pointcut("execution(* com.XXX.XXX.XXX.XXX.controller.WantedJobPostController.findPostDetailInfoVo(..))")
    public void browseTimePoint() {
    }
  /**
     * @Author: txm
     * @Description: 接口响应成功之后触发
     * @Param: [responsePostDetailInfoVo]
     * @return: void
     * @Date:  2022/12/17 11:13
     **/
    @AfterReturning(returning = "result",pointcut = "browseTimePoint()")
    public void doAfterRuturn(JoinPoint joinPoint,Object result) {
        ResultVo<PostDetailInfoVo> responsePostDetailInfoVo=(ResultVo<PostDetailInfoVo>) result;
        if(ObjectUtil.isNotNull(responsePostDetailInfoVo) && ObjectUtil.isNotNull(responsePostDetailInfoVo.getData())){
            handleBrowseCount(responsePostDetailInfoVo.getData().getPostId(),responsePostDetailInfoVo.getData().getBrowseCount());
        }
    }
    /**
     * @Author: txm
     * @Description: 浏览次数加一
     * @Param: [responsePostDetailInfoVo]
     * @return: void
     * @Date:  2022/12/17 11:13
     **/
    private synchronized void handleBrowseCount(Long postId,Integer browseCount) {
        // 设置岗位浏览数为数据库中实际的浏览次数,setIfAbsent方法作用:添加过一次之后不会重新添加,每天第一次浏览岗位会记录岗位信息以及浏览次数,在此浏览只会浏览次数加一处理.定时任务会在每天凌晨进行获取当天每个岗位的浏览次数然后批量写入数据库,最后清除缓存中岗位浏览次数
      redisTemplate.opsForValue().setIfAbsent(String.format("jobBrowseCount:post_%s",postId),browseCount));
        redisTemplate.opsForValue().increment(String.format("jobBrowseCount:post_%s",postId));
    }
}


说明

   业务场景只有对岗位详情查看是才实现浏览次数加一,所以此处切入点表达式直接限制到具体的方法即可.

@Pointcut("execution(* com.XXX.XXX.XXX.XXX.controller.WantedJobPostController.findPostDetailInfoVo(..))")
    public void browseTimePoint() {
    }


   aop实现浏览次数加一处理,切面处理逻辑放到方法执行之后.实现逻辑是每次需要设置岗位id以及对应的浏览次数,如果岗位信息已经添加过则直接进行浏览次数加一处理.其中result对象为接口响应返回参数.需要强转成岗位信息获取岗位信息中的浏览次数.

   相关的实体类PostDetailInfoVo以及接口固定的响应参数ResultVo:

PostDetailInfoVo.java:

/**
 * @ClassName: PostDetailInfoVo
 * @Desc:岗位详情信息
 * @Author: txm
 * @Date: 2022/6/21 16:23
 **/
@ApiModel("岗位详情信息")
@Data
@ToString
public class PostDetailInfoVo implements Serializable {
    private static final long serialVersionUID = -3411333643335244983L;
    @ApiModelProperty(value = "求职岗位id",example = "1",dataType = "Long")
    private Long postId;
    // add by txm 2022/12/17 添加岗位浏览次数
    @ApiModelProperty(value = "岗位浏览次数",dataType = "Integer" ,example = "2")
    private Integer browseCount=0;
// 省略其余岗位属性信息
}


ResultVo.java:

@Data
@Builder
@Accessors(chain = true)
@ApiModel("响应参数")
public class ResultVo<T> implements Serializable {
    private static final long serialVersionUID = -8054007511410819665L;
    @ApiModelProperty(value = "响应状态码",example = "1",dataType = "Integer")
    private int code;
    // 是否成功标识.true表示成功,false表示失败
    @ApiModelProperty("success标识,true表示成功,false表示失败")
    private boolean success;
    // 操作成功时需要响应给客户端的响应数据
    @ApiModelProperty("响应信息")
    private String msg;
    // 返回给客户端的具体数据内容,NON_NULL:如果为null就不返回data,NON_EMPTY:如果为空字符串就不返回data
    @ApiModelProperty("响应数据")
//    @JsonInclude(JsonInclude.Include.NON_NULL)
    //@JsonInclude(JsonInclude.Include.NON_EMPTY)
    private T data;
    @ApiModelProperty("当前时间")
    @JSONField(format = "yyyy-MM-dd HH:mm:ss")
    @JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss",timezone = "GMT+8")
    private Date time;
}


   后台每天会读取前一天的岗位浏览次数,并更新到数据库,并将前一天的缓存数据清除.


@Slf4j
@Component
public class ScheduleHandle {
    @Autowired
    private RedisTemplate redisTemplate;
    @Scheduled(cron = "0 5 0 * * *")  // 每天凌晨5分
    public void handle(){
        handleBrowseCount();
    }
    /**
     * @Author: txm
     * @Description: 批量更新岗位浏览次数
     * @Param: []
     * @return: void
     * @Date:  2022/12/17 15:38
     **/
    public void handleBrowseCount() {
        Set<String> browseCountPostSet = redisTemplate.keys("jobBrowseCount:post_*");
        ArrayList<BrowseCountDto> browseCountDtos = new ArrayList<>();
        BrowseCountDto browseCountDto=null;
        if(CollectionUtil.isNotEmpty(browseCountPostSet)){
            for (String postIdInfo : browseCountPostSet) {
                Long postId =Long.valueOf(postIdInfo.substring(20));
                Integer browseCount = (Integer)redisTemplate.opsForValue().get(String.format("jobBrowseCount:post_%s", postId));
                browseCountDto=new BrowseCountDto(browseCount,postId);
                browseCountDtos.add(browseCountDto);
            }
            // 批量更新岗位浏览量,此处入表逻辑不进行展开
            // 删除缓存的浏览次数信息
            redisTemplate.delete(browseCountPostSet);
        }
    }
}


涉及的实体类:

@ApiModel("浏览次数")
@Data
@AllArgsConstructor
public class BrowseCountDto implements Serializable {
    private static final long serialVersionUID = -5948133205817407204L;
    @ApiModelProperty(value = "浏览次数",example = "1",dataType = "Integer")
    private Integer browseCount;
    @ApiModelProperty(value = "岗位id",example = "1",dataType = "Long")
    private Long postId;
}


   至此,以实际项目为例介绍了浏览次数增加的完整实现方案,看到这里如果感觉有帮助欢迎点赞或是评论区留言!


相关实践学习
基于Redis实现在线游戏积分排行榜
本场景将介绍如何基于Redis数据库实现在线游戏中的游戏玩家积分排行榜功能。
云数据库 Redis 版使用教程
云数据库Redis版是兼容Redis协议标准的、提供持久化的内存数据库服务,基于高可靠双机热备架构及可无缝扩展的集群架构,满足高读写性能场景及容量需弹性变配的业务需求。 产品详情:https://www.aliyun.com/product/kvstore &nbsp; &nbsp; ------------------------------------------------------------------------- 阿里云数据库体验:数据库上云实战 开发者云会免费提供一台带自建MySQL的源数据库&nbsp;ECS 实例和一台目标数据库&nbsp;RDS实例。跟着指引,您可以一步步实现将ECS自建数据库迁移到目标数据库RDS。 点击下方链接,领取免费ECS&amp;RDS资源,30分钟完成数据库上云实战!https://developer.aliyun.com/adc/scenario/51eefbd1894e42f6bb9acacadd3f9121?spm=a2c6h.13788135.J_3257954370.9.4ba85f24utseFl
相关文章
|
27天前
|
Java 应用服务中间件
SpringBoot获取项目文件的绝对路径和相对路径
SpringBoot获取项目文件的绝对路径和相对路径
64 1
SpringBoot获取项目文件的绝对路径和相对路径
|
18天前
|
存储 运维 安全
Spring运维之boot项目多环境(yaml 多文件 proerties)及分组管理与开发控制
通过以上措施,可以保证Spring Boot项目的配置管理在专业水准上,并且易于维护和管理,符合搜索引擎收录标准。
31 2
|
22天前
|
分布式计算 关系型数据库 MySQL
SpringBoot项目中mysql字段映射使用JSONObject和JSONArray类型
SpringBoot项目中mysql字段映射使用JSONObject和JSONArray类型 图像处理 光通信 分布式计算 算法语言 信息技术 计算机应用
38 8
|
2月前
|
JavaScript 前端开发 Java
解决跨域问题大集合:vue-cli项目 和 java/springboot(6种方式) 两端解决(完美解决)
这篇文章详细介绍了如何在前端Vue项目和后端Spring Boot项目中通过多种方式解决跨域问题。
367 1
解决跨域问题大集合:vue-cli项目 和 java/springboot(6种方式) 两端解决(完美解决)
|
29天前
|
JavaScript 前端开发 Java
SpringBoot项目的html页面使用axios进行get post请求
SpringBoot项目的html页面使用axios进行get post请求
45 2
|
29天前
|
前端开发 Java Spring
SpringBoot项目thymeleaf页面支持词条国际化切换
SpringBoot项目thymeleaf页面支持词条国际化切换
60 2
|
29天前
|
JSON Java 数据库
SpringBoot项目使用AOP及自定义注解保存操作日志
SpringBoot项目使用AOP及自定义注解保存操作日志
38 1
|
1月前
|
JavaScript Java 项目管理
Java毕设学习 基于SpringBoot + Vue 的医院管理系统 持续给大家寻找Java毕设学习项目(附源码)
基于SpringBoot + Vue的医院管理系统,涵盖医院、患者、挂号、药物、检查、病床、排班管理和数据分析等功能。开发工具为IDEA和HBuilder X,环境需配置jdk8、Node.js14、MySQL8。文末提供源码下载链接。
|
13天前
|
JavaScript 前端开发 Java
SpringBoot项目的html页面使用axios进行get post请求
SpringBoot项目的html页面使用axios进行get post请求
31 0
|
1月前
|
关系型数据库 MySQL Java
SpringBoot项目中mysql字段映射使用JSONObject和JSONArray类型
SpringBoot项目中mysql字段映射使用JSONObject和JSONArray类型
27 0