SSM框架下的redis缓存

绝地灬酷狼 2022-06-07 09:09 213阅读 0赞

[SSM框架下的redis缓存][SSM_redis]

基本SSM框架搭建：http://www.cnblogs.com/fuchuanzhipan1209/p/6274358.html

配置文件部分：

第一步：加入jar包

pom.xml

![复制代码][copycode.gif]

<dependency>
                <groupId>org.springframework.data</groupId>
                <artifactId>spring-data-redis</artifactId>
                <version>1.6.2.RELEASE</version>
            </dependency>
            
            <dependency>
                <groupId>redis.clients</groupId>
                <artifactId>jedis</artifactId>
                <version>2.8.0</version>
            </dependency>
            
            <dependency>
                <groupId>org.mybatis</groupId>
                <artifactId>mybatis-ehcache</artifactId>
                <version>1.0.0</version>
            </dependency>

![复制代码][copycode.gif]

主配置文件：applicationContext.xml

![复制代码][copycode.gif]

<beans xmlns="http://www.springframework.org/schema/beans"
        xmlns:p="http://www.springframework.org/schema/p" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
        xmlns:mvc="http://www.springframework.org/schema/mvc" xmlns:context="http://www.springframework.org/schema/context"
        xmlns:aop="http://www.springframework.org/schema/aop" xmlns:tx="http://www.springframework.org/schema/tx"
        xsi:schemaLocation="http://www.springframework.org/schema/beans 
            http://www.springframework.org/schema/beans/spring-beans-3.2.xsd 
            http://www.springframework.org/schema/mvc 
            http://www.springframework.org/schema/mvc/spring-mvc-3.2.xsd 
            http://www.springframework.org/schema/context 
            http://www.springframework.org/schema/context/spring-context-3.2.xsd 
            http://www.springframework.org/schema/aop 
            http://www.springframework.org/schema/aop/spring-aop-3.2.xsd 
            http://www.springframework.org/schema/tx 
            http://www.springframework.org/schema/tx/spring-tx-3.2.xsd ">
    
        
        
        <bean id="propertyConfigurer"
            class="org.springframework.beans.factory.config.PropertyPlaceholderConfigurer">
            <property name="locations">
                <list>
                    <value>classpath:db.properties</value>
                    <value>classpath:redis.properties</value>
                </list>
            </property>
        </bean>
        
        <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>
        
        <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" />
        
        <bean id="redisCacheTransfer" class="com.nuo.cache.RedisCacheTransfer">
            <property name="jedisConnectionFactory" ref="jedisConnectionFactory" />
        </bean>
        
    
        <bean id="dataSource" class="org.apache.commons.dbcp.BasicDataSource"
            destroy-method="close">
            <property name="driverClassName" value="${jdbc.driver}" />
            <property name="url" value="${jdbc.url}" />
            <property name="username" value="${jdbc.username}" />
            <property name="password" value="${jdbc.password}" />
            <property name="maxActive" value="30" />
            <property name="maxIdle" value="5" />
        </bean>
        
        <bean id="sqlSessionFactory" class="org.mybatis.spring.SqlSessionFactoryBean">
            
            <property name="dataSource" ref="dataSource" />
            
            <property name="configLocation" value="classpath:sqlMapConfig.xml" />
        </bean>
        
        <bean class="org.mybatis.spring.mapper.MapperScannerConfigurer">
            
            <property name="basePackage" value="com.nuo.mapper"></property>
            <property name="sqlSessionFactoryBeanName" value="sqlSessionFactory" />
        </bean>
    
        
        <bean id="PersonService" class="com.nuo.service.impl.PersonServiceImpl" />
    
    
        
        <bean id="transactionManager"
            class="org.springframework.jdbc.datasource.DataSourceTransactionManager">
            
            <property name="dataSource" ref="dataSource" />
        </bean>
        
        <tx:advice id="txAdvice" transaction-manager="transactionManager">
            <tx:attributes>
                
                <tx:method name="save*" propagation="REQUIRED" />
                <tx:method name="delete*" propagation="REQUIRED" />
                <tx:method name="insert*" propagation="REQUIRED" />
                <tx:method name="update*" propagation="REQUIRED" />
                <tx:method name="find*" propagation="SUPPORTS" read-only="true" />
                <tx:method name="get*" propagation="SUPPORTS" read-only="true" />
                <tx:method name="select*" propagation="SUPPORTS" read-only="true" />
            </tx:attributes>
        </tx:advice>
    
        
        <aop:config>
            <aop:advisor advice-ref="txAdvice"
                pointcut="execution(* com.nuo.service.impl.*.*(..))" />
        </aop:config>
    
    </beans>

![复制代码][copycode.gif]

mybitas配置文件：

sqlMapConfig.xml

![复制代码][copycode.gif]

<?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>
    
        
    
        
    
        
        
        
        <settings>
    
            
            <setting name="cacheEnabled" value="true" />
    
            
            <setting name="lazyLoadingEnabled" value="false" />
    
            
            <setting name="multipleResultSetsEnabled" value="true" />
    
            
            <setting name="aggressiveLazyLoading" value="true" />
    
        </settings>
        
        <typeAliases>
            
            <package name="com.nuo.model" />
        </typeAliases>
        
        
    </configuration>

![复制代码][copycode.gif]

redis配置：

redis.properties

![复制代码][copycode.gif]

# Redis settings  
    redis.host=127.0.0.1
    redis.port=6379  
    redis.pass=
    
    redis.maxIdle=300  
    redis.maxActive=600  
    redis.maxWait=1000  
    redis.testOnBorrow=true

![复制代码][copycode.gif]

Java代码工具类部分

静态注入中间类

![复制代码][copycode.gif]

import org.springframework.beans.factory.annotation.Autowired;
    import org.springframework.data.redis.connection.jedis.JedisConnectionFactory;
    
    /**
     * 
     * @描述: 静态注入中间类
    
     */
    public class RedisCacheTransfer 
    {
    
        @Autowired
        public void setJedisConnectionFactory(JedisConnectionFactory jedisConnectionFactory) {
            RedisCache.setJedisConnectionFactory(jedisConnectionFactory);
            
        }
    
    }

![复制代码][copycode.gif]

第三方内存数据库Redis

![复制代码][copycode.gif]

import java.util.concurrent.locks.ReadWriteLock;
    import java.util.concurrent.locks.ReentrantReadWriteLock;
    
    import org.apache.ibatis.cache.Cache;
    import org.slf4j.Logger;
    import org.slf4j.LoggerFactory;
    import org.springframework.data.redis.connection.jedis.JedisConnection;
    import org.springframework.data.redis.connection.jedis.JedisConnectionFactory;
    import org.springframework.data.redis.serializer.JdkSerializationRedisSerializer;
    import org.springframework.data.redis.serializer.RedisSerializer;
    
    import redis.clients.jedis.exceptions.JedisConnectionException;
    
    /**
     * 
     * @描述: 使用第三方内存数据库Redis作为二级缓存
     * @版权: Copyright (c) 2016
     * @作者:
     * @版本: 1.0
     * @创建日期:
     * @创建时间:
     */
    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() {
            // TODO Auto-generated method stub
            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;
        }
    
    }

![复制代码][copycode.gif]

Java代码 SQL语句部分

![复制代码][copycode.gif]

<?xml version="1.0" encoding="UTF-8"?>
    <!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
    
    <mapper namespace="com.nuo.mapper.PersonMapper">
        <cache eviction="LRU" type="com.nuo.cache.RedisCache" />
        <resultMap type="Person" id="PersonMap">
            <id column="id" property="id"/>
            <result column="name" property="name"/>
            <result column="gender" property="gender"/>     
        </resultMap>
        <select id="getByName" parameterType="String" resultMap="PersonMap">
            <![CDATA[
                SELECT
                    * 
                FROM 
                    person
                WHERE 
                    name = LOWER(#{name})
            ]]>
        </select>
        
        <insert id="addPerson" parameterType="Person">
            <![CDATA[
            insert into
              person(name,gender)
              values(#{name},#{gender});
            
            ]]>
        </insert>
        
        <select id="getById" parameterType="int" resultMap="PersonMap">
            <![CDATA[
                SELECT
                    * 
                FROM 
                    person
                WHERE 
                    id = LOWER(#{id})
            ]]>
        </select>
        
    </mapper>

![复制代码][copycode.gif]

关键部分：

执行验证

第一次执行sql查询：

![1077876-20170719114255083-1924779180.png][]

第二次执行相同语句时，不再打印sql语句，说明直接从缓存中读取了数据。

![1077876-20170719114416552-884901617.png][]

redis服务器查看

![1077876-20170719114550693-1569403321.png][]

转载网址：[http://www.cnblogs.com/fuchuanzhipan1209/p/7204756.html][SSM_redis]

[SSM_redis]: http://www.cnblogs.com/fuchuanzhipan1209/p/7204756.html
[copycode.gif]: /images/20220607/463aabab2e874ab0abdd075e5c89400b.png
[1077876-20170719114255083-1924779180.png]: /images/20220607/bbd2b464999843b2a3438721b0b6250e.png
[1077876-20170719114416552-884901617.png]: /images/20220607/5392ce7b464b47408d4890595760373c.png
[1077876-20170719114550693-1569403321.png]: /images/20220607/2647e863ca9944548bbf49fe9d12437f.png