SpringBoot数据访问-------------数据缓存
Spring缓存支持
Spring开始定义了org.springframework.cache.Cache和org.springframework.cache.CacheManager接口来统一不同的缓存技术。Spring Cache的核心就是对某个方法进行缓存，其实质就是缓存该方法的返回结果，并把方法参数和结果用键值对的方式存放到缓存中，当再次调用该方法使用相应的参数时，就会直接从缓存里面取出指定的结果进行返回。所以在使用Cache的时候我们要保证我们缓存的方法对于相同的参数要有相同的返回结果。
自定义缓存
定义实体类
public class Account {private int id;private String name;public Account(String name) {this.name = name;}public int getId() {return id;}public void setId(int id) {this.id = id;}public String getName() {return name;}public void setName(String name) {this.name = name;}
}
定义一个缓存管理器
import com.google.common.collect.Maps;
import java.util.Map;
public class CacheContext<T> {private Map<String, T> cache = Maps.newConcurrentMap();public T get(String key){return cache.get(key);}public void addOrUpdateCache(String key,T value) {cache.put(key, value);}// 依据 key 来删除缓存中的一条记录public void evictCache(String key) {if(cache.containsKey(key)) {cache.remove(key);}}// 清空缓存中的全部记录public void evictCache() {cache.clear();}
}
定义服务类
import com.google.common.base.Optional;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.stereotype.Service;import javax.annotation.Resource;
@Service
public class AccountService1 {private final Logger logger = LoggerFactory.getLogger(AccountService1.class);@Resourceprivate CacheContext<Account> accountCacheContext;public Account getAccountByName(String accountName) {Account result = accountCacheContext.get(accountName);if (result != null) {logger.info("get from cache... {}", accountName);return result;}Optional<Account> accountOptional = getFromDB(accountName);if (!accountOptional.isPresent()) {throw new IllegalStateException(String.format("can not find account by account name : [%s]", accountName));}Account account = accountOptional.get();accountCacheContext.addOrUpdateCache(accountName, account);return account;}public void reload() {accountCacheContext.evictCache();}private Optional<Account> getFromDB(String accountName) {logger.info("real querying db... {}", accountName);//Todo query data from databasereturn Optional.fromNullable(new Account(accountName));}}Spring Cache
注解 描述
@Cacheable 在方法执行前Spring先查看缓存中是否有数据，如果有数据则直接返回缓存数据。反之调用方法并将方法返回值放入缓存填充。
@CachePut 无论缓存是否有数据，都会将方法的返回值放入缓存。
@CacheEvict 将一条或多条数据从缓存中删除。
@Caching 组合多个注解策略在一个方法上。
Spring Cache实例
package com.kingdee.service;import java.util.Optional;import org.springframework.cache.annotation.CacheEvict;
import org.springframework.cache.annotation.CachePut;
import org.springframework.cache.annotation.Cacheable;
import org.springframework.stereotype.Service;import com.kingdee.domains.Account;@Service
public class AccountService {@Cacheable(value="accountCache")public Account getAccountByName(String accountName) {System.out.println("real querying account... "+accountName);// 方法内部实现不考虑缓存逻辑，直接实现业务Account accountOptional = getFromDB(accountName);return accountOptional;}@CacheEvict(value="accountCache",key="#account.getName()")public void updateAccount(Account account) {updateDB(account);}@CachePut(value="accountCache",key="#account.getName()")public Account updateAccount2(Account account){account.setName("bcd");System.out.println("========="+account.getName());return account;}private void updateDB(Account account) {System.out.println("real update db..."+account.getName());}private Account getFromDB(String accountName) {System.out.println("real querying db... "+accountName);Account account = new Account(accountName);return account;}
}
Spring配置
<?xml version="1.0" encoding="UTF-8"?>
<beansxmlns="http://www.springframework.org/schema/beans"xmlns:context="http://www.springframework.org/schema/context"xmlns:p="http://www.springframework.org/schema/p"xmlns:util="http://www.springframework.org/schema/util"xmlns:mvc="http://www.springframework.org/schema/mvc"xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"xmlns:task="http://www.springframework.org/schema/task"xmlns:rabbit="http://www.springframework.org/schema/rabbit"xmlns:cache="http://www.springframework.org/schema/cache"xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-3.0.xsdhttp://www.springframework.org/schema/contexthttp://www.springframework.org/schema/context/spring-context-3.0.xsdhttp://www.springframework.org/schema/mvchttp://www.springframework.org/schema/mvc/spring-mvc-3.0.xsdhttp://www.springframework.org/schema/utilhttp://www.springframework.org/schema/util/spring-util-3.0.xsdhttp://www.springframework.org/schema/taskhttp://www.springframework.org/schema/task/spring-task-3.0.xsdhttp://www.springframework.org/schema/rabbithttp://www.springframework.org/schema/rabbit/spring-rabbit-1.0.xsdhttp://www.springframework.org/schema/cachehttp://www.springframework.org/schema/cache/spring-cache.xsd"><context:component-scan base-package="com.kingdee"></context:component-scan>
<context:annotation-config/>
<cache:annotation-driven/><bean id="cacheManager" class="org.springframework.cache.support.SimpleCacheManager"><property name="caches"><set><bean class="org.springframework.cache.concurrent.ConcurrentMapCacheFactoryBean"><property name="name" value="default"/></bean><bean class="org.springframework.cache.concurrent.ConcurrentMapCacheFactoryBean"><property name="name" value="accountCache"/></bean><bean class="org.springframework.cache.concurrent.ConcurrentMapCacheFactoryBean"><property name="name" value="myCache"/></bean></set></property></bean></beans>
测试
package com.kingdee;import org.springframework.context.support.ClassPathXmlApplicationContext;import com.kingdee.domains.Account;
import com.kingdee.domains.User;
import com.kingdee.service.AccountService;
import com.kingdee.service.UserService;public class CacheTest {public static void main(String[] args){ClassPathXmlApplicationContext context = new ClassPathXmlApplicationContext("application-beans.xml");AccountService accountService = context.getBean("accountService", AccountService.class);Account account = accountService.getAccountByName("abc");Account account2 = accountService.getAccountByName("abc");UserService userService = context.getBean("userService", UserService.class);User user = userService.findName("abc");System.out.println("==========="+user.getName());User user2 = userService.findName("abc");System.out.println("==========="+user2.getName());}
}
注解详解
缓存@Cacheable
@Cacheable注解会先查询是否已经有缓存，有会使用缓存，没有则会执行方法并缓存。
@Cacheable(value = "emp" ,key = "targetClass + methodName +#p0")public List<NewJob> queryAll(User uid) {return newJobDao.findAllByUid(uid);} 此处的value是必需的，它指定了你的缓存存放在哪块命名空间。
此处的key是使用的spEL表达式，参考上章。这里有一个小坑，如果你把methodName换成method运行会报错，观察它们的返回类型，原因在于methodName是String而methoh是Method。
源码分析
String[] cacheNames() default {}; //和value注解差不多，二选一
String keyGenerator() default ""; //key的生成器。key/keyGenerator二选一使用
String cacheManager() default ""; //指定缓存管理器
String cacheResolver() default ""; //或者指定获取解析器
String condition() default ""; //条件符合则缓存
String unless() default ""; //条件符合则不缓存
boolean sync() default false; //是否使用异步模式
配置@CacheConfig
当我们需要缓存的地方越来越多，你可以使用@CacheConfig(cacheNames = {"myCache"})注解来统一指定value的值，这时可省略value，如果你在你的方法依旧写上了value，那么依然以方法的value值为准。
@CacheConfig(cacheNames = {"myCache"})
public class BotRelationServiceImpl implements BotRelationService {@Override@Cacheable(key = "targetClass + methodName +#p0")//此处没写valuepublic List<BotRelation> findAllLimit(int num) {return botRelationRepository.findAllLimit(num);}.....
}
源码分析
String keyGenerator() default ""; //key的生成器。key/keyGenerator二选一使用
String cacheManager() default ""; //指定缓存管理器
String cacheResolver() default ""; //或者指定获取解析器更新@CachePut
@CachePut注解的作用 主要针对方法配置，能够根据方法的请求参数对其结果进行缓存，和 @Cacheable 不同的是，它每次都会触发真实方法的调用 。简单来说就是用户更新缓存数据。但需要注意的是该注解的value 和 key 必须与要更新的缓存相同，也就是与@Cacheable 相同。示例：
@CachePut(value = "emp", key = "targetClass + #p0")public NewJob updata(NewJob job) {NewJob newJob = newJobDao.findAllById(job.getId());newJob.updata(job);return job;}
源码分析
String[] cacheNames() default {}; //与value二选一
String keyGenerator() default ""; //key的生成器。key/keyGenerator二选一使用
String cacheManager() default ""; //指定缓存管理器
String cacheResolver() default ""; //或者指定获取解析器
String condition() default ""; //条件符合则缓存
String unless() default ""; //条件符合则不缓存清除@CacheEvict
@CachEvict 的作用 主要针对方法配置，能够根据一定的条件对缓存进行清空 。
@CacheEvict(value="emp",key="#id")public void delect(int id) {newJobDao.deleteAllById(id);}
源码分析
String[] cacheNames() default {}; //与value二选一
String keyGenerator() default ""; //key的生成器。key/keyGenerator二选一使用
String cacheManager() default ""; //指定缓存管理器
String cacheResolver() default ""; //或者指定获取解析器
String condition() default ""; //条件符合则清空
SpringBoot实例
在Springboot运行时开启缓存支持
package com.kingdee;import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.cache.annotation.EnableCaching;
import org.springframework.context.annotation.ImportResource;@SpringBootApplication
@EnableCaching
public class App {public static void main(String[] args){SpringApplication.run(App.class);}
}转载于:https://www.cnblogs.com/youzhongmin/p/10163863.html
SpringBoot数据访问-------------数据缓存相关推荐
- SpringBoot25-spingboot数据访问-数据缓存Cache
我们知道一个程序的瓶颈在于数据库,我们也知道内存的速度是大大快于硬盘的速度的.当我们需要重复地获取相同的数据的时候,我们一次又一次的请求数据库或者远程服务,导致大量的时间耗费在数据库查询或者远程方法调 ...
- SpringBoot数据访问Mybatis注解版，配置版，注解与配置一体版
SpringBoot数据访问Mybatis注解版,配置版,注解与配置一体版 注解版: 1.改druid 连接池,不改可以跳过这步 添加依赖 <dependency><groupId& ...
- SpringBoot：Mybatis + Druid 数据访问
SpringBoot:Mybatis + Druid 数据访问 文章目录 SpringBoot:Mybatis + Druid 数据访问 1.简介 2.JDBC 3.CRUD操作 4.自定义数据源 D ...
- 详细SpringBoot教程之数据访问
写在前面 鉴于有人留言说想要学习SpringBoot相关的知识,我这里打算写一个SpringBoot系列的相关博文,目标呢是想让看了这一系列博文的同学呢,能够对SpringBoot略窥门径,这一系列的 ...
- SpringBoot 之 数据访问
3.数据访问 3.1.SQL 3.1.1.数据源的自动配置-HikariDataSource ① 导入JDBC场景 <dependency><groupId>org.sprin ...
- SpringBoot+Redis完成数据缓存（内容丰富度一定超出你的想象）
SpringBoot+Redis完成数据缓存 去年今日此门中 人面桃花相映红 人面不知何处去 桃花依旧笑春风 感谢相遇!感谢自己,努力的样子很给力! 为了更多朋友看见,还是和大家说一声抱歉,限制为粉丝 ...
- SpringBoot 2 访问 Pivotal GemFire 数据
开篇词 该指南将引导你使用 Pivotal GemFire 的数据服务集来构建应用. 你将创建的应用 我们将使用功能强大的 Spring Data for Pivotal GemFire 库来存储和检 ...
- SpringBoot实战系列——数据访问=(Mybatis+Redis)
前言 在开发中我们通常会对数据库的数据进行操作,SpringBoot对关系性和非关系型数据库的访问操作都提供了非常好的整合支持.SpringData是spring提供的一个用于简化数据库访问.支持云服 ...
- SpringBoot数据访问配置
文章目录 一.简介 二.特性 三.主要模块 四.SpringBoot整合基本JDBC与数据源 SpringBoot整合JDBC SpringBoot整合Druid数据源 一.简介 对于数据访问层而言, ...
- springboot数据访问基本操作步骤
springboot数据访问基本操作步骤 步骤一:创建一个springboot项目 配置pom.xml依赖(此阶段我没有配置web场景启动器) <?xml version="1.0&q ...
最新文章
- 想让语音助手听懂方言，这个数据集或能帮你？
- C++算术运算符与算术表达式
- CPLEX在Linux上的安装与配置
- 在sql2005中加数据库时出现无法打开物理文件
- 熊仔科技Steamduino PIC18F46J50主控板 部分原理图
- 到华为去，到AI最前沿去～ 华为杭州研究所欢迎您！
- 相当郁闷的问题，TabHost选项卡标签图标始终不出现？
- 数据库的三种状态RESTRICT、QUIESCE和SUSPEND
- 如何搭建tftp服务器
- 我收藏的PDF电子书第一部分
- 【科普】中医药治疗重症肌无力的独特优势
- 一些最基本的健身知识分享
- java工程师找工作建议
- 单片机及接口课程设计报告-------基于音乐播放器
- File和MultipartFile互转
- c# 任务调度篇QuartZ（第四部分：配置添加任务文件使用）
- 栈的应用4——递归函数的非递归形式（主讲阿克曼函数的非递归形式）
- 身份证号码验证（c语言）
- 8.7 存储容量的计算
- BUUCTF PWN rip1 WP