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

Spring?Cache+Redis緩存數(shù)據(jù)的實現(xiàn)示例

 更新時間:2022年01月05日 08:34:12   作者:別團等shy哥發(fā)育  
本文主要介紹了Spring?Cache+Redis緩存數(shù)據(jù),文中通過示例代碼介紹的非常詳細,具有一定的參考價值,感興趣的小伙伴們可以參考一下

1、為什么使用緩存

  我們知道內(nèi)存的讀取速度遠大于硬盤的讀取速度。當需要重復地獲取相同數(shù)據(jù)時,一次一次地請求數(shù)據(jù)庫或者遠程服務,導致在數(shù)據(jù)庫查詢或遠程方法調(diào)用上消耗大量的時間,最終導致程序性能降低,這就是數(shù)據(jù)緩存要解決的問題。

  Spring Cache 是一個非常優(yōu)秀的緩存組件。自Spring 3.1起,提供了類似于@Transactional注解事務的注解Cache支持,且提供了Cache抽象,方便切換各種底層Cache(如:redis)

  使用Spring Cache的好處

1,提供基本的Cache抽象,方便切換各種底層Cache;

2,通過注解Cache可以實現(xiàn)類似于事務一樣,緩存邏輯透明的應用到我們的業(yè)務代碼上,且只需要更少的代碼就可以完成;

3,提供事務回滾時也自動回滾緩存;

4,支持比較復雜的緩存邏輯;

  一旦配置好Spring緩存支持,就可以在Spring容器里管理的Bean中使用緩存注解(基于AOP原理),一般情況下,都是在業(yè)務層(Service類)使用這些注解。

2、常用的緩存注解

2.1 @Cacheable

  @Cacheable可以標記在一個方法上,也可以標記在一個類上。當標記在一個方法上時表示該方法是支持緩存的;當標記在一個類上時則表示該類所有的方法都是支持緩存的。對于一個支持緩存的方法,在方法執(zhí)行前,Spring先檢查緩存中是否存在該方法返回的數(shù)據(jù),如果存在,則直接返回緩存數(shù)據(jù);如果不存在,則調(diào)用方法并將方法返回值寫入緩存

  @Cacheable注解經(jīng)常使用value、key、condition等屬性

value:緩存的名稱,指定一個或多個緩存名稱。如

@Cacheable(value="mycache")或者@Cacheable(value={<!--{cke_protected}{C}%3C!%2D%2D%20%2D%2D%3E-->"cache1","cache2"})

該屬性與cacheNames屬性意義相同

key:緩存的key,可以為空。如果指定。需要按照SpEL編寫;如果不指定,則默認按照方法的所有參數(shù)進行組合。如

@Cacheable(value="testcache",key="#student.id")

condition:緩存的條件,可以為空,如果指定,需要按照SpEL編寫,返回true或者false,只有為true才進行緩存。如

@Cacheable(value="testcache",condition="#student.id>2")

該屬性與unless相反,條件成立時,不進行緩存

2.2 @CacheEvict

一般用在更新或者刪除方法上

  @CacheEvict是用來標注在需要清除 緩存元素的方法或類上的。當標記在一個類上時,表示其中所有方法的執(zhí)行都會觸發(fā)緩存的清除操作。@CacheEvict可以指定的屬性有value、key、conditon、allEntries和beforeInvocation。其中,value、key和condition的語義與@Cacheable對應的屬性類似。

allEntries:是否清空所有緩存內(nèi)容,默認為false,如果指定為true,則方法調(diào)用后將立即清空所有緩存。如

@CacheEvict(value="testcache",allEntries=true)

beforeInvocation:是否在方法執(zhí)行前就清空,默認為false,如果指定為true,則在方法還沒有執(zhí)行時就清空緩存。默認情況下,如果方法執(zhí)行拋出異常,則不會清空緩存。

2.3、@Cacheput

  使用該注解標志的方法,每次都會執(zhí)行,并將結(jié)果存入指定的緩存中。其他方法可以直接從響應的緩存中讀取緩存數(shù)據(jù),而不需要再去查詢數(shù)據(jù)庫。一般用在新增方法上。

2.4、@Caching

  該注解可以在一個方法或類上同時指定多個Spring Cache相關(guān)的注解。其擁有三個屬性:cacheable、put和evict,分別用于指定@Cacheable、@CachePut和@CacheEvict。示例代碼如下:

@Caching(
cacheable=@Cacheable("cache1"),
evict={@CacheEvict("cache2"),@CacheEvict(value="cache3",allEntries=true)}
)

2.5、@CacheConfig

  所有的Cache注解都需要提供Cache名稱,如果每個Service方法上都包含相同的Cache名稱,可能寫起來重復。此時可以使用@CacheConfig注解作用在類上,設(shè)置當前緩存的一些公共配置。

3、SpringBoot緩存支持

  在SpringBoot應用中,使用緩存技術(shù)只需在應用中引入相關(guān)緩存技術(shù)的依賴,并在配置類中使用@EnableCaching注解開啟緩存支持即可。

4、項目繼承Spring Cache+Redis

4.1 添加依賴

         <!-- redis -->
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-data-redis</artifactId>
        </dependency>

        <!-- spring2.X集成redis所需common-pool2-->
        <dependency>
            <groupId>org.apache.commons</groupId>
            <artifactId>commons-pool2</artifactId>
            <version>2.6.0</version>
        </dependency>

4.2 配置類

/**
 * Redis+Cache配置類
 */
@Configuration
@EnableCaching
public class RedisConfig {
    /**
     * 自定義key規(guī)則
     * @return
     */
    @Bean
    public KeyGenerator keyGenerator() {
        return new KeyGenerator() {
            @Override
            public Object generate(Object target, Method method, Object... params) {
                StringBuilder sb = new StringBuilder();
                sb.append(target.getClass().getName());
                sb.append(method.getName());
                for (Object obj : params) {
                    sb.append(obj.toString());
                }
                return sb.toString();
            }
        };
    }

    /**
     * 設(shè)置RedisTemplate規(guī)則
     * @param redisConnectionFactory
     * @return
     */
    @Bean
    public RedisTemplate<Object, Object> redisTemplate(RedisConnectionFactory redisConnectionFactory) {
        RedisTemplate<Object, Object> redisTemplate = new RedisTemplate<>();
        redisTemplate.setConnectionFactory(redisConnectionFactory);
        Jackson2JsonRedisSerializer jackson2JsonRedisSerializer = new Jackson2JsonRedisSerializer(Object.class);

        //解決查詢緩存轉(zhuǎn)換異常的問題
        ObjectMapper om = new ObjectMapper();
        // 指定要序列化的域,field,get和set,以及修飾符范圍,ANY是都有包括private和public
        om.setVisibility(PropertyAccessor.ALL, JsonAutoDetect.Visibility.ANY);
        // 指定序列化輸入的類型,類必須是非final修飾的,final修飾的類,比如String,Integer等會跑出異常
        om.enableDefaultTyping(ObjectMapper.DefaultTyping.NON_FINAL);
        jackson2JsonRedisSerializer.setObjectMapper(om);

        //序列號key value
        redisTemplate.setKeySerializer(new StringRedisSerializer());
        redisTemplate.setValueSerializer(jackson2JsonRedisSerializer);
        redisTemplate.setHashKeySerializer(new StringRedisSerializer());
        redisTemplate.setHashValueSerializer(jackson2JsonRedisSerializer);

        redisTemplate.afterPropertiesSet();
        return redisTemplate;
    }

    /**
     * 設(shè)置CacheManager緩存規(guī)則
     * @param factory
     * @return
     */
    @Bean
    public CacheManager cacheManager(RedisConnectionFactory factory) {
        RedisSerializer<String> redisSerializer = new StringRedisSerializer();
        Jackson2JsonRedisSerializer jackson2JsonRedisSerializer = new Jackson2JsonRedisSerializer(Object.class);

        //解決查詢緩存轉(zhuǎn)換異常的問題
        ObjectMapper om = new ObjectMapper();
        om.setVisibility(PropertyAccessor.ALL, JsonAutoDetect.Visibility.ANY);
        om.enableDefaultTyping(ObjectMapper.DefaultTyping.NON_FINAL);
        jackson2JsonRedisSerializer.setObjectMapper(om);

        // 配置序列化(解決亂碼的問題),過期時間600秒
        RedisCacheConfiguration config = RedisCacheConfiguration.defaultCacheConfig()
                .entryTtl(Duration.ofSeconds(600))
                .serializeKeysWith(RedisSerializationContext.SerializationPair.fromSerializer(redisSerializer))
                .serializeValuesWith(RedisSerializationContext.SerializationPair.fromSerializer(jackson2JsonRedisSerializer))
                .disableCachingNullValues();

        RedisCacheManager cacheManager = RedisCacheManager.builder(factory)
                .cacheDefaults(config)
                .build();
        return cacheManager;
    }

}

4.3 添加redis配置

# redis配置
spring.redis.host=192.168.159.33
spring.redis.port=6379
spring.redis.database= 0
spring.redis.timeout=1800000

spring.redis.lettuce.pool.max-active=20
spring.redis.lettuce.pool.max-wait=-1
#最大阻塞等待時間(負數(shù)表示沒限制)
spring.redis.lettuce.pool.max-idle=5
spring.redis.lettuce.pool.min-idle=0

4.4 接口中使用緩存注解

Service實現(xiàn)類中添加相應的注解

@Service
public class DictServiceImpl extends ServiceImpl<DictMapper, Dict> implements DictService {

    //根據(jù)上級id查詢子數(shù)據(jù)列表
    @Override
    @Cacheable(value = "dict",keyGenerator = "keyGenerator")
    public List<Dict> findChildData(Long id) {
        QueryWrapper<Dict> wrapper=new QueryWrapper<>();
        wrapper.eq("parent_id",id);
        List<Dict> list = baseMapper.selectList(wrapper);
        //向list集合中的每個dict對象中設(shè)置hasChildren
        list.forEach(x->{
            Long dictId = x.getId();
            boolean isChild = this.isChildren(dictId);
            x.setHasChildren(isChild);
        });
        return list;
    }

    //導出數(shù)據(jù)字典接口
    @Override
    public void exportDictData(HttpServletResponse response) {
        //設(shè)置下載信息
        response.setContentType("application/vnd.ms-excel");
        response.setCharacterEncoding("utf-8");
// 這里URLEncoder.encode可以防止中文亂碼 當然和easyexcel沒有關(guān)系
        String fileName = "dict";
        response.setHeader("Content-disposition", "attachment;filename="+ fileName + ".xlsx");

        //查詢數(shù)據(jù)庫
        List<Dict> dictList = baseMapper.selectList(null);
        //Dict-->DictEeVo
        List<DictEeVo> dictEeVoList=new ArrayList<>();
        dictList.forEach(x->{
            DictEeVo dictEeVo=new DictEeVo();
            BeanUtils.copyProperties(x,dictEeVo);
            dictEeVoList.add(dictEeVo);
        });

        try {
            //調(diào)用方法實現(xiàn)寫操作
            EasyExcel.write(response.getOutputStream(), DictEeVo.class)
                    .sheet("dict")
                    .doWrite(dictEeVoList);
        } catch (IOException e) {
            e.printStackTrace();
        }


    }

    //導入數(shù)據(jù)字典
    @Override
    @CacheEvict(value = "dict", allEntries=true)
    public void importDictData(MultipartFile file) {
        try {
            //excel數(shù)據(jù)取出來并添加到數(shù)據(jù)庫中
            EasyExcel.read(file.getInputStream(),DictEeVo.class,new DictListener(baseMapper))
            .sheet()
            .doRead();
        } catch (IOException e) {
            e.printStackTrace();
        }
    }

    //判斷id下面是否有子數(shù)據(jù)
    private boolean isChildren(Long id){
        QueryWrapper<Dict> wrapper=new QueryWrapper<>();
        wrapper.eq("parent_id",id);
        Integer count = baseMapper.selectCount(wrapper);
        return count > 0;
    }
}

4.5 緩存效果測試

我們現(xiàn)在調(diào)用根據(jù)上級id查詢子數(shù)據(jù)列表這個方法的controller

第一次訪問接口

image-20220103000552702

查看控制臺:

image-20220103000610546

查看redis中是否有緩存的數(shù)據(jù)

image-20220103000649837

用連接工具查看下redis中的數(shù)據(jù),方便數(shù)據(jù)的可視化

image-20220103000739705

從上面的數(shù)據(jù)不難發(fā)現(xiàn),數(shù)據(jù)已經(jīng)被緩存到了redis中

清空SpringBoot的控制臺,再次發(fā)起相同的請求,看是否會再次請求數(shù)據(jù)庫

第二次請求的控制臺輸出如下:

image-20220103000845343

頁面中的數(shù)據(jù)也正常獲取到了,如下:

image-20220103000904829

  從上面的效果可以很明顯的看到,我們第一次請求后端接口的時候,由于緩存中并沒有需要的數(shù)據(jù),所以會被緩存到redis中,第二次請求相同接口的時候,Spring先檢查緩存中是否存在該方法返回的數(shù)據(jù),如果存在,則直接返回緩存數(shù)據(jù),減小對數(shù)據(jù)庫查詢的壓力。上面的緩存一定要設(shè)置下TTL,這樣長期不用的數(shù)據(jù)就會自動失效

 到此這篇關(guān)于Spring Cache+Redis緩存數(shù)據(jù)的實現(xiàn)示例的文章就介紹到這了,更多相關(guān)Spring Cache Redis緩存 內(nèi)容請搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家!

相關(guān)文章

  • 使用RestTemplate調(diào)用https接口跳過證書驗證

    使用RestTemplate調(diào)用https接口跳過證書驗證

    這篇文章主要介紹了使用RestTemplate調(diào)用https接口跳過證書驗證,具有很好的參考價值,希望對大家有所幫助。如有錯誤或未考慮完全的地方,望不吝賜教
    2021-10-10
  • Java 注解的使用實例詳解

    Java 注解的使用實例詳解

    這篇文章主要介紹了Java 注解的使用實例詳解的相關(guān)資料,需要的朋友可以參考下
    2016-12-12
  • Struts和servlet不能共存問題解決方法

    Struts和servlet不能共存問題解決方法

    這篇文章主要介紹了Struts和servlet不能共存問題解決方法,共有三種方法,需要的朋友可以參考下。
    2017-09-09
  • Java Spring WEB應用實例化如何實現(xiàn)

    Java Spring WEB應用實例化如何實現(xiàn)

    這篇文章主要介紹了Java Spring WEB應用實例化如何實現(xiàn),文中通過示例代碼介紹的非常詳細,對大家的學習或者工作具有一定的參考學習價值,需要的朋友可以參考下
    2020-12-12
  • Fastjson反序列化隨機性失敗示例詳解

    Fastjson反序列化隨機性失敗示例詳解

    這篇文章主要為大家介紹了Fastjson反序列化隨機性失敗示例詳解,有需要的朋友可以借鑒參考下,希望能夠有所幫助,祝大家多多進步,早日升職加薪
    2022-08-08
  • Java實現(xiàn)自定義ArrayList類的示例代碼

    Java實現(xiàn)自定義ArrayList類的示例代碼

    這篇文章主要為大家簡單的介紹ArrayList一下里面的add方法、size方法、isEmpty方法,以及如何實現(xiàn)自定義ArrayList類,感興趣的可以了解一下
    2022-08-08
  • Java實現(xiàn)選擇排序

    Java實現(xiàn)選擇排序

    這篇文章主要介紹了Java實現(xiàn)選擇排序,把一列數(shù)組按從小到大或從大到小排序,文中示例代碼介紹的非常詳細,具有一定的參考價值,感興趣的小伙伴們可以參考一下
    2021-08-08
  • 一篇文章帶你了解Java泛型的super和extends

    一篇文章帶你了解Java泛型的super和extends

    這篇文章主要介紹了Java泛型extends及super區(qū)別實例解析,文中通過示例代碼介紹的非常詳細,對大家的學習或者工作具有一定的參考學習價值,需要的朋友可以參考下
    2021-08-08
  • idea安裝hsdis的方法

    idea安裝hsdis的方法

    這篇文章主要介紹了idea安裝hsdis,本文給大家介紹的非常詳細,對大家的學習或工作具有一定的參考借鑒價值,需要的朋友可以參考下
    2021-03-03
  • java實現(xiàn)發(fā)牌小程序

    java實現(xiàn)發(fā)牌小程序

    這篇文章主要為大家詳細介紹了java實現(xiàn)發(fā)牌小程序,文中示例代碼介紹的非常詳細,具有一定的參考價值,感興趣的小伙伴們可以參考一下
    2020-11-11

最新評論