1. 程式人生 > >Spring Cache抽象-基於XML的配置宣告(基於ConcurrentMap的配置)

Spring Cache抽象-基於XML的配置宣告(基於ConcurrentMap的配置)

概述

如果不想使用註解或者由於其他原因無法獲得專案的原始碼等,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,說明是從快取中取的資料。 然後清空快取,第一次從資料庫中載入,第二次從快取中取的資料。

示例原始碼