Springboot-结合ehcache实现文章浏览量功能(通过ip唯一)

本文主要是介绍Springboot-结合ehcache实现文章浏览量功能(通过ip唯一),希望对大家解决编程问题提供一定的参考价值,需要的开发者们随着小编来一起学习吧!

背景

想要实现一个单机应用,就是普通的浏览量功能实现,如果同一个ip地址点击的文章多次的话,只能算是一次点击,因为是分布式,所以不想安装Redis服务。
EhCache 是一个纯Java的进程内缓存框架,具有快速、精干等特点,是Hibernate中默认的CacheProvider。
所以自己实现了一个使用缓存添加浏览量的功能,减少服务器的负担,要经常操作数据库。

前提条件

  1. 添加依赖 版本2.6.11用这个,较高版本在删掉了一些方法,高版本未实现
<!-- ehcache缓存   --><dependency><groupId>net.sf.ehcache</groupId><artifactId>ehcache-core</artifactId><version>2.6.11</version></dependency></dependencies>
  1. 在resources包下添加ehcache.xml 相关配置说明可以百度
<?xml version="1.0" encoding="UTF-8"?>
<ehcache updateCheck="false" dynamicConfig="false"><diskStore path="java.io.tmpdir"/><!--日点击量缓存--><cache name="dayHits" maxEntriesLocalHeap="500" eternal="true" overflowToDisk="true"></cache></ehcache>
  1. 修改application.yml文件
 # 缓存spring:cache:ehcache:config: ehcache.xml

controller

ApiResponse 只是我自定义返回的一个实体对象

/*** @description: 文章控制类* @author: yuxiang* @create: 2019-11-30 15:34**/
@RequestMapping("/article")
@RestController
public class ArticleController {@Autowiredprivate ArticleService articleService;//缓存private static CacheManager cacheManager = CacheManager.newInstance();private static Long viewArticleTime = System.currentTimeMillis();/*** 增加浏览量* @param id* @return*/@PostMapping("visitCount")public ApiResponse visitCount(@RequestParam("id")String id, HttpServletRequest request){ApiResponse response = new ApiResponse();try {Integer count = cacheCount(id, IpUtil.getIpAddr(request));response.setMsg("浏览量添加成功");response.setObj(count);}catch (Exception e){e.printStackTrace();return new ApiResponse<>(-1,"服务器错误,添加浏览量失败");}return response;}/*** 缓存点击量方法* @param articleId* @return*/public Integer cacheCount(String articleId,String Ip){ArticleEntity articleEntity = articleService.findById(articleId);//查询缓存Ehcache cache = cacheManager.getEhcache("dayHits");Element element = cache.get(Ip+articleId+"_count");Integer count = 0;if(element!=null){//如果缓存存在,则不增加countcount = (Integer) element.getValue();}else{count = articleEntity.getVisitCount()== null?0:articleEntity.getVisitCount();count++;cache.put(new Element(Ip+articleId+"_count",count));}cache.put(new Element(Ip+articleId+"_dayHitsDate",new SimpleDateFormat("yyyy-MM-dd").format(TimeUtil.getDayZero())));System.out.println("==========================>>>"+new SimpleDateFormat("yyyy-MM-dd").format(TimeUtil.getDayZero()));//超过有效时间更新数据库Long time = System.currentTimeMillis();if(time > (viewArticleTime+ 300000)){viewArticleTime = time;articleEntity.setVisitCount(count);articleService.saveArticle(articleEntity);cache.removeAll();}return count;}}

工具类

重要:获取ip地址工具类

/*** @description: ip工具类* @author: yuxiang* @create: 2019-12-01 17:57**/
public class IpUtil {public static String getIpAddr(HttpServletRequest request){String ipAddress = null;try {ipAddress = request.getHeader("x-forwarded-for");if (ipAddress == null || ipAddress.length() == 0 || "unknown".equalsIgnoreCase(ipAddress)) {ipAddress = request.getHeader("Proxy-Client-IP");}if (ipAddress == null || ipAddress.length() == 0 || "unknown".equalsIgnoreCase(ipAddress)) {ipAddress = request.getHeader("WL-Proxy-Client-IP");}if (ipAddress == null || ipAddress.length() == 0 || "unknown".equalsIgnoreCase(ipAddress)) {ipAddress = request.getRemoteAddr();if (ipAddress.equals("127.0.0.1")) {// 根据网卡取本机配置的IPInetAddress inet = null;try {inet = InetAddress.getLocalHost();} catch (UnknownHostException e) {e.printStackTrace();}ipAddress = inet.getHostAddress();}}// 对于通过多个代理的情况,第一个IP为客户端真实IP,多个IP按照','分割if (ipAddress != null && ipAddress.length() > 15) { // "***.***.***.***".length()// = 15if (ipAddress.indexOf(",") > 0) {ipAddress = ipAddress.substring(0, ipAddress.indexOf(","));}}} catch (Exception e) {ipAddress="";}// ipAddress = this.getRequest().getRemoteAddr();return ipAddress;}
}
/*** @Description 时间工具类* @Author yuxiang* @CreatedDate 2019/7/27 18:58*/
public class TimeUtil {/*** 返回今天零点* @return*/public  static Long getDayZero() {Calendar calendar = Calendar.getInstance();Long zero = calendar.getTime().getTime() / (1000 * 3600 * 24) * (1000 * 3600 * 24) - TimeZone.getDefault().getRawOffset();return zero;}/*** 根据截至时间戳返回今天零点* @return*/public  static Long getDayZero(Long endTime) {Calendar calendar = Calendar.getInstance();calendar.setTimeInMillis(endTime);Long zero = calendar.getTime().getTime() / (1000 * 3600 * 24) * (1000 * 3600 * 24) - TimeZone.getDefault().getRawOffset();return zero;}/*** 获取当前时间* @return*/public  static Long getCurrent() {Calendar calendar = Calendar.getInstance();Long zero = calendar.getTime().getTime();return zero;}
}
参考

springboot+EHcache 实现文章浏览量的缓存和超时更新

还是存在一些bug吧,这个能达到一天之内重复ip点击同一文章算一次点击,有时间再修改一下逻辑过来,对ehcache不是很熟悉,如果用注解的话,又达不到Redis根据key获取值的效果。

这篇关于Springboot-结合ehcache实现文章浏览量功能(通过ip唯一)的文章就介绍到这儿,希望我们推荐的文章对编程师们有所帮助!


原文地址:
本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.chinasem.cn/article/498008

相关文章

Linux虚拟机不显示IP地址的解决方法(亲测有效)

《Linux虚拟机不显示IP地址的解决方法(亲测有效)》本文主要介绍了通过VMware新装的Linux系统没有IP地址的解决方法,主要步骤包括:关闭虚拟机、打开VM虚拟网络编辑器、还原VMnet8或修... 目录前言步骤0.问题情况1.关闭虚拟机2.China编程打开VM虚拟网络编辑器3.1 方法一:点击还原VM

Java实现将byte[]转换为File对象

《Java实现将byte[]转换为File对象》这篇文章将通过一个简单的例子为大家演示Java如何实现byte[]转换为File对象,并将其上传到外部服务器,感兴趣的小伙伴可以跟随小编一起学习一下... 目录前言1. 问题背景2. 环境准备3. 实现步骤3.1 从 URL 获取图片字节数据3.2 将字节数组

Win32下C++实现快速获取硬盘分区信息

《Win32下C++实现快速获取硬盘分区信息》这篇文章主要为大家详细介绍了Win32下C++如何实现快速获取硬盘分区信息,文中的示例代码讲解详细,感兴趣的小伙伴可以跟随小编一起学习一下... 实现代码CDiskDriveUtils.h#pragma once #include <wtypesbase

Nginx实现前端灰度发布

《Nginx实现前端灰度发布》灰度发布是一种重要的策略,它允许我们在不影响所有用户的情况下,逐步推出新功能或更新,通过灰度发布,我们可以测试新版本的稳定性和性能,下面就来介绍一下前端灰度发布的使用,感... 目录前言一、基于权重的流量分配二、基于 Cookie 的分流三、基于请求头的分流四、基于请求参数的分

Java捕获ThreadPoolExecutor内部线程异常的四种方法

《Java捕获ThreadPoolExecutor内部线程异常的四种方法》这篇文章主要为大家详细介绍了Java捕获ThreadPoolExecutor内部线程异常的四种方法,文中的示例代码讲解详细,感... 目录方案 1方案 2方案 3方案 4结论方案 1使用 execute + try-catch 记录

Python Excel实现自动添加编号

《PythonExcel实现自动添加编号》这篇文章主要为大家详细介绍了如何使用Python在Excel中实现自动添加编号效果,文中的示例代码讲解详细,感兴趣的小伙伴可以跟随小编一起学习一下... 目录1、背景介绍2、库的安装3、核心代码4、完整代码1、背景介绍简单的说,就是在Excel中有一列h=会有重复

SpringBoot接收JSON类型的参数方式

《SpringBoot接收JSON类型的参数方式》:本文主要介绍SpringBoot接收JSON类型的参数方式,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐教... 目录一、jsON二、代码准备三、Apifox操作总结一、JSON在学习前端技术时,我们有讲到过JSON,而在

Spring-AOP-ProceedingJoinPoint的使用详解

《Spring-AOP-ProceedingJoinPoint的使用详解》:本文主要介绍Spring-AOP-ProceedingJoinPoint的使用方式,具有很好的参考价值,希望对大家有所帮... 目录ProceedingJoinPoijsnt简介获取环绕通知方法的相关信息1.proceed()2.g

Spring Security注解方式权限控制过程

《SpringSecurity注解方式权限控制过程》:本文主要介绍SpringSecurity注解方式权限控制过程,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐教... 目录一、摘要二、实现步骤2.1 在配置类中添加权限注解的支持2.2 创建Controller类2.3 Us

Spring MVC跨域问题及解决

《SpringMVC跨域问题及解决》:本文主要介绍SpringMVC跨域问题及解决方案,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐教... 目录跨域问题不同的域同源策略解决方法1.CORS2.jsONP3.局部解决方案4.全局解决方法总结跨域问题不同的域协议、域名、端口