zoukankan      html  css  js  c++  java
  • redis之(二十一)redis之深入理解Spring Redis的使用

    关于spring redis框架的使用,网上的例子很多很多。但是在自己最近一段时间的使用中,发现这些教程都是入门教程,包括很多的使用方法,与spring redis丰富的api大相径庭,真是浪费了这么优秀的一个框架。这里,我们就对比之前对spring orm中对hibernate的使用,来理解使用spring redis的使用。(本文章不做redis基本命令使用的讲解)

    Redis集群明细文档

    ubuntu 12.10下安装Redis(图文详解)+ Jedis连接Redis

    Redis系列-安装部署维护篇

    CentOS 6.3安装Redis

    Redis安装部署学习笔记

    Redis配置文件redis.conf 详解

    1. Redis使用场景

    Redis是一个开源的使用ANSI C语言编写、支持网络、可基于内存亦可持久化的日志型、Key-Value数据库,并提供多种语言的API。

    我们都知道,在日常的应用中,数据库瓶颈是最容易出现的。数据量太大和频繁的查询,由于磁盘IO性能的局限性,导致项目的性能越来越低。

    这时候,基于内存的缓存框架,就能解决我们很多问题。例如Memcache,Redis等。将一些频繁使用的数据放入缓存读取,大大降低了数据库的负担。提升了系统的性能。

    其实,对于hibernate的二级缓存,是同样的道理。利用内存高速的读写速度,来解决硬盘的瓶颈。

    2. 配置使用redis

    首先,我们需要引入基本的jar包。maven中的基本引用如下:

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

            <dependency>
                <groupId>redis.clients</groupId>
                <artifactId>jedis</artifactId>
                <version>2.6.2</version>
            </dependency>
     

    然后,在applicationContext中配置如下:

    <bean id="poolConfig" class="redis.clients.jedis.JedisPoolConfig">
            <property name="maxIdle" value="http://www.linuxidc.com/Linux/2015-07/${redis.maxIdle}" />
            <property name="maxTotal" value="http://www.linuxidc.com/Linux/2015-07/${redis.maxActive}" />
            <property name="maxWaitMillis" value="http://www.linuxidc.com/Linux/2015-07/${redis.maxWait}" />
            <property name="testOnBorrow" value="http://www.linuxidc.com/Linux/2015-07/${redis.testOnBorrow}" />
        </bean>

        <bean id="connectionFactory" 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="stringSerializer" class="org.springframework.data.redis.serializer.StringRedisSerializer"/>
        <!-- 开启事务,可以通过transcational注解控制 -->
        <bean id="redisTemplate" class="org.springframework.data.redis.core.RedisTemplate">
            <property name="connectionFactory" ref="connectionFactory" />
            <property name="keySerializer" ref="stringSerializer" />
            <property name="enableTransactionSupport" value="http://www.linuxidc.com/Linux/2015-07/true" />
        </bean>

    对于hibernate的配置可知,第一个poolconfig是对连接池的配置。包括最大连接数,队列数,存活时间,最大等待时间等等,还有一些额外的配置,请直接点击JedisPoolConfig类源码,进行查看。

    这些配置的意思如果不明白的话,一定要去把线程池好好学习下。

    第一个配置是连接工厂,顾名思义,最基本的使用一定是对连接的打开和关闭。我们需要为其配置redis服务器的账户密码,端口号。(这里还可以配置数据库的index,但是我使用时候一直使用redis的默认数据库,也就是第0个)

    最后一个配置特别重要。这个类似于spring提供的HibernateDaoSupport。

    接下来,全部讲解都将围绕这个类展开。

    3. RedisTemplate的使用

    这个类作为一个模版类,提供了很多快速使用redis的api,而不需要自己来维护连接,事务。

    最初的时候,我创建的BaseRedisDao是继承自这个类的。继承的好处是我的每个Dao中,都可以自由的控制序列化器,自由的控制自己是否需要事务,这个先不需要了解,跟着我目前的这种配置方法来即可。

    template提供了一系列的operation,比如valueOperation,HashOperation,ListOperation,SetOperation等,用来操作不同数据类型的Redis。

    并且,RedisTemplate还提供了对应的*OperationsEditor,用来通过RedisTemplate直接注入对应的Operation。我们暂时不讲这个。

    对于下面的test1方法,我们暂时不用考虑,先了解通过RedisTemplate来使用connection操作Redis。

    Test代码如下:

    package cn.test.spjedis;


    import Javax.annotation.Resource;

    import org.junit.Test;
    import org.junit.runner.RunWith;
    import org.springframework.beans.factory.annotation.Autowired;
    import org.springframework.dao.DataAccessException;
    import org.springframework.data.redis.connection.RedisConnection;
    import org.springframework.data.redis.core.RedisCallback;
    import org.springframework.data.redis.core.RedisTemplate;
    import org.springframework.data.redis.core.ValueOperations;
    import org.springframework.test.context.ContextConfiguration;
    import org.springframework.test.context.junit4.SpringJUnit4ClassRunner;

    import com.cn.redis2.dao.IncrDao;

    @RunWith(SpringJUnit4ClassRunner.class)
    @ContextConfiguration(locations = "classpath:applicationContext.xml")
    public class TestRedis {
        @Resource(name = "redisTemplate")
        private RedisTemplate<String, String> template; // inject the template as ListOperations
        //至于这个为什么可以注入。需要参考AbstractBeanFactory doGetBean
        //super.setValue(((RedisOperations) value).opsForValue());就这一行代码  依靠一个editor
        @Resource(name = "redisTemplate")
        private ValueOperations<String, Object> vOps;
       
        public void testSet(){
            template.execute(new RedisCallback<Boolean>() {
                @Override
                public Boolean doInRedis(RedisConnection connection) throws DataAccessException {
                    byte [] key = "tempkey".getBytes();
                    byte[] value = "http://www.linuxidc.com/Linux/2015-07/tempvalue".getBytes();
                    connection.set(key, value);
                    return true;
                }
            });
        }
       
        public void testSet1(){
            vOps.set("tempkey", "tempvalue");
        }
       
        @Autowired
        private IncrDao incr;
       
       
        @Test
        public void addLink() {
            system.out.println(incr.incr(13));
            System.out.println(incr.get(13));
        }
       
    }

    这个是对String类型插入的两个测试。test方法中,使用了模版类提交回调(RedisCallBack)的方法来使用jedis connection操作数据。这一部分,有没有似曾相识呢?

    HibernateTemplate的HibernateCallback,以及Hibernate Session类中的doWork以及doReturningWork方法,都是使用了这样的机制,方便对于连接或者session的统一管理。

    public int excuteHqlupdate(final String hql,final Object ...params){
            return getHibernateTemplate().executeWithNativeSession(new HibernateCallback<Integer>() {
                @Override
                @SuppressWarnings("unchecked")
                public Integer doInHibernate(Session session) throws HibernateException {
                    Query queryObject = session.createQuery(hql);
                    if (params != null) {
                        for (int i = 0; i < params.length; i++) {
                            queryObject.setParameter(i, params[i]);
                        }
                    }
                    return queryObject.executeUpdate();
                }
            });
        }

    4. 总结

    我 们这节,讲了spring redis的配置使用,基本特性,以及引入使用RedisTemplate。通过之前HibernateTemplate的对比,也应该对 RedisTemplate的基本设计有了一定的了解。下节,我们将进行深入学习RedisTempalte。

    更多详情见请继续阅读下一页的精彩内容

    上一篇文章我们讲解了RedisTemplate的基本使用,通过RedisCallback来获得connection,然后去操作Redis。网上的教程,大部分也都是这样的操作。

    这个类似于HibernateTemplate里面提供的executeWithNativeSession方法,是Java中的一种同步回调机制。在方法的前后,系统替我们打开关闭连接,设置事务等。

    RedisTemplate  api详解

    1. RedisTemplate的事务

        private boolean enableTransactionSupport = false;
        private boolean exposeConnection = false;
        private boolean initialized = false;
        private boolean enableDefaultSerializer = true;
        private RedisSerializer<?> defaultSerializer = new JdkSerializationRedisSerializer();

        private RedisSerializer keySerializer = null;
        private RedisSerializer valueSerializer = null;
        private RedisSerializer hashKeySerializer = null;
        private RedisSerializer hashValueSerializer = null;
        private RedisSerializer<String> stringSerializer = new StringRedisSerializer();

        private ScriptExecutor<K> scriptExecutor;

        // cache singleton objects (where possible)
        private ValueOperations<K, V> valueOps;
        private ListOperations<K, V> listOps;
        private SetOperations<K, V> setOps;
        private ZSetOperations<K, V> zSetOps;

    enableTransactionSupport: 是否启用事务支持。我们在代码中搜索下用到这个变量的地方,会看到,在调用RedisCallback之前,有一行代码是如果启用事务支持,那么conn = RedisConnectionUtils.bindConnection(factory, enableTransactionSupport),也就是说,系统自动帮我们拿到了事务中绑定的连接。可以在一个方法的多次对Redis增删该查中, 始终使用同一个连接。但是,即使使用了同样的连接,没有进行connection.multi()和connection.exec(),依然是无法启用 事务的。

    我没有仔细的查阅代码,但是可以知道的是,Spring已经对这个,给了我们一个更好的支持:@Transactional

    在调用RedisTempalte中的execute()方法的地方,加入这个注解(是spring包下面提供的,不要引用成rt包下的注解),能让这个方法中的所有execute,自动加入multi()以及异常的回滚或者是正常运行时候的提交!

    2. RedisTempalte的Serializer

    用过jedis操作的都知道,所有connection的操作方法,都是传入字节数组。那么,将一个对象和字节相互转换,就需要通过序列化和反序列化。

    模版方法中,Spring提供了默认的StringSerializer和JdkSerializer,第一个很简单,就是通过String.getBytes()来实现的。而且在Redis中,所有存储的值都是字符串类 型的。所以这种方法保存后,通过Redis-cli控制台,是可以清楚的查看到我们保存了什么key,value是什么。但是对于 JdkSerializationRedisSerializer来说,这个序列化方法就是Jdk提供的了。首先要求我们要被序列化的类继承自 Serializeable接口,然后通过,然后通过Jdk对象序列化的方法保存。(注:这个序列化保存的对象,即使是个String类型的,在redis控制台,也是看不出来的,因为它保存了一些对象的类型什么的额外信息,)

    这么一长串,其实就是一个int类型的123。

    keySerializer:这个是对key的默认序列化器。默认值是StringSerializer。

    valueSerializer:这个是对value的默认序列化器,默认值是取自DefaultSerializer的JdkSerializationRedisSerializer。

    hashKeySerializer:对hash结构数据的hashkey序列化器,默认值是取自DefaultSerializer的JdkSerializationRedisSerializer。

    hashValueSerializer:对hash结构数据的hashvalue序列化器,默认值是取自DefaultSerializer的JdkSerializationRedisSerializer。

    除此之外,我们在该类中,还发现了valueOps和hashOps等操作类,这是spring给我们提供的可以直接使用来操作Redis的类,非常方便。下一篇我们将讲解这些类。

  • 相关阅读:
    对C++类的继承和派生的理解
    排序算法 之 归并排序
    排序算法 之 冒泡排序
    排序算法 之 选择排序
    排序算法 之 插入排序
    排序算法 之 快速排序
    进程和线程
    C++ 之 强制转换
    C++ 之 智能指针
    C++ STL 之 分配器(allocator)
  • 原文地址:https://www.cnblogs.com/shangxiaofei/p/6232731.html
Copyright © 2011-2022 走看看