转载
定义数据访问接口:
[java]
- package org.kevin.cache.dao;
- import java.util.Collection;
- import org.kevin.cache.domain.Data;
- public interface DataDAO {
- public void add(Data data);
- public void update(Data data);
- public Data find(Integer id);
- public void delete(Integer id);
- public Collection<Data> getAll();
- }
[java]
- package org.kevin.cache.dao;
- import java.util.Collection;
- import java.util.HashMap;
- import java.util.Map;
- import org.kevin.cache.domain.Data;
- import org.springframework.cache.annotation.CacheEvict;
- import org.springframework.cache.annotation.Cacheable;
- public class DataDAOImpl implements DataDAO {
- private Map<Integer, Data> dataMap = new HashMap<>();
- @Override
- @CacheEvict(value = "data", allEntries = true)
- public void add(Data data) {
- System.out.println("Execute:public void add(Data data)");
- dataMap.put(data.getId(), data);
- }
- @Override
- @CacheEvict(value = "data", allEntries = true)
- public void update(Data data) {
- System.out.println("Execute:public void update(Data data) ");
- dataMap.put(data.getId(), data);
- }
- @Override
- @Cacheable(value = "data")
- public Data find(Integer id) {
- System.out.println("Execute:public Data find(Integer id)");
- return dataMap.get(id);
- }
- @Override
- @CacheEvict(value = "data", allEntries = true)
- public void delete(Integer id) {
- System.out.println("Execute:public void delete(Integer id)");
- dataMap.remove(id);
- }
- @Override
- @Cacheable(value = "data")
- public Collection<Data> getAll() {
- System.out.println("Execute:public Collection<Data> getAll()");
- return dataMap.values();
- }
- }
如上,对数据进行增删改的时候清空缓存,查询时使用缓存。其中value为缓存区,allEntries表示清空缓存区中的所有数据。为了稍后验证缓存是否生效,打印出执行的方法签名。
定义领域模型:
[java]
- package org.kevin.cache.domain;
- public class Data {
- private Integer id;
- private String first;
- private String second;
- public Data(Integer id, String first, String second) {
- this.id = id;
- this.first = first;
- this.second = second;
- }
- public String getFirst() {
- return first;
- }
- public void setFirst(String first) {
- this.first = first;
- }
- public String getSecond() {
- return second;
- }
- public void setSecond(String second) {
- this.second = second;
- }
- public void setId(Integer id) {
- this.id = id;
- }
- public Integer getId() {
- return id;
- }
- }
[html]
- <beans xmlns="http://www.springframework.org/schema/beans"
- xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:p="http://www.springframework.org/schema/p"
- 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.1.xsd
- http://www.springframework.org/schema/cache http://www.springframework.org/schema/cache/spring-cache-3.1.xsd">
- <cache:annotation-driven />
- <bean id="cacheManager" class="org.springframework.cache.support.SimpleCacheManager">
- <property name="caches">
- <set>
- <bean class="org.springframework.cache.concurrent.ConcurrentMapCacheFactoryBean" p:name="default" />
- <bean class="org.springframework.cache.concurrent.ConcurrentMapCacheFactoryBean" p:name="data" />
- </set>
- </property>
- </bean>
- <bean id="dataDao" class="org.kevin.cache.dao.DataDAOImpl" />
- </beans>
最后编写main方法验证缓存是否生效:
[java]
- package org.kevin.cache;
- import java.util.Collection;
- import org.kevin.cache.dao.DataDAO;
- import org.kevin.cache.domain.Data;
- import org.springframework.context.support.ClassPathXmlApplicationContext;
- public class CacheMain {
- public static void main(String[] args) {
- ClassPathXmlApplicationContext context = new ClassPathXmlApplicationContext("spring-cache-demo.xml");
- DataDAO dataDAO = context.getBean("dataDao", DataDAO.class);
- dataDAO.add(new Data(1, "li", "wenkai"));
- Collection<Data> dataCollection = dataDAO.getAll();
- System.out.println(dataCollection.size());
- System.out.println("=================================");
- dataDAO.add(new Data(2, "jack", "lee"));
- dataCollection = dataDAO.getAll();
- System.out.println(dataCollection.size());;
- Data data = dataDAO.find(1);
- System.out.println(data.getFirst());
- data = dataDAO.find(2);
- System.out.println(data.getFirst());
- data = dataDAO.find(2);
- System.out.println(data.getFirst());;
- System.out.println("====================================");
- dataDAO.add(new Data(3, "kevin", "lee"));
- data = dataDAO.find(2);
- System.out.println(data.getFirst());
- data = dataDAO.find(3);
- System.out.println(data.getFirst());
- data = dataDAO.find(2);
- System.out.println(data.getFirst());
- }
- }
[plain]
- Execute:public void add(Data data)
- Execute:public Collection<Data> getAll()
- 1
- =================================
- Execute:public void add(Data data)
- Execute:public Collection<Data> getAll()
- 2
- Execute:public Data find(Integer id)
- li
- Execute:public Data find(Integer id)
- jack
- jack
- ====================================
- Execute:public void add(Data data)
- Execute:public Data find(Integer id)
- jack
- Execute:public Data find(Integer id)
- kevin
- jack
最后,spring支持的缓存机制,是方法级的缓存,而不关注底层是否使用了数据库以及通过什么方式访问的数据库;因此这种缓存不止可以放到DAO层,也可以放置到Service层,甚至可以对各种代码数据进行缓存。
如果应用中同时使用了Hibernate和Ibatis,或者这种方式是一种好的缓存解决方案。