欧美bbbwbbbw肥妇,免费乱码人妻系列日韩,一级黄片

Java模擬并解決緩存穿透問題

 更新時間：2019年08月08日 10:51:42   作者：mqk100  
這篇文章主要介紹了Java模擬并解決緩存穿透問題，本文給大家介紹的非常詳細，具有一定的參考借鑒價值 ,需要的朋友可以參考下

什么叫做緩存穿透

緩存穿透只會發(fā)生在高并發(fā)的時候，就是當有10000個并發(fā)進行查詢數(shù)據(jù)的時候，我們一般都會先去redis里面查詢進行數(shù)據(jù)，但是如果redis里面沒有這個數(shù)據(jù)的時候，那么這10000個并發(fā)里面就會有很大一部分并發(fā)會一下子都去mysql數(shù)據(jù)庫里面進行查詢了

解決緩存穿透

首先我模擬一下緩存穿透

比如下面的代碼

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代碼，下面的藍色代碼是模仿10000個并發(fā)線程
/**
 * 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集合，下面的代碼就是如果查詢到數(shù)據(jù)，那么就用redis里面的，如果查詢不到就用數(shù)據(jù)庫里面的

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("查詢數(shù)據(jù)庫");
   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);
 }
}

數(shù)據(jù)庫里面的數(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', '李四');

然后我們查詢下面的鏈接，因為此時上面的模擬redis的map集合里面沒有id值是2的數(shù)據(jù)，所以此時都是查詢數(shù)據(jù)庫，你想這一下子10000并發(fā)過去，數(shù)據(jù)庫會有很大壓力的，

然后打印結果如下，就是打印了很多查詢數(shù)據(jù)庫和查詢緩存，此時也就說明10000個并發(fā)里面有很多去查詢了數(shù)據(jù)庫，這個是要避免的，至于為什么有查詢緩存的打印，因為我們把查詢的數(shù)據(jù)給放到模擬的redis里面了啊，所以剛開始的一大部分線程都是查詢數(shù)據(jù)庫，然后剩下的都是查詢模擬的redis緩存里面的數(shù)據(jù)

查詢數(shù)據(jù)庫
查詢數(shù)據(jù)庫
查詢數(shù)據(jù)庫
查詢數(shù)據(jù)庫
查詢數(shù)據(jù)庫
查詢數(shù)據(jù)庫
查詢數(shù)據(jù)庫
查詢數(shù)據(jù)庫
查詢數(shù)據(jù)庫
查詢數(shù)據(jù)庫
查詢數(shù)據(jù)庫
查詢數(shù)據(jù)庫
查詢數(shù)據(jù)庫
查詢緩存
查詢緩存
查詢緩存
查詢緩存
查詢緩存
查詢緩存
查詢緩存
查詢緩存
查詢緩存
查詢緩存

然后我們使用雙重檢測鎖來解決上面的緩存穿透

我們怎么解決緩存穿透呢，即使10000個并發(fā)過來，然后這10000個并發(fā)需要的數(shù)據(jù)在redis里面都沒有，那么我們應該第一個線程查詢數(shù)據(jù)里面的數(shù)據(jù)，然后把這個數(shù)據(jù)給放到redis里面，然后剩下的9999個線程都到redis里面查詢，這樣就解決了緩存穿透，所以我們可以把上面的代碼變成下面這樣

比如下面的代碼

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代碼，下面的藍色代碼是模仿10000個并發(fā)線程

/**
 * 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集合，下面的代碼就是如果查詢到數(shù)據(jù)，那么就用redis里面的，如果查詢不到就用數(shù)據(jù)庫里面的

然后下面的紅色代碼就是解決上面的緩存穿透問題，使用鎖來解決緩存穿透問題，而且叫做雙重檢測鎖，為什么叫做雙重檢測鎖呢，因為有兩個if語句，第一個if語句就是為了減少走紅色代碼里面的同步代碼塊，因為如果換成里面存在想要的數(shù)據(jù)，那么就不需要走下面的紅色代碼里面的同步代碼塊了，所以有兩個if語句，至于為什么要有下面的 user= userMap.get(id);，是因為第一次線程查詢把數(shù)據(jù)放到模仿的redis緩存里面之后，剩下的線程當走到下面的同步代碼塊的時候，需要在查詢一下緩存里面的數(shù)據(jù)就會發(fā)現(xiàn)剛剛第一個線程放到redis里面的數(shù)據(jù)了，所以才會有下面的紅色代碼里面的 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("查詢數(shù)據(jù)庫");
     userMap.put(user.getId(),user);
    }else{
     System.out.println("查詢緩存");
    }
   }
  }else{
   System.out.println("查詢緩存");
  }
  //紅色代碼注釋結束
  return user;
 };
}

數(shù)據(jù)庫里面的數(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', '李四');

然后我們查詢下面的鏈接，因為此時上面的模擬redis的map集合里面沒有id值是2的數(shù)據(jù)，所以此時都是查詢數(shù)據(jù)庫，你想這一下子10000并發(fā)過去，數(shù)據(jù)庫會有很大壓力的，

 

然后打印結果如下，就是就只有第一個打印了查詢數(shù)據(jù)庫，然后剩下的都是查詢緩存了，這就是解決緩存穿透

查詢數(shù)據(jù)庫
查詢緩存
查詢緩存
查詢緩存
查詢緩存
查詢緩存
查詢緩存
查詢緩存
查詢緩存
查詢緩存
查詢緩存
查詢緩存
查詢緩存
查詢緩存
查詢緩存
查詢緩存
查詢緩存
查詢緩存
查詢緩存
查詢緩存
查詢緩存
查詢緩存

總結

以上所述是小編給大家介紹的Java模擬并解決緩存穿透問題,希望對大家有所幫助，如果大家有任何疑問請給我留言，小編會及時回復大家的。在此也非常感謝大家對腳本之家網(wǎng)站的支持！
如果你覺得本文對你有幫助，歡迎轉載，煩請注明出處，謝謝！

相關文章

  • Intellij?IDEA根據(jù)maven依賴名查找它是哪個pom.xml引入的(圖文詳解)

    Intellij?IDEA根據(jù)maven依賴名查找它是哪個pom.xml引入的(圖文詳解)

    這篇文章主要介紹了Intellij?IDEA根據(jù)maven依賴名查找它是哪個pom.xml引入的,本文通過圖文并茂的形式給大家介紹的非常詳細，對大家的學習或工作具有一定的參考借鑒價值，需要的朋友可以參考下
    2022-08-08
  • mybatis如何獲取剛剛新插入數(shù)據(jù)的主鍵值id

    mybatis如何獲取剛剛新插入數(shù)據(jù)的主鍵值id

    這篇文章主要介紹了mybatis如何獲取剛剛新插入數(shù)據(jù)的主鍵值id問題,具有很好的參考價值,希望對大家有所幫助,如有錯誤或未考慮完全的地方,望不吝賜教
    2023-08-08
  • logback高效狀態(tài)管理器StatusManager源碼解析

    logback高效狀態(tài)管理器StatusManager源碼解析

    這篇文章主要為大家介紹了logback高效狀態(tài)管理器StatusManager源碼解析,有需要的朋友可以借鑒參考下,希望能夠有所幫助,祝大家多多進步,早日升職加薪
    2023-11-11
  • Java中的代理原理及代理使用示例

    Java中的代理原理及代理使用示例

    這篇文章主要介紹了Java中的代理原理及代理使用示例,本文講解了Java Socket編程中加入代理的2種方法,需要的朋友可以參考下
    2015-03-03
  • 類似Object監(jiān)視器方法的Condition接口(詳解)

    類似Object監(jiān)視器方法的Condition接口(詳解)

    下面小編就為大家?guī)硪黄愃芆bject監(jiān)視器方法的Condition接口(詳解)。小編覺得挺不錯的，現(xiàn)在就分享給大家，也給大家做個參考。一起跟隨小編過來看看吧
    2017-05-05
  • 全面剖析java中的注解（Annotation）

    全面剖析java中的注解（Annotation）

    一個詞就可以描述注解，那就是元數(shù)據(jù)，即一種描述數(shù)據(jù)的數(shù)據(jù)。所以，可以說注解就是源代碼的元數(shù)據(jù)。文中通過示例代碼介紹的非常詳細，對大家的學習或者工作具有一定的參考學習價值，需要的朋友們下面隨著小編來一起學習學習吧
    2019-04-04
  • Spring Security基于JWT登錄認證的項目實踐

    Spring Security基于JWT登錄認證的項目實踐

    JWT被用來在身份提供者和服務提供者間傳遞被認證的用戶身份信息，本文主要介紹了Spring Security基于JWT登錄認證的項目實踐，文中通過示例代碼介紹的非常詳細，需要的朋友們下面隨著小編來一起學習學習吧
    2023-07-07
  • Java編程之如何通過JSP實現(xiàn)頭像自定義上傳

    Java編程之如何通過JSP實現(xiàn)頭像自定義上傳

    之前做這個頭像上傳功能還是花了好多時間的,今天我將我的代碼分享給大家,下面這篇文章主要給大家介紹了關于Java編程之如何通過JSP實現(xiàn)頭像自定義上傳的相關資料,文中通過示例代碼介紹的非常詳細,需要的朋友可以參考下
    2022-12-12
  • java開發(fā)RocketMQ消息中間件原理基礎詳解

    java開發(fā)RocketMQ消息中間件原理基礎詳解

    最近 RocketMQ 剛剛上生產(chǎn)環(huán)境，閑暇之時在這里做一些分享，主要目的是讓初學者能快速上手RocketMQ，有需要的朋友可以借鑒參考下，希望能夠有所幫助
    2021-11-11

最新評論