Java模拟并解决缓存穿透
Java模拟并解决缓存穿透
什么叫做缓存穿透
缓存穿透只会发生在高并发的时候，就是当有10000个并发进行查询数据的时候，我们一般都会先去redis里面查询进行数据，但是如果redis里面没有这个数据的时候，那么这10000个并发里面就会有很大一部分并发会一下子都去mysql数据库里面进行查询了
解决缓存穿透
首先我模拟一下缓存穿透
比如下面的代码
在这里插入图片描述
Pom.xml代码
<?xml version="1.0" encoding="UTF-8"?>
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd"> <modelVersion>4.0.0</modelVersion> <groupId>com.example</groupId> <artifactId>springboot</artifactId> <version>0.0.1-SNAPSHOT</version> <packaging>jar</packaging> <name>springboot</name> <description>Demo project for Spring Boot</description> <parent> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-parent</artifactId> <version>2.1.1.RELEASE</version> <relativePath></relativePath> <!-- lookup parent from repository --> </parent> <properties> <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding> <project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding> <java.version>1.8</java.version> </properties> <dependencies> <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-web</artifactId> </dependency> <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-devtools</artifactId> </dependency> <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-test</artifactId> <scope>test</scope> </dependency> <dependency> <groupId>org.mybatis.spring.boot</groupId> <artifactId>mybatis-spring-boot-starter</artifactId> <version>1.1.1</version> </dependency> <dependency> <groupId>mysql</groupId> <artifactId>mysql-connector-java</artifactId> </dependency> </dependencies> <build> <plugins> <plugin> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-maven-plugin</artifactId> </plugin> </plugins> </build> Application.properties
server.port=8081
DB Configuration:
spring.datasource.driverClassName=com.mysql.jdbc.Driver
spring.datasource.url=jdbc:mysql://47.91.248.236:3306/hello?useUnicode=true&characterEncoding=utf8
spring.datasource.username=root
spring.datasource.password=root
spring集成Mybatis环境
pojo别名扫描包
mybatis.type-aliases-package=com.itheima.domain
加载Mybatis映射文件
mybatis.mapper-locations=classpath:mapper/*Mapper.xml
MyController代码，下面的蓝色代码是模仿10000个并发线程
/**
- sinture.com Inc.
- Copyright (c) 2016-2018 All Rights Reserved.
*/
package com.itheima.controller;
import com.itheima.mapper.UserMapper;
import com.itheima.domain.User;
import com.itheima.service.UserService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.PathVariable;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.ResponseBody;
import org.springframework.web.bind.annotation.RestController;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
/**
- @author xinzhu
- @version Id: MyController.java, v 0.1 2018年12月05日 下午6:29 xinzhu Exp $
*/
@RestController
public class MyController {
@Autowired private UserService userService; @RequestMapping("/hello/{id}") @ResponseBody public User queryUser(@PathVariable Integer id){ // 蓝色代码注释开始 new Thread(){ @Override public void run() { for (int x = 0; x < 10000; x++) { userService.queryUser(id); } } }.start(); // 蓝色代码注释结束 return userService.queryUser(id); }}
User类
/**
- sinture.com Inc.
- Copyright (c) 2016-2018 All Rights Reserved.
*/
package com.itheima.domain;
/**
- @author xinzhu
- @version Id: User.java, v 0.1 2018年12月06日 下午1:40 xinzhu Exp $
*/
public class User {
// 主键 private Integer id; // 用户名 private String username; // 密码 private String password; // 姓名 private String name; public void setId(Integer id) { this.id = id; } @Override public String toString() { return "User{" + "id=" + id + ", username='" + username + '\'' + ", password='" + password + '\'' + ", name='" + name + '\'' + '}'; } public Integer getId() { return id; } public String getUsername() { return username; } public void setUsername(String username) { this.username = username; } public String getPassword() { return password; } public void setPassword(String password) { this.password = password; } public String getName() { return name; } public void setName(String name) { this.name = name; }}
UserService
package com.itheima.service;
import com.itheima.domain.User;
public interface UserService {
public User queryUser(Integer id);}
UserServiceImpl，下面的蓝色代码就是模仿redis，此时要注意下面的模拟redis的map集合必须放到下面的queryUser的外面，也就是说下面的userMap变量必须是成员变量，不然的话，因为redis是被多个线程共享的，如果你放到下面的queryUser()方法里面，那么就是多个线程有多个userMap集合，下面的代码就是如果查询到数据，那么就用redis里面的，如果查询不到就用数据库里面的
package com.itheima.service;
import com.itheima.domain.User;
import com.itheima.mapper.UserMapper;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import java.util.HashMap;
import java.util.Map;
@Service
public class UserServiceImpl implements UserService {
@Autowired private UserMapper userMapper; // 蓝色代码注释开始 static Map<Integer,User> userMap=new HashMap(); static { User huancun_user =new User(); huancun_user.setId(1); huancun_user.setName("zhangsan"); huancun_user.setPassword("123"); huancun_user.setName("张三"); userMap.put(1,huancun_user); } // 蓝色代码注释结束 public User queryUser(Integer id){ User user=userMap.get(id); if(user==null){ user= userMapper.queryUser(id); System.out.println("查询数据库"); userMap.put(user.getId(),user); }else{ System.out.println("查询缓存"); } return user; };}
SpringbootApplication代码
package com.itheima;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
@SpringBootApplication
public class SpringbootApplication {
public static void main(String[] args) { SpringApplication.run(SpringbootApplication.class, args); } }
数据库里面的数据如下
-- ----------------------------
-- Table structure for user
-- ----------------------------
DROP TABLE IF EXISTS user;
CREATE TABLE user (id int(11) NOT NULL AUTO_INCREMENT,username varchar(50) DEFAULT NULL,password varchar(50) DEFAULT NULL,name varchar(50) DEFAULT NULL,
PRIMARY KEY (id)
) ENGINE=InnoDB AUTO_INCREMENT=10 DEFAULT CHARSET=utf8;
-- ----------------------------
-- Records of user
-- ----------------------------
INSERT INTO user VALUES ('1', 'zhangsan', '123', '张三');
INSERT INTO user VALUES ('2', 'lisi', '123', '李四');
然后我们查询下面的链接，因为此时上面的模拟redis的map集合里面没有id值是2的数据，所以此时都是查询数据库，你想这一下子10000并发过去，数据库会有很大压力的，
在这里插入图片描述
然后打印结果如下，就是打印了很多查询数据库和查询缓存，此时也就说明10000个并发里面有很多去查询了数据库，这个是要避免的，至于为什么有查询缓存的打印，因为我们把查询的数据给放到模拟的redis里面了啊，所以刚开始的一大部分线程都是查询数据库，然后剩下的都是查询模拟的redis缓存里面的数据
查询数据库
查询数据库
查询数据库
查询数据库
查询数据库
查询数据库
查询数据库
查询数据库
查询数据库
查询数据库
查询数据库
查询数据库
查询数据库
查询缓存
查询缓存
查询缓存
查询缓存
查询缓存
查询缓存
查询缓存
查询缓存
查询缓存
查询缓存
然后我们使用双重检测锁来解决上面的缓存穿透
我们怎么解决缓存穿透呢，即使10000个并发过来，然后这10000个并发需要的数据在redis里面都没有，那么我们应该第一个线程查询数据里面的数据，然后把这个数据给放到redis里面，然后剩下的9999个线程都到redis里面查询，这样就解决了缓存穿透，所以我们可以把上面的代码变成下面这样
比如下面的代码
在这里插入图片描述
Pom.xml代码
<?xml version="1.0" encoding="UTF-8"?>
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd"> <modelVersion>4.0.0</modelVersion> <groupId>com.example</groupId> <artifactId>springboot</artifactId> <version>0.0.1-SNAPSHOT</version> <packaging>jar</packaging> <name>springboot</name> <description>Demo project for Spring Boot</description> <parent> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-parent</artifactId> <version>2.1.1.RELEASE</version> <relativePath></relativePath> <!-- lookup parent from repository --> </parent> <properties> <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding> <project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding> <java.version>1.8</java.version> </properties> <dependencies> <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-web</artifactId> </dependency> <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-devtools</artifactId> </dependency> <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-test</artifactId> <scope>test</scope> </dependency> <dependency> <groupId>org.mybatis.spring.boot</groupId> <artifactId>mybatis-spring-boot-starter</artifactId> <version>1.1.1</version> </dependency> <dependency> <groupId>mysql</groupId> <artifactId>mysql-connector-java</artifactId> </dependency> </dependencies> <build> <plugins> <plugin> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-maven-plugin</artifactId> </plugin> </plugins> </build> Application.properties
server.port=8081
DB Configuration:
spring.datasource.driverClassName=com.mysql.jdbc.Driver
spring.datasource.url=jdbc:mysql://47.91.248.236:3306/hello?useUnicode=true&characterEncoding=utf8
spring.datasource.username=root
spring.datasource.password=root
spring集成Mybatis环境
pojo别名扫描包
mybatis.type-aliases-package=com.itheima.domain
加载Mybatis映射文件
mybatis.mapper-locations=classpath:mapper/*Mapper.xml
MyController代码，下面的蓝色代码是模仿10000个并发线程
/**
- sinture.com Inc.
- Copyright (c) 2016-2018 All Rights Reserved.
*/
package com.itheima.controller;
import com.itheima.mapper.UserMapper;
import com.itheima.domain.User;
import com.itheima.service.UserService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.PathVariable;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.ResponseBody;
import org.springframework.web.bind.annotation.RestController;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
/**
- @author xinzhu
- @version Id: MyController.java, v 0.1 2018年12月05日 下午6:29 xinzhu Exp $
*/
@RestController
public class MyController {
@Autowired private UserService userService; @RequestMapping("/hello/{id}") @ResponseBody public User queryUser(@PathVariable Integer id){ // 蓝色代码注释开始 new Thread(){ @Override public void run() { for (int x = 0; x < 10000; x++) { userService.queryUser(id); } } }.start(); // 蓝色代码注释结束 return userService.queryUser(id); }}
User类
/**
- sinture.com Inc.
- Copyright (c) 2016-2018 All Rights Reserved.
*/
package com.itheima.domain;
/**
- @author xinzhu
- @version Id: User.java, v 0.1 2018年12月06日 下午1:40 xinzhu Exp $
*/
public class User {
// 主键 private Integer id; // 用户名 private String username; // 密码 private String password; // 姓名 private String name; public void setId(Integer id) { this.id = id; } @Override public String toString() { return "User{" + "id=" + id + ", username='" + username + '\'' + ", password='" + password + '\'' + ", name='" + name + '\'' + '}'; } public Integer getId() { return id; } public String getUsername() { return username; } public void setUsername(String username) { this.username = username; } public String getPassword() { return password; } public void setPassword(String password) { this.password = password; } public String getName() { return name; } public void setName(String name) { this.name = name; }}
UserService
package com.itheima.service;
import com.itheima.domain.User;
public interface UserService {
public User queryUser(Integer id);}
UserServiceImpl，下面的蓝色代码就是模仿redis，此时要注意下面的模拟redis的map集合必须放到下面的queryUser的外面，也就是说下面的userMap变量必须是成员变量，不然的话，因为redis是被多个线程共享的，如果你放到下面的queryUser()方法里面，那么就是多个线程有多个userMap集合，下面的代码就是如果查询到数据，那么就用redis里面的，如果查询不到就用数据库里面的
然后下面的红色代码就是解决上面的缓存穿透问题，使用锁来解决缓存穿透问题，而且叫做双重检测锁，为什么叫做双重检测锁呢，因为有两个if语句，第一个if语句就是为了减少走红色代码里面的同步代码块，因为如果换成里面存在想要的数据，那么就不需要走下面的红色代码里面的同步代码块了，所以有两个if语句，至于为什么要有下面的 user= userMap.get(id);，是因为第一次线程查询把数据放到模仿的redis缓存里面之后，剩下的线程当走到下面的同步代码块的时候，需要在查询一下缓存里面的数据就会发现刚刚第一个线程放到redis里面的数据了，所以才会有下面的红色代码里面的 user= userMap.get(id);
package com.itheima.service;
import com.itheima.domain.User;
import com.itheima.mapper.UserMapper;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import java.util.HashMap;
import java.util.Map;
@Service
public class UserServiceImpl implements UserService {
@Autowired private UserMapper userMapper; // 蓝色代码注释开始 static Map<Integer,User> userMap=new HashMap(); static { User huancun_user =new User(); huancun_user.setId(1); huancun_user.setName("zhangsan"); huancun_user.setPassword("123"); huancun_user.setName("张三"); userMap.put(1,huancun_user); } // 蓝色代码注释结束 public User queryUser(Integer id){ User user=userMap.get(id); // 红色代码注释开始 if(user==null){ synchronized (this) { user= userMap.get(id); if (null == user) { user= userMapper.queryUser(id); System.out.println("查询数据库"); userMap.put(user.getId(),user); }else{ System.out.println("查询缓存"); } } }else{ System.out.println("查询缓存"); } //红色代码注释结束 return user; };}
数据库里面的数据如下
-- ----------------------------
-- Table structure for user
-- ----------------------------
DROP TABLE IF EXISTS user;
CREATE TABLE user (id int(11) NOT NULL AUTO_INCREMENT,username varchar(50) DEFAULT NULL,password varchar(50) DEFAULT NULL,name varchar(50) DEFAULT NULL,
PRIMARY KEY (id)
) ENGINE=InnoDB AUTO_INCREMENT=10 DEFAULT CHARSET=utf8;
-- ----------------------------
-- Records of user
-- ----------------------------
INSERT INTO user VALUES ('1', 'zhangsan', '123', '张三');
INSERT INTO user VALUES ('2', 'lisi', '123', '李四');
然后我们查询下面的链接，因为此时上面的模拟redis的map集合里面没有id值是2的数据，所以此时都是查询数据库，你想这一下子10000并发过去，数据库会有很大压力的，
在这里插入图片描述
然后打印结果如下，就是就只有第一个打印了查询数据库，然后剩下的都是查询缓存了，这就是解决缓存穿透
查询数据库
查询缓存
查询缓存
查询缓存
查询缓存
查询缓存
查询缓存
查询缓存
查询缓存
查询缓存
查询缓存
查询缓存
查询缓存
查询缓存
查询缓存
查询缓存
查询缓存
查询缓存
查询缓存
查询缓存
查询缓存
查询缓存
能看到这里的同学，就帮忙点个推荐吧，Thanks(･ω･)ﾉ
原文地址https://www.cnblogs.com/mqk100/p/11319758.html
关注公众号 低调大师中文资讯倾力打造互联网数据资讯、行业资源、电子商务、移动互联网、网络营销平台。
持续更新报道IT业界、互联网、市场资讯、驱动更新,是最及时权威的产业资讯及硬件资讯报道平台。
转载内容版权归作者及来源网站所有，本站原创内容转载请注明来源。
- 上一篇
![Spring cloud Feign不支持对象传参解决办法[完美解决]](https://res.xujun.org/img/article/from/aliyun.jpg)
Spring cloud Feign不支持对象传参解决办法[完美解决]
Spring cloud Feign不支持对象传参解决办法[完美解决] spring cloud 使用 Feign 进行服务调用时，不支持对象参数。 通常解决方法是，要么把对象每一个参数平行展开，并使用 @RequestParam 标识出每一个参数，要么用 @RequestBody 将请求改为 body 传参，虽然这样解决了问题，但是这样限制了传参方式，并且使代码变得很繁重。 以下为完美解决 Feign 对象传参问题的办法。 引入如下依赖（可以在maven仓库中搜索 strongfeign） 复制代码1 2 3 com.moonciki.strongfeign4 feign-httpclient5 10.2.36 复制代码该源码修改自 https://github.com/OpenFeign/feign，提交过pr，但是项目原作者并没有采纳，pr地址如下：https://github.com/OpenFeign/feign/pull/949 之后为了同步到了maven 仓库，做了相应删减及pom的变更，具体改动可参考github。地址：https://github.com/cdmama...
- 下一篇
Tomcat使用线程池配置高并发连接
Tomcat使用线程池配置高并发连接1：配置executor属性 打开/conf/server.xml文件，在Connector之前配置一个线程池： namePrefix="tomcatThreadPool-" maxThreads="1000" maxIdleTime="300000" minSpareThreads="200"/> 重要参数说明：name：共享线程池的名字。这是Connector为了共享线程池要引用的名字，该名字必须唯一。默认值：None；namePrefix：在JVM上，每个运行线程都可以有一个name 字符串。这一属性为线程池中每个线程的name字符串设置了一个前缀，Tomcat将把线程号追加到这一前缀的后面。默认值：tomcat-exec-；maxThreads：该线程池可以容纳的最大线程数。默认值：200；maxIdleTime：在Tomcat关闭一个空闲线程之前，允许空闲线程持续的时间(以毫秒为单位)。只有当前活跃的线程数大于minSpareThread的值，才会关闭空闲线程。默认值：60000(一分钟)。minSpareThreads：Tomcat...
相关文章
文章评论
共有0条评论来说两句吧...
文章二维码
点击排行
推荐阅读
最新文章
- CentOS7设置SWAP分区，小内存服务器的救世主
- Docker安装Oracle12C，快速搭建Oracle学习环境
- Docker快速安装Oracle11G，搭建oracle11g学习环境
- CentOS7编译安装Gcc9.2.0，解决mysql等软件编译问题
- SpringBoot2整合MyBatis，连接MySql数据库做增删改查操作
- CentOS8安装MyCat，轻松搞定数据库的读写分离、垂直分库、水平分库
- SpringBoot2整合Thymeleaf，官方推荐html解决方案
- Mario游戏-低调大师作品
- 2048小游戏-低调大师作品
- SpringBoot2初体验，简单认识spring boot2并且搭建基础工程
微信收款码
支付宝收款码