SpringMVC + MyBatis + Mysql + Redis(做爲二級緩存) 配置

SpringMVC + MyBatis + Mysql + Redis(做爲二級緩存) 配置
項目環境： 在SpringMVC + MyBatis + Mysql。Redis部署在Linux虛擬機。
一、總體思路
參考Ehcache實現MyBatis二級緩存代碼（Maven引用對應jar查閱）
使用Spring管理Redis鏈接池
模仿EhcacheCache，實現RedisCache
二、pom.xml中加入Maven依賴
[Java] 純文本查看 複製代碼
?

<!-- spring-redis實現 -->
<dependency>

<groupId>org.springframework.data</groupId>
<artifactId>spring-data-redis</artifactId>
<version>1.6.2.RELEASE</version>

</dependency>
<!-- redis客戶端jar -->
<dependency>

<groupId>redis.clients</groupId>
<artifactId>jedis</artifactId>
<version>2.8.0</version>

</dependency>
<!-- Ehcache實現,用於參考 -->
<dependency>

<groupId>org.mybatis</groupId>
<artifactId>mybatis-ehcache</artifactId>
<version>1.0.0</version>

</dependency>
三、引入applicationContext.xml中引入redis配置
[Java] 純文本查看 複製代碼
?

<!-- 引入數據庫配置文件 -->
<bean
id="propertyConfigurer" class="org.springframework.beans.factory.config.PropertyPlaceholderConfigurer">

<property name="locations">
    <list>
        <value>classpath:jdbc.properties</value>
        <value>classpath:redis.properties</value>
    </list>
</property>

</bean>
<!-- redis數據源 -->
<bean id="poolConfig" class="redis.clients.jedis.JedisPoolConfig">

<property name="maxIdle" value="${redis.maxIdle}" />  
<property name="maxTotal" value="${redis.maxActive}" />  
<property name="maxWaitMillis" value="${redis.maxWait}" />  
<property name="testOnBorrow" value="${redis.testOnBorrow}" />

</bean>
<!-- Spring-redis鏈接池管理工廠 -->
<bean id="jedisConnectionFactory" class="org.springframework.data.redis.connection.jedis.JedisConnectionFactory"

p:host-name="${redis.host}" p:port="${redis.port}" p:password="${redis.pass}"  p:pool-config-ref="poolConfig"/>

<!-- 使用中間類解決RedisCache.jedisConnectionFactory的靜態注入，從而使MyBatis實現第三方緩存 -->
<bean id="redisCacheTransfer" class="com.strive.cms.cache.RedisCacheTransfer">

<property name="jedisConnectionFactory" ref="jedisConnectionFactory"/>

</bean>
四、建立緩存實現類RedisCache
[Java] 純文本查看 複製代碼
?

public class RedisCache implements Cache
{

private static final Logger logger = LoggerFactory.getLogger(RedisCache.class);

private static JedisConnectionFactory jedisConnectionFactory;

private final String id;

/**
 * The {@code ReadWriteLock}.
 */
private final ReadWriteLock readWriteLock = new ReentrantReadWriteLock();

public RedisCache(final String id) {
    if (id == null) {
        throw new IllegalArgumentException("Cache instances require an ID");
    }
    logger.debug("MybatisRedisCache:id=" + id);
    this.id = id;
}

@Override
public void clear()
{
    JedisConnection connection = null;
    try
    {
        connection = jedisConnectionFactory.getConnection();
        connection.flushDb();
        connection.flushAll();
    }
    catch (JedisConnectionException e)
    {
        e.printStackTrace();
    }
    finally
    {
        if (connection != null) {
            connection.close();
        }
    }
}

@Override
public String getId()
{
    return this.id;
}

@Override
public Object getObject(Object key)
{
    Object result = null;
    JedisConnection connection = null;
    try
    {
        connection = jedisConnectionFactory.getConnection();
        RedisSerializer<Object> serializer = new JdkSerializationRedisSerializer();
        result = serializer.deserialize(connection.get(serializer.serialize(key)));
    }
    catch (JedisConnectionException e)
    {
        e.printStackTrace();
    }
    finally
    {
        if (connection != null) {
            connection.close();
        }
    }
    return result;
}

@Override
public ReadWriteLock getReadWriteLock()
{
    return this.readWriteLock;
}

@Override
public int getSize()
{
    int result = 0;
    JedisConnection connection = null;
    try
    {
        connection = jedisConnectionFactory.getConnection();
        result = Integer.valueOf(connection.dbSize().toString());
    }
    catch (JedisConnectionException e)
    {
        e.printStackTrace();
    }
    finally
    {
        if (connection != null) {
            connection.close();
        }
    }
    return result;
}

@Override
public void putObject(Object key, Object value)
{
    JedisConnection connection = null;
    try
    {
        connection = jedisConnectionFactory.getConnection();
        RedisSerializer<Object> serializer = new JdkSerializationRedisSerializer();
        connection.set(serializer.serialize(key), serializer.serialize(value));
    }
    catch (JedisConnectionException e)
    {
        e.printStackTrace();
    }
    finally
    {
        if (connection != null) {
            connection.close();
        }
    }
}

@Override
public Object removeObject(Object key)
{
    JedisConnection connection = null;
    Object result = null;
    try
    {
        connection = jedisConnectionFactory.getConnection();
        RedisSerializer<Object> serializer = new JdkSerializationRedisSerializer();
        result =connection.expire(serializer.serialize(key), 0);
    }
    catch (JedisConnectionException e)
    {
        e.printStackTrace();
    }
    finally
    {
        if (connection != null) {
            connection.close();
        }
    }
    return result;
}

public static void setJedisConnectionFactory(JedisConnectionFactory jedisConnectionFactory) {
    RedisCache.jedisConnectionFactory = jedisConnectionFactory;
}

}
五、建立中間類RedisCacheTransfer，完成RedisCache.jedisConnectionFactory的靜態注入
[Java] 純文本查看 複製代碼
?

public class RedisCacheTransfer
{

@Autowired
public void setJedisConnectionFactory(JedisConnectionFactory jedisConnectionFactory) {
    RedisCache.setJedisConnectionFactory(jedisConnectionFactory);
}

}
六、配置文件redis.properties

Redis settings

redis.host=192.168.25.132
redis.port=6379
redis.pass=
redis.maxIdle=300
redis.maxActive=600
redis.maxWait=1000
redis.testOnBorrow=true
七、mapper中加入MyBatis二級緩存
[Java] 純文本查看 複製代碼

<mapper namespace="com.strive.cms.dao.site.CatalogMapper" >
<cache type="com.strive.cms.cache.RedisCache"/>
</mapper>
八、Mybatis全局配置
[Java] 純文本查看 複製代碼
?

<?xml version="1.0" encoding="UTF-8" ?>
<!DOCTYPE configuration

PUBLIC "-//mybatis.org//DTD Config 3.0//EN"
    "http://mybatis.org/dtd/mybatis-3-config.dtd">

<configuration>

<!-- 配置mybatis的緩存，延遲加載等等一系列屬性 -->
<settings>

    <!-- 全局映射器啓用緩存 -->
    <setting name="cacheEnabled" value="true"/>

    <!-- 查詢時，關閉關聯對象即時加載以提升性能 -->
    <setting name="lazyLoadingEnabled" value="false"/>

    <!-- 對於未知的SQL查詢，容許返回不一樣的結果集以達到通用的效果 -->
    <setting name="multipleResultSetsEnabled" value="true"/>

    <!-- 容許使用列標籤代替列名 -->
    <setting name="useColumnLabel" value="true"/>

    <!-- 不容許使用自定義的主鍵值(好比由程序生成的UUID 32位編碼做爲鍵值)，數據表的PK生成策略將被覆蓋 -->
    <setting name="useGeneratedKeys" value="false"/>

    <!-- 給予被嵌套的resultMap以字段-屬性的映射支持 FULL,PARTIAL -->
    <setting name="autoMappingBehavior" value="PARTIAL"/>

    <!-- 對於批量更新操做緩存SQL以提升性能 BATCH,SIMPLE -->
    <!-- <setting name="defaultExecutorType" value="BATCH" /> -->

    <!-- 數據庫超過25000秒仍未響應則超時 -->
    <!-- <setting name="defaultStatementTimeout" value="25000" /> -->

    <!-- Allows using RowBounds on nested statements -->
    <setting name="safeRowBoundsEnabled" value="false"/>

    <!-- Enables automatic mapping from classic database column names A_COLUMN to camel case classic Java property names aColumn. -->
    <setting name="mapUnderscoreToCamelCase" value="true"/>

    <!-- MyBatis uses local cache to prevent circular references and speed up repeated nested queries. By default (SESSION) all queries executed during a session are cached. If localCacheScope=STATEMENT 
        local session will be used just for statement execution, no data will be shared between two different calls to the same SqlSession. -->
    <setting name="localCacheScope" value="SESSION"/>

    <!-- Specifies the JDBC type for null values when no specific JDBC type was provided for the parameter. Some drivers require specifying the column JDBC type but others work with generic values 
        like NULL, VARCHAR or OTHER. -->
    <setting name="jdbcTypeForNull" value="OTHER"/>

    <!-- Specifies which Object's methods trigger a lazy load -->
    <setting name="lazyLoadTriggerMethods" value="equals,clone,hashCode,toString"/>

    <!-- 設置關聯對象加載的形態，此處爲按需加載字段(加載字段由SQL指 定)，不會加載關聯表的全部字段，以提升性能 -->
    <setting name="aggressiveLazyLoading" value="true"/>

</settings>

</configuration>

九、打印Sql日誌，方便測試

定義LOG輸出級別爲INFO

log4j.rootLogger=INFO,Console,File

定義日誌輸出目的地爲控制檯

log4j.appender.Console=org.apache.log4j.ConsoleAppender
log4j.appender.Console.Target=System.out

能夠靈活地指定日誌輸出格式，下面一行是指定具體的格式

log4j.appender.Console.layout = org.apache.log4j.PatternLayout
log4j.appender.Console.layout.ConversionPattern=[%c] - %m%n

文件大小到達指定尺寸的時候產生一個新的文件

log4j.appender.File = org.apache.log4j.RollingFileAppender

指定輸出目錄

log4j.appender.File.File = logs/ssm.log

定義文件最大大小

log4j.appender.File.MaxFileSize = 10MB

輸出因此日誌，若是換成DEBUG表示輸出DEBUG以上級別日誌

log4j.appender.File.Threshold = ALL
log4j.appender.File.layout = org.apache.log4j.PatternLayout
log4j.appender.File.layout.ConversionPattern =[%p] %d{yyyy-MM-dd HH:mm:ss}%m%n

顯示本項目SQL語句部分

log4j.logger.com.strive.cms=DEBUG