Java模擬并解決緩存穿透問(wèn)題
什么叫做緩存穿透
緩存穿透只會(huì)發(fā)生在高并發(fā)的時(shí)候,就是當(dāng)有10000個(gè)并發(fā)進(jìn)行查詢(xún)數(shù)據(jù)的時(shí)候,我們一般都會(huì)先去redis里面查詢(xún)進(jìn)行數(shù)據(jù),但是如果redis里面沒(méi)有這個(gè)數(shù)據(jù)的時(shí)候,那么這10000個(gè)并發(fā)里面就會(huì)有很大一部分并發(fā)會(huì)一下子都去mysql數(shù)據(jù)庫(kù)里面進(jìn)行查詢(xún)了
解決緩存穿透
首先我模擬一下緩存穿透
比如下面的代碼

Pom.xml代碼
<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
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>
</project>
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環(huán)境
#pojo別名掃描包
mybatis.type-aliases-package=com.itheima.domain
#加載Mybatis映射文件
mybatis.mapper-locations=classpath:mapper/*Mapper.xml
MyController代碼,下面的藍(lán)色代碼是模仿10000個(gè)并發(fā)線(xiàn)程
/**
* 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){
// 藍(lán)色代碼注釋開(kāi)始
new Thread(){
@Override
public void run() {
for (int x = 0; x < 10000; x++) {
userService.queryUser(id);
}
}
}.start();
// 藍(lán)色代碼注釋結(jié)束
return userService.queryUser(id);
}
}
User類(lèi)
/**
* 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;
// 用戶(hù)名
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,下面的藍(lán)色代碼就是模仿redis,此時(shí)要注意下面的模擬redis的map集合必須放到下面的queryUser的外面,也就是說(shuō)下面的userMap變量必須是成員變量,不然的話(huà),因?yàn)閞edis是被多個(gè)線(xiàn)程共享的,如果你放到下面的queryUser()方法里面,那么就是多個(gè)線(xiàn)程有多個(gè)userMap集合,下面的代碼就是如果查詢(xún)到數(shù)據(jù),那么就用redis里面的,如果查詢(xún)不到就用數(shù)據(jù)庫(kù)里面的
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;
// 藍(lán)色代碼注釋開(kāi)始
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);
}
// 藍(lán)色代碼注釋結(jié)束
public User queryUser(Integer id){
User user=userMap.get(id);
if(user==null){
user= userMapper.queryUser(id);
System.out.println("查詢(xún)數(shù)據(jù)庫(kù)");
userMap.put(user.getId(),user);
}else{
System.out.println("查詢(xún)緩存");
}
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);
}
}
數(shù)據(jù)庫(kù)里面的數(shù)據(jù)如下
-- ----------------------------
-- 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', '李四');
然后我們查詢(xún)下面的鏈接,因?yàn)榇藭r(shí)上面的模擬redis的map集合里面沒(méi)有id值是2的數(shù)據(jù),所以此時(shí)都是查詢(xún)數(shù)據(jù)庫(kù),你想這一下子10000并發(fā)過(guò)去,數(shù)據(jù)庫(kù)會(huì)有很大壓力的,

然后打印結(jié)果如下,就是打印了很多查詢(xún)數(shù)據(jù)庫(kù)和查詢(xún)緩存,此時(shí)也就說(shuō)明10000個(gè)并發(fā)里面有很多去查詢(xún)了數(shù)據(jù)庫(kù),這個(gè)是要避免的,至于為什么有查詢(xún)緩存的打印,因?yàn)槲覀儼巡樵?xún)的數(shù)據(jù)給放到模擬的redis里面了啊,所以剛開(kāi)始的一大部分線(xiàn)程都是查詢(xún)數(shù)據(jù)庫(kù),然后剩下的都是查詢(xún)模擬的redis緩存里面的數(shù)據(jù)
查詢(xún)數(shù)據(jù)庫(kù)
查詢(xún)數(shù)據(jù)庫(kù)
查詢(xún)數(shù)據(jù)庫(kù)
查詢(xún)數(shù)據(jù)庫(kù)
查詢(xún)數(shù)據(jù)庫(kù)
查詢(xún)數(shù)據(jù)庫(kù)
查詢(xún)數(shù)據(jù)庫(kù)
查詢(xún)數(shù)據(jù)庫(kù)
查詢(xún)數(shù)據(jù)庫(kù)
查詢(xún)數(shù)據(jù)庫(kù)
查詢(xún)數(shù)據(jù)庫(kù)
查詢(xún)數(shù)據(jù)庫(kù)
查詢(xún)數(shù)據(jù)庫(kù)
查詢(xún)緩存
查詢(xún)緩存
查詢(xún)緩存
查詢(xún)緩存
查詢(xún)緩存
查詢(xún)緩存
查詢(xún)緩存
查詢(xún)緩存
查詢(xún)緩存
查詢(xún)緩存
然后我們使用雙重檢測(cè)鎖來(lái)解決上面的緩存穿透
我們?cè)趺唇鉀Q緩存穿透呢,即使10000個(gè)并發(fā)過(guò)來(lái),然后這10000個(gè)并發(fā)需要的數(shù)據(jù)在redis里面都沒(méi)有,那么我們應(yīng)該第一個(gè)線(xiàn)程查詢(xún)數(shù)據(jù)里面的數(shù)據(jù),然后把這個(gè)數(shù)據(jù)給放到redis里面,然后剩下的9999個(gè)線(xiàn)程都到redis里面查詢(xún),這樣就解決了緩存穿透,所以我們可以把上面的代碼變成下面這樣
比如下面的代碼

Pom.xml代碼
<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
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>
</project>
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環(huán)境
#pojo別名掃描包
mybatis.type-aliases-package=com.itheima.domain
#加載Mybatis映射文件
mybatis.mapper-locations=classpath:mapper/*Mapper.xml
MyController代碼,下面的藍(lán)色代碼是模仿10000個(gè)并發(fā)線(xiàn)程
/**
* 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){
// 藍(lán)色代碼注釋開(kāi)始
new Thread(){
@Override
public void run() {
for (int x = 0; x < 10000; x++) {
userService.queryUser(id);
}
}
}.start();
// 藍(lán)色代碼注釋結(jié)束
return userService.queryUser(id);
}
}
User類(lèi)
/**
* 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;
// 用戶(hù)名
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,下面的藍(lán)色代碼就是模仿redis,此時(shí)要注意下面的模擬redis的map集合必須放到下面的queryUser的外面,也就是說(shuō)下面的userMap變量必須是成員變量,不然的話(huà),因?yàn)閞edis是被多個(gè)線(xiàn)程共享的,如果你放到下面的queryUser()方法里面,那么就是多個(gè)線(xiàn)程有多個(gè)userMap集合,下面的代碼就是如果查詢(xún)到數(shù)據(jù),那么就用redis里面的,如果查詢(xún)不到就用數(shù)據(jù)庫(kù)里面的
然后下面的紅色代碼就是解決上面的緩存穿透問(wèn)題,使用鎖來(lái)解決緩存穿透問(wèn)題,而且叫做雙重檢測(cè)鎖,為什么叫做雙重檢測(cè)鎖呢,因?yàn)橛袃蓚€(gè)if語(yǔ)句,第一個(gè)if語(yǔ)句就是為了減少走紅色代碼里面的同步代碼塊,因?yàn)槿绻麚Q成里面存在想要的數(shù)據(jù),那么就不需要走下面的紅色代碼里面的同步代碼塊了,所以有兩個(gè)if語(yǔ)句,至于為什么要有下面的 user= userMap.get(id);,是因?yàn)榈谝淮尉€(xiàn)程查詢(xún)把數(shù)據(jù)放到模仿的redis緩存里面之后,剩下的線(xiàn)程當(dāng)走到下面的同步代碼塊的時(shí)候,需要在查詢(xún)一下緩存里面的數(shù)據(jù)就會(huì)發(fā)現(xiàn)剛剛第一個(gè)線(xiàn)程放到redis里面的數(shù)據(jù)了,所以才會(huì)有下面的紅色代碼里面的 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;
// 藍(lán)色代碼注釋開(kāi)始
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);
}
// 藍(lán)色代碼注釋結(jié)束
public User queryUser(Integer id){
User user=userMap.get(id);
// 紅色代碼注釋開(kāi)始
if(user==null){
synchronized (this) {
user= userMap.get(id);
if (null == user) {
user= userMapper.queryUser(id);
System.out.println("查詢(xún)數(shù)據(jù)庫(kù)");
userMap.put(user.getId(),user);
}else{
System.out.println("查詢(xún)緩存");
}
}
}else{
System.out.println("查詢(xún)緩存");
}
//紅色代碼注釋結(jié)束
return user;
};
}
數(shù)據(jù)庫(kù)里面的數(shù)據(jù)如下
-- ----------------------------
-- 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', '李四');
然后我們查詢(xún)下面的鏈接,因?yàn)榇藭r(shí)上面的模擬redis的map集合里面沒(méi)有id值是2的數(shù)據(jù),所以此時(shí)都是查詢(xún)數(shù)據(jù)庫(kù),你想這一下子10000并發(fā)過(guò)去,數(shù)據(jù)庫(kù)會(huì)有很大壓力的,

然后打印結(jié)果如下,就是就只有第一個(gè)打印了查詢(xún)數(shù)據(jù)庫(kù),然后剩下的都是查詢(xún)緩存了,這就是解決緩存穿透
查詢(xún)數(shù)據(jù)庫(kù)
查詢(xún)緩存
查詢(xún)緩存
查詢(xún)緩存
查詢(xún)緩存
查詢(xún)緩存
查詢(xún)緩存
查詢(xún)緩存
查詢(xún)緩存
查詢(xún)緩存
查詢(xún)緩存
查詢(xún)緩存
查詢(xún)緩存
查詢(xún)緩存
查詢(xún)緩存
查詢(xún)緩存
查詢(xún)緩存
查詢(xún)緩存
查詢(xún)緩存
查詢(xún)緩存
查詢(xún)緩存
查詢(xún)緩存
總結(jié)
以上所述是小編給大家介紹的Java模擬并解決緩存穿透問(wèn)題,希望對(duì)大家有所幫助,如果大家有任何疑問(wèn)請(qǐng)給我留言,小編會(huì)及時(shí)回復(fù)大家的。在此也非常感謝大家對(duì)腳本之家網(wǎng)站的支持!
如果你覺(jué)得本文對(duì)你有幫助,歡迎轉(zhuǎn)載,煩請(qǐng)注明出處,謝謝!
相關(guān)文章
Spring Boot優(yōu)化后啟動(dòng)速度快到飛起技巧示例
這篇文章主要為大家介紹了Spring Boot優(yōu)化后啟動(dòng)速度快到飛起的技巧示例詳解,有需要的朋友可以借鑒參考下,希望能夠有所幫助,祝大家多多進(jìn)步,早日升職加薪2022-07-07
SpringBoot中的@RequestMapping注解的用法示例
@RequestMapping注解是SpringBoot中最常用的注解之一,它可以幫助開(kāi)發(fā)者定義和處理HTTP請(qǐng)求,本篇文章我們將詳細(xì)為大家介紹如何使用SpringBoot中的@RequestMapping注解,感興趣的同學(xué)跟著小編一起來(lái)學(xué)習(xí)吧2023-06-06
分享Java多線(xiàn)程實(shí)現(xiàn)的四種方式
這篇文章主要介紹了分享Java多線(xiàn)程實(shí)現(xiàn)的四種方式,文章基于?Java的相關(guān)資料展開(kāi)多線(xiàn)程的詳細(xì)介紹,具有一的的參考價(jià)值,需要的小伙伴可以參考一下2022-05-05
Springboot啟動(dòng)執(zhí)行特定代碼的方式匯總
這篇文章主要介紹了Springboot啟動(dòng)執(zhí)行特定代碼的幾種方式,本文通過(guò)實(shí)例代碼給大家介紹的非常詳細(xì),對(duì)大家的學(xué)習(xí)或工作具有一定的參考借鑒價(jià)值,需要的朋友可以參考下2021-12-12
SpringBoot應(yīng)用jar包啟動(dòng)原理詳解
本文主要介紹了SpringBoot應(yīng)用jar包啟動(dòng)原理詳解,文中通過(guò)示例代碼介紹的非常詳細(xì),對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值,需要的朋友們下面隨著小編來(lái)一起學(xué)習(xí)學(xué)習(xí)吧2022-03-03
解決JPA?save()方法null值覆蓋掉mysql預(yù)設(shè)的默認(rèn)值問(wèn)題
這篇文章主要介紹了解決JPA?save()方法null值覆蓋掉mysql預(yù)設(shè)的默認(rèn)值問(wèn)題,具有很好的參考價(jià)值,希望對(duì)大家有所幫助。如有錯(cuò)誤或未考慮完全的地方,望不吝賜教2021-11-11
Spring Bean生命周期之Bean元信息的配置與解析階段詳解
這篇文章主要為大家詳細(xì)介紹了Spring Bean生命周期之Bean元信息的配置與解析階段,文中示例代碼介紹的非常詳細(xì),具有一定的參考價(jià)值,感興趣的小伙伴們可以參考一下,希望能夠給你帶來(lái)幫助2022-03-03

