Berbagi teknologi

cache - cache menggunakan 2

2024-07-12

한어Русский языкEnglishFrançaisIndonesianSanskrit日本語DeutschPortuguêsΕλληνικάespañolItalianoSuomalainenLatina

1. Kerusakan cache, penetrasi, longsoran salju

1. Penetrasi cache

Mengacu pada menanyakan data yang tidak boleh ada. Karena cache tidak terkena, database akan ditanyakan, tetapi database tidak memiliki catatan seperti itu. Kami tidak menulis nilai nol dari kueri ini ke dalam cache, yang akan menghasilkan dalam setiap permintaan untuk data yang tidak ada ini. Anda harus pergi ke lapisan penyimpanan untuk melakukan kueri, yang kehilangan arti caching.

mempertaruhkan:

Menggunakan data yang tidak ada untuk melakukan serangan akan meningkatkan tekanan seketika pada database dan pada akhirnya menyebabkan keruntuhan.

menyelesaikan:

Hasil null di-cache dan waktu kedaluwarsa singkat ditambahkan.

2. Longsoran cache

Longsoran cache: Longsoran cache berarti ketika kita mengatur cache, Kunci mengadopsi waktu kedaluwarsa yang sama, menyebabkan cache menjadi tidak valid pada saat tertentu, semua permintaan diteruskan ke DB, dan DB berada di bawah tekanan dan longsoran seketika.

Solusi: Tambahkan nilai acak ke waktu kedaluwarsa asli, misalnya 1-5 menit secara acak, sehingga tingkat pengulangan setiap waktu kedaluwarsa yang di-cache akan berkurang, sehingga sulit menyebabkan peristiwa kegagalan kolektif.

3. Kerusakan cache

Perincian cache:

  • Untuk beberapa kunci dengan waktu kedaluwarsa yang ditetapkan, jika kunci ini dapat diakses secara bersamaan pada titik waktu tertentu, ini adalah data yang sangat "panas".
  • Jika kunci hotspot ini kedaluwarsa tepat sebelum sejumlah besar permintaan masuk pada saat yang sama, maka semua permintaan data untuk kunci ini akan jatuh ke db, yang disebut kerusakan cache.

menyelesaikan:

Kunci

Konkurensi dalam jumlah besar memungkinkan hanya satu untuk memeriksa, dan yang lain menunggu. Setelah memeriksa, kunci dilepaskan, dan yang lain memperoleh kunci, arahkan kursor, periksa cache terlebih dahulu, dan akan ada data tanpa masuk ke db.

2. Selesaikan masalahnya

Selesaikan penetrasi cache dan longsoran salju terlebih dahulu

  1.   private static final String CATALOG_JSON="CATALOG_JSON";
  2.     @Override
  3.     public Map<String, List<Catelog2Vo>> getCatalogJson() {
  4.  
  5.         /**
  6.          * 空结果缓存:解决缓存穿透
  7.          * 设置过期时间(加随机值) 缓存雪崩
  8.          * 加锁 解决缓存击穿
  9.          */
  10.         Object result = redisTemplate.opsForValue().get(CATALOG_JSON);
  11.         if(result!=null){
  12.             return (Map<String, List<Catelog2Vo>>) result;
  13.         }
  14.  
  15.         Map<String, List<Catelog2Vo>> map = getCatalogJsonFromDB();
  16.         if (map==null){
  17.             /**
  18.              * 解决缓存穿透
  19.              */
  20.             map=new HashMap<>();
  21.         }
  22.         redisTemplate.opsForValue().set(CATALOG_JSON,map, Duration.ofDays(1));
  23.         return map;
  24.     }

Selesaikan kerusakan cache

1. Gunakan kunci lokal untuk menyelesaikannya

Objek kontainer springboot berada dalam mode tunggal secara default, sehingga objek yang sama dapat disinkronkan dan dikunci. Saat menggunakan mode deteksi ganda, objek tersebut dapat dijalankan secara bersamaan.

  1.  public synchronized Map<String, List<Catelog2Vo>> getCatalogJsonFromDB() {
  2.  
  3.         Object result = redisTemplate.opsForValue().get(CATALOG_JSON);
  4.         if (result != null) {
  5.             return (Map<String, List<Catelog2Vo>>) result;
  6.         }
  7.  
  8.  
  9.         //1.查出所有1级分类
  10.         List<CategoryEntity> selectList = baseMapper.selectList(null);
  11.         /**
  12.          * 将数据库的多次查询变成一次
  13.          */
  14.  
  15.         //2. 封装数据
  16.         List<CategoryEntity> level1Category = selectList.stream().filter(s -> s.getParentCid().equals(0L)).collect(Collectors.toList());
  17.         Map<String, List<Catelog2Vo>> map = level1Category.stream().collect(Collectors.toMap(k -> k.getCatId().toString(), v -> {
  18.             //1.每一个的一级分类,查到1级分类的所有二级分类
  19.             List<CategoryEntity> categoryEntities = selectList.stream().filter(s -> s.getParentCid().equals(v.getCatId())).collect(Collectors.toList());
  20.  
  21.             List<Catelog2Vo> catelog2VoList = categoryEntities.stream().map(c -> {
  22.                 Catelog2Vo catelog2Vo = new Catelog2Vo();
  23.                 catelog2Vo.setId(c.getCatId().toString());
  24.                 catelog2Vo.setName(c.getName());
  25.                 catelog2Vo.setCatalog1Id(v.getCatId().toString());
  26.  
  27.                 List<CategoryEntity> categoryEntities1 = selectList.stream().filter(s -> s.getParentCid().equals(c.getCatId())).collect(Collectors.toList());
  28.                 List<Catelog2Vo.Catelog3Vo> collect = categoryEntities1.stream().map(c3 -> {
  29.                     Catelog2Vo.Catelog3Vo catelog3Vo = new Catelog2Vo.Catelog3Vo();
  30.                     catelog3Vo.setId(c3.getCatId().toString());
  31.                     catelog3Vo.setName(c3.getName());
  32.                     catelog3Vo.setCatalog2Id(c.getCatId().toString());
  33.                     return catelog3Vo;
  34.                 }).collect(Collectors.toList());
  35.  
  36.                 catelog2Vo.setCatalog3List(collect);
  37.  
  38.                 return catelog2Vo;
  39.             }).collect(Collectors.toList());
  40.  
  41.  
  42.             return catelog2VoList;
  43.         }));
  44.         return map;
  45.     }
  1.  public Map<String, List<Catelog2Vo>> getCatalogJson() {
  2.  
  3.         /**
  4.          * 空结果缓存:解决缓存穿透
  5.          * 设置过期时间(加随机值) 缓存雪崩
  6.          * 加锁 解决缓存击穿
  7.          */
  8.         Object result = redisTemplate.opsForValue().get(CATALOG_JSON);
  9.         if (result != null) {
  10.             return (Map<String, List<Catelog2Vo>>) result;
  11.         }
  12.  
  13.         Map<String, List<Catelog2Vo>> map = getCatalogJsonFromDB();
  14.         if (map == null) {
  15.             /**
  16.              * 解决缓存穿透
  17.              */
  18.             map = new HashMap<>();
  19.         }
  20.         redisTemplate.opsForValue().set(CATALOG_JSON, map, Duration.ofDays(1));
  21.         return map;
  22.     }

Masih akan ada masalah dengan logika kode di atas. Ketika dijalankan secara bersamaan, itu akan menyebabkan thread pertama selesai memeriksa database dan melepaskan kunci sebelum memasukkannya ke dalam cache dan tidak ada data, lalu periksa kembali databasenya. Tidak ada jaminan bahwa hanya akan ada satu Thread untuk memeriksa database

Pendekatan yang benar

  1.   public synchronized Map<String, List<Catelog2Vo>> getCatalogJsonFromDB() {
  2.  
  3.         Object result = redisTemplate.opsForValue().get(CATALOG_JSON);
  4.         if (result != null) {
  5.             return (Map<String, List<Catelog2Vo>>) result;
  6.         }
  7.  
  8.  
  9.         //1.查出所有1级分类
  10.         List<CategoryEntity> selectList = baseMapper.selectList(null);
  11.         /**
  12.          * 将数据库的多次查询变成一次
  13.          */
  14.  
  15.         //2. 封装数据
  16.         List<CategoryEntity> level1Category = selectList.stream().filter(s -> s.getParentCid().equals(0L)).collect(Collectors.toList());
  17.         Map<String, List<Catelog2Vo>> map = level1Category.stream().collect(Collectors.toMap(k -> k.getCatId().toString(), v -> {
  18.             //1.每一个的一级分类,查到1级分类的所有二级分类
  19.             List<CategoryEntity> categoryEntities = selectList.stream().filter(s -> s.getParentCid().equals(v.getCatId())).collect(Collectors.toList());
  20.  
  21.             List<Catelog2Vo> catelog2VoList = categoryEntities.stream().map(c -> {
  22.                 Catelog2Vo catelog2Vo = new Catelog2Vo();
  23.                 catelog2Vo.setId(c.getCatId().toString());
  24.                 catelog2Vo.setName(c.getName());
  25.                 catelog2Vo.setCatalog1Id(v.getCatId().toString());
  26.  
  27.                 List<CategoryEntity> categoryEntities1 = selectList.stream().filter(s -> s.getParentCid().equals(c.getCatId())).collect(Collectors.toList());
  28.                 List<Catelog2Vo.Catelog3Vo> collect = categoryEntities1.stream().map(c3 -> {
  29.                     Catelog2Vo.Catelog3Vo catelog3Vo = new Catelog2Vo.Catelog3Vo();
  30.                     catelog3Vo.setId(c3.getCatId().toString());
  31.                     catelog3Vo.setName(c3.getName());
  32.                     catelog3Vo.setCatalog2Id(c.getCatId().toString());
  33.                     return catelog3Vo;
  34.                 }).collect(Collectors.toList());
  35.  
  36.                 catelog2Vo.setCatalog3List(collect);
  37.  
  38.                 return catelog2Vo;
  39.             }).collect(Collectors.toList());
  40.  
  41.  
  42.             return catelog2VoList;
  43.         }));
  44.         if (map == null) {
  45.             /**
  46.              * 解决缓存穿透
  47.              */
  48.             map = new HashMap<>();
  49.         }
  50.         redisTemplate.opsForValue().set(CATALOG_JSON, map, Duration.ofDays(1));
  51.         return map;
  52.     }

Masukkan operasi penyimpanan ke dalam cache ke dalam blok kode sinkronisasi

  1.  @Override
  2.     public Map<String, List<Catelog2Vo>> getCatalogJson() {
  3.  
  4.         /**
  5.          * 空结果缓存:解决缓存穿透
  6.          * 设置过期时间(加随机值) 缓存雪崩
  7.          * 加锁 解决缓存击穿
  8.          */
  9.         Object result = redisTemplate.opsForValue().get(CATALOG_JSON);
  10.         if (result != null) {
  11.             return (Map<String, List<Catelog2Vo>>) result;
  12.         }
  13.  
  14.         Map<String, List<Catelog2Vo>> map = getCatalogJsonFromDB();
  15.  
  16.         return map;
  17.     }

 

 

Kunci lokal hanya dapat mengunci proses saat ini, jadi kita memerlukan kunci terdistribusi

3. Masalah dengan kunci lokal di lingkungan terdistribusi

Artinya, setiap kunci hanya dapat mengunci proses saat ini, yaitu setiap layanan akan memeriksa database.

Profil pribadi

Ia telah mengabdikan dirinya untuk meneliti teknologi selama lebih dari 30 tahun, dan mahir dalam berbagai bahasa seperti java, linux, javascript, php, css, dll. Ia telah memberikan banyak kontribusi di bidang open source stasiun dokumentasi pengembang untuk berbagi beberapa masalah dalam pengembangan teknologi untuk referensi di masa mendatang. Semua orang memeriksanya

informasi kontak saya

Surat