Spring Cache抽象-基於XML的配置宣告(基於ConcurrentMap的配置)
阿新 • • 發佈:2019-02-07
概述
如果不想使用註解或者由於其他原因無法獲得專案的原始碼等,Spring也支援使用XML的方式配置Spring Cache,主要是通過類似於aop:advice的cache:advice來進行的。
在cache名稱空間下定義了一個cache:advice元素用來定義一個對於Cache的advice。其需要指定一個cache-manager屬性,預設為cacheManager。
cache:advice下面可以指定多個cache:caching元素,其有點類似於使用註解時的@Caching註解。
cache:caching元素下又可以指定cache:cacheable、cache:cache-put和cache:cache-evict元素,它們類似於使用註解時的@Cacheable、@CachePut和@CacheEvict。
示例
專案結構:
資料庫表資料(Oracle):
實體類
package com.xgj.cache.springCacheXml.domain;
import java.io.Serializable;
/**
*
*
* @ClassName: LittleArtisan
*
* @Description: Java中的快取和序列化是息息相關的,注意實現Serializable介面
*
* @author: Mr.Yang
*
* @date: 2017年10月2日 下午1:40:53
*/
public class LittleArtisan implements Serializable {
private static final long serialVersionUID = 1L;
private String artisanId;
private String artisanName;
private String artisanDesc;
public String getArtisanId() {
return artisanId;
}
public void setArtisanId(String artisanId) {
this .artisanId = artisanId;
}
public String getArtisanName() {
return artisanName;
}
public void setArtisanName(String artisanName) {
this.artisanName = artisanName;
}
public String getArtisanDesc() {
return artisanDesc;
}
public void setArtisanDesc(String artisanDesc) {
this.artisanDesc = artisanDesc;
}
public static long getSerialversionuid() {
return serialVersionUID;
}
}
服務層
package com.xgj.cache.springCacheXml.service;
import java.sql.ResultSet;
import java.sql.SQLException;
import org.apache.log4j.Logger;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.jdbc.core.JdbcTemplate;
import org.springframework.jdbc.core.RowCallbackHandler;
import com.xgj.cache.springCacheXml.domain.LittleArtisan;
/**
*
*
* @ClassName: LittleArtisanSpringCacheService
*
* @Description:
*
* @author: Mr.Yang
*
* @date: 2017年10月4日 上午12:41:32
*/
public class LittleArtisanSpringCacheService {
private Logger logger = Logger
.getLogger(LittleArtisanSpringCacheService.class);
private static final String selectArtisanSQL = "select artisan_id ,artisan_name ,artisan_desc from little_artisan where artisan_name = ?";
private JdbcTemplate jdbcTemplate;
@Autowired
public void setJdbcTemplate(JdbcTemplate jdbcTemplate) {
this.jdbcTemplate = jdbcTemplate;
}
/**
*
*
* @Title: getArtisan
*
* @Description: getArtisan 通過在xml中配置 快取資料
*
* @param artisanName
* @return
*
* @return: LittleArtisan
*/
public LittleArtisan getArtisan(String artisanName) {
// 方法內部實現不考慮快取邏輯,直接實現業務
System.out.println("查詢Artisan:" + artisanName);
return getFromDB(artisanName);
}
/**
*
*
* @Title: reloadArtisan
*
* @Description: 清除快取
*
*
* @return: void
*/
public void reloadArtisan() {
System.out.println("cache cleared");
}
/**
*
*
* @Title: getFromDB
*
* @Description: 從資料庫中獲取LittleArtisan
*
* @param artisanName
* @return
*
* @return: LittleArtisan
*/
private LittleArtisan getFromDB(String artisanName) {
System.out.println("getFromDB");
final LittleArtisan littleArtisan = new LittleArtisan();
jdbcTemplate.query(selectArtisanSQL, new Object[] { artisanName },
new RowCallbackHandler() {
@Override
public void processRow(ResultSet rs) throws SQLException {
littleArtisan.setArtisanId(rs.getString("artisan_id"));
littleArtisan.setArtisanName(rs
.getString("artisan_name"));
littleArtisan.setArtisanDesc(rs
.getString("artisan_desc"));
}
});
return littleArtisan;
}
}
Spring配置檔案
<?xml version="1.0" encoding="UTF-8" ?>
<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:aop="http://www.springframework.org/schema/aop"
xmlns:context="http://www.springframework.org/schema/context"
xmlns:cache="http://www.springframework.org/schema/cache"
xsi:schemaLocation="http://www.springframework.org/schema/beans
http://www.springframework.org/schema/beans/spring-beans.xsd
http://www.springframework.org/schema/context
http://www.springframework.org/schema/context/spring-context.xsd
http://www.springframework.org/schema/aop
http://www.springframework.org/schema/aop/spring-aop.xsd
http://www.springframework.org/schema/cache
http://www.springframework.org/schema/cache/spring-cache.xsd">
<!-- 掃描注入註解,比如@Autowired -->
<context:component-scan base-package="com.xgj.cache.springCacheXml"/>
<!-- 使用context名稱空間,載入資料庫的properties檔案 -->
<context:property-placeholder location="classpath:spring/jdbc.properties" />
<!-- 資料庫 -->
<bean id="dataSource" class="org.apache.commons.dbcp.BasicDataSource"
destroy-method="close"
p:driverClassName="${jdbc.driverClassName}"
p:url="${jdbc.url}"
p:username="${jdbc.username}"
p:password="${jdbc.password}" />
<!-- 配置namedParameterJdbcTemplate模板 -->
<bean id="jdbcTemplate" class="org.springframework.jdbc.core.JdbcTemplate">
<constructor-arg ref="dataSource"/>
</bean>
<!-- 定義需要使用快取的類 -->
<bean id="littleArtisanSpringCacheService" class="com.xgj.cache.springCacheXml.service.LittleArtisanSpringCacheService"/>
<!-- 快取管理器 使用SimpleCacheManager,基於JDK的實現-->
<bean id="cacheManager" class="org.springframework.cache.support.SimpleCacheManager">
<property name="caches">
<set>
<bean class="org.springframework.cache.concurrent.ConcurrentMapCacheFactoryBean" p:name="littleArtisan"/>
</set>
</property>
</bean>
<!-- 快取定義 -->
<cache:advice id="cacheAdvice" cache-manager="cacheManager" >
<cache:caching cache="littleArtisan"> <!-- 公共快取littleArtisan -->
<cache:cacheable method="getArtisan" key="#artisanName"/> <!-- getArtisan使用 Cacheable -->
<cache:cache-evict method="reloadArtisan" all-entries="true"/><!-- reloadArtisan使用 CacheEvict -->
</cache:caching>
</cache:advice>
<!-- 切面增強 -->
<aop:config>
<aop:pointcut id="cachePoint" expression="execution(* com.xgj.cache.springCacheXml.service.LittleArtisanSpringCacheService.*(..))" />
<aop:advisor advice-ref="cacheAdvice"
pointcut-ref="cachePoint"/>
</aop:config>
</beans>
單元測試
package com.xgj.cache.springCacheXml.service;
import org.junit.After;
import org.junit.Before;
import org.junit.Test;
import org.springframework.context.support.ClassPathXmlApplicationContext;
import com.xgj.cache.springCacheXml.domain.LittleArtisan;
public class TestXmlCache {
ClassPathXmlApplicationContext context = null;
LittleArtisanSpringCacheService service = null;
LittleArtisan littleArtisan;
@Before
public void initContext() {
// 啟動Spring 容器
context = new ClassPathXmlApplicationContext(
"classpath:com/xgj/cache/springCacheXml/conf_spring.xml");
}
@Test
public void testXmlCache() {
service = context.getBean(
"littleArtisanSpringCacheService",
LittleArtisanSpringCacheService.class);
// 第一次 從資料庫載入
littleArtisan = service.getArtisan("masterArtisan");
printArtisan();
// 第二次 從快取載入
littleArtisan = service.getArtisan("masterArtisan");
printArtisan();
// 清空快取
service.reloadArtisan();
// 再次查詢,從資料庫載入
service.getArtisan("masterArtisan");
printArtisan();
// 又查詢,從快取載入
service.getArtisan("masterArtisan");
printArtisan();
}
private void printArtisan() {
System.out.println(littleArtisan.getArtisanName() + "||"
+ littleArtisan.getArtisanDesc());
}
@After
public void releaseContext() {
if (context != null) {
context.close();
}
}
}
日誌輸出
2017-10-04 08:40:00,529 INFO [main] (AbstractApplicationContext.java:583) - Refreshing org.springframework.context.support.ClassPathXmlApplicationContext@403d0d64: startup date [Wed Oct 04 08:40:00 BOT 2017]; root of context hierarchy
2017-10-04 08:40:00,623 INFO [main] (XmlBeanDefinitionReader.java:317) - Loading XML bean definitions from class path resource [com/xgj/cache/springCacheXml/conf_spring.xml]
查詢Artisan:masterArtisan
getFromDB
masterArtisan||Spring Cache
masterArtisan||Spring Cache
cache cleared
查詢Artisan:masterArtisan
getFromDB
masterArtisan||Spring Cache
masterArtisan||Spring Cache
2017-10-04 08:40:03,433 INFO [main] (AbstractApplicationContext.java:984) - Closing org.springframework.context.support.ClassPathXmlApplicationContext@403d0d64: startup date [Wed Oct 04 08:40:00 BOT 2017]; root of context hierarchy
日誌分析
第一次從資料庫中載入,第二次沒有列印getFromDB,說明是從快取中取的資料。 然後清空快取,第一次從資料庫中載入,第二次從快取中取的資料。