Spring Boot 应用场景Redis实现代码示例
1. Redis作用
在Springboot中提供了spring-data-redis操作Redis很方便,底层它提供了Jedis和Lettuce两种方式来访问Redis,通过Springboot配置就可以完成Jedis和Lettuce的集成,使得集成非常简单。同时它也提供了统一的访问类RedisTemplate来访问Redis,使得访问Redis接口统一,代码也更优雅。同时它也提供了序列化数据的方式,使得读取和存储数据更加简单,更加高效。但在使用SpringDataRedis时,也需要注意一些问题,特别是序列化引起的兼容性问题,需要多加注意。这篇文章将从各个方面详细的讲解在SpringBoot中使用Redis的注意事项。
2. 网站的访问次数应用场景
大型网站访问次数的查询、更新非常频繁,如果通过关系数据库读写,无疑会耗费大量的性能,而使用 Redis 可以大幅提高速度并降低对关系数据库的消耗。
2.1 使用 Spring Initializr 创建项目
Spring Boot 版本选择 2.2.5 ,Group 为 com.imooc , Artifact 为 spring-boot-redis,生成项目后导入 Eclipse 开发环境。
2.2 引入项目依赖
我们引入 Web 项目依赖与 Redis 依赖。
实例:
<!-- Web 依赖 --> <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-web</artifactId> </dependency> <!-- Redis 依赖 --> <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-data-redis</artifactId> </dependency>
2.3 配置 Redis 数据库连接
修改 application.properties 配置文件内容如下。
实例:
# Redis库的编号spring.redis.database=0# Redis实例地址spring.redis.host=127.0.0.1# Redis实例端口号,默认6379spring.redis.port=6379# Redis登录密码spring.redis.password=Easy@0122# Redis连接池最大连接数spring.redis.jedis.pool.max-active=10# Redis连接池最大空闲连接数spring.redis.jedis.pool.max-idle=10# Redis连接池最小空闲连接数spring.redis.jedis.pool.min-idle=0
2.4 开发网站访问统计服务类
开发网站访问统计服务类,在第 1 次获取访问次数时初始化次数为 0 ,后续每次访问次数加 1 。
实例:
/** * 网站访问统计服务类 */@Servicepublic class VisitService { // 设定访问次数Redis键名 private final static String KEY = "visit_count"; // 注入redisTemplate操作Redis @Autowired private RedisTemplate<String, String> redisTemplate; // 获取当前访问次数 public String getCurrentCount() { String count = redisTemplate.opsForValue().get(KEY); if (count == null || "".equals(count)) { redisTemplate.opsForValue().set(KEY, "0"); return "0"; } return count; } // 访问次数加1 public void addCount() { redisTemplate.opsForValue().increment(KEY, 1); }}
2.5 并发访问测试
我们通过测试类发起并发访问测试,代码如下:
实例:
/** * 访问统计服务测试 */@SpringBootTestclass VisitServiceTest { private Logger logger = LoggerFactory.getLogger(this.getClass()); @Autowired private VisitService visitService; @Test void test() { logger.info("访问次数:{}", visitService.getCurrentCount()); // 使用线程池快速发起10000次访问 ExecutorService cachedThreadPool = Executors.newCachedThreadPool(); for (int i = 0; i < 10000; i++) { cachedThreadPool.execute(new Runnable() { public void run() { visitService.addCount(); } }); } }}
此时我们通过 Redis 客户端发现 visit_count 的值如下:
Tips:Redis 中的操作都是原子性的,要么执行,要么不执行,在高并发场景下依然可以准确的进行计数,关键是速度还非常之快!
3. 热门商品排行榜
如果是大型网站,时刻有很多用户在访问网页,对热门商品排行榜的访问频率是非常恐怖的。
我们可以通过定时器,定时从关系数据库中取出热门商品数据放入 Redis 缓存,用户访问网页时,直接从缓存中获取热门商品数据。这将大大提高响应速度,并降低对关系数据库的性能损耗。
3.1 定义商品类
我们简单的定义一个商品类,便于展现商品排行榜数据。
实例:
/** * 商品类 */public class GoodsDo { /** * 商品id */ private Long id; /** * 商品名称 */ private String name; /** * 商品价格 */ private String price; /** * 商品图片 */ private String pic; // 省略get set方法}
3.2 开发商品排行榜服务类
开发商品排行榜服务类,负责从数据库查询最新排行榜信息,并更新到 Redis ,以及从 Redis 中取出排行榜信息。
实例:
/** * 商品排行榜服务类 */@Servicepublic class GoodsRankService { // 设定商品排行榜Redis键名 private final static String KEY = "goods_rank"; // 注入redisTemplate操作Redis @Autowired private RedisTemplate<String, String> redisTemplate; // 更新Redis缓存的排行榜 public void updateRankList() throws JsonProcessingException { // 此处直接定义商品排行榜,真实场景应为从数据库获取 List<GoodsDo> rankList = new ArrayList<GoodsDo>(); GoodsDo goods = new GoodsDo(); goods.setId(1L); goods.setName("鸡蛋" + new Date());// 添加时间信息,以便测试缓存更新了 rankList.add(goods); // 将rankList序列化后写入Reidis ObjectMapper mapper = new ObjectMapper(); redisTemplate.opsForValue().set(KEY, mapper.writeValueAsString(rankList)); } // 获取Redis缓存的排行榜 public List<GoodsDo> getRandkList() throws JsonMappingException, JsonProcessingException { ObjectMapper mapper = new ObjectMapper(); return mapper.readValue(redisTemplate.opsForValue().get(KEY), List.class); }}
3.3 通过定时器更新排行榜
为启动类添加 @EnableScheduling 注解,以便开启定时任务,然后编写 RankListUpdateTask 类定时刷新排行榜。
实例:
/** * 排行榜更新任务 */@Componentpublic class RankListUpdateTask { @Autowired private GoodsRankService goodsRankService; /** * 容器启动后马上执行,且每1秒执行1次 */ @Scheduled(initialDelay = 0, fixedRate = 1000) public void execute() throws InterruptedException, JsonProcessingException { goodsRankService.updateRankList(); }}
3.4 开发控制器方法
我们还需要一个控制器方法,用于演示获取商品列表的结果。
实例:
@RestControllerpublic class GoodsRankController { @Autowired private GoodsRankService goodsRankService; @GetMapping("getRankList") public List getRankList() throws Exception { return goodsRankService.getRandkList(); }}
3.5 测试
运行启动类,然后访问 http://127.0.0.1:8080/getRankList
,结果如下:
[{"id":1,"name":"鸡蛋Thu May 28 22:47:33 CST 2020","price":null,"pic":null}]
稍等会再次访问,结果如下:
[{"id":1,"name":"鸡蛋Thu May 28 22:48:09 CST 2020","price":null,"pic":null}]
说明我们设计的缓存机制生效了。
4. 小结
开发的项目多了,越来越能体会,传统数据库访问速度是限制系统性能的最大瓶颈。
而 Redis 基于内存的特性,可以极大地提高读写效率,使用得当,往往使系统性能有质的提升。
Spring Boot 可以非常方便地集成 Redis ,当我们在项目开发中遇到访问频率非常高的热点数据时,可以优先考虑使用 Redis 进行存储操作。
原文链接: https://www.yukx.com/spring/article/details/2152.html 优科学习网Spring Boot 应用场景Redis实现代码示例
-
在HTML中,如果你想让一个输入框(input元素)不可编辑,你可以通过设置其readonly属性来实现。示例如下:input type="text" value="此处内容不可编辑" readonly在上述代码中,readonly属性使得用户无法修改输入框中的内容。另外,如果你希望输入框完全不可交
-
ASP.NET教程ASP.NET又称为ASP+,基于.NETFramework的Web开发平台,是微软公司推出的新一代脚本语言。ASP.NET是一个使用HTML、CSS、JavaScript和服务器脚本创建网页和网站的开发框架。ASP.NET支持三种不一样的开发模式:WebPages(Web页面)、
-
C# 判断判断结构要求程序员指定一个或多个要评估或测试的条件,以及条件为真时要执行的语句(必需的)和条件为假时要执行的语句(可选的)。下面是大多数编程语言中典型的判断结构的通常形式:判断语句C#提供了以下类型的判断语句。点击链接查看每个语句的细节。语句描述if语句一个 if语句 由一个布尔表达式后跟
-
C#循环有的时候,可能需要多次执行同一块代码。通常情况下,语句是顺序执行的:函数中的第一个语句先执行,接着是第二个语句,依此类推。编程语言提供了允许更为复杂的执行路径的多种控制结构。循环语句允许我们多次执行一个语句或语句组,下面是大多数编程语言中循环语句的通常形式:循环类型C#提供了以下几种循环类型
-
C#数组(Array)数组是一个存储相同类型元素的固定大小的顺序集合。数组是用来存储数据的集合,一般认为数组是一个同一类型变量的集合。声明数组变量并不是声明number0、number1、...、number99一个个单独的变量,而是声明一个就像numbers这样的变量,然后使用numbers[0]
-
ASP.NET是一个由微软公司开发的用于构建Web应用程序的框架,它是.NETFramework的一部分。它提供了一种模型-视图-控制器(MVC)架构、Web表单以及最新的ASP.NETCore中的RazorPages等多种开发模式,可以用来创建动态网页和Web服务。以下是一些基础的ASP.NET编