Spring Data Redis 管理Redis 之1

标签：redis   spring data   

redis是一款非常流行的Nosql,提供的功能非常强大，本节不再赘述。

本文简单介绍Spring Data框架提供的spring_data_redis模块，所提供的强大功能。虽然，spring_data_redis不具体负责与redis通信，但提供了丰富的外围功能。

主要包含以下内容

1. 搭建测试环境

2. 序列工具
   

3. 认识RedisConnectionFactory&RedisTemplate

1.搭建测试环境

1.1 pom.xml

<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0"
         xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
    <modelVersion>4.0.0</modelVersion>
    <parent>
        <!-- Your own application should inherit from spring-boot-starter-parent -->
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-parent</artifactId>
        <version>1.3.5.RELEASE</version>
    </parent>
    <groupId>com.hellodb.springdata</groupId>
    <artifactId>redisdemo</artifactId>
    <version>1.0-SNAPSHOT</version>
    <dependencies>
        <dependency>
            <groupId>org.springframework.data</groupId>
            <artifactId>spring-data-redis</artifactId>
        </dependency>
        <!-- 客户端 -->
        <dependency>
            <groupId>redis.clients</groupId>
            <artifactId>jedis</artifactId>
        </dependency>
        <dependency>
                    <groupId>biz.paluch.redis</groupId>
                    <artifactId>lettuce</artifactId>
                    <version>3.2.Final</version>
        </dependency>
        <!--序列化工具 -->
        <dependency>
            <groupId>com.fasterxml.jackson.core</groupId>
            <artifactId>jackson-databind</artifactId>
        </dependency>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-test</artifactId>
            <scope>test</scope>
        </dependency>
    </dependencies> 
</project>

1.2配置XML

jedis-context.xml

<?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"
       xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd">

       <!-- Jedis ConnectionFactory -->
       <bean id="jedisConnectionFactory" class="org.springframework.data.redis.connection.jedis.JedisConnectionFactory"
              p:port="6379" p:hostName="192.168.163.146"/>

       <bean id="redisTemplate" class="org.springframework.data.redis.core.RedisTemplate">
              <property name="connectionFactory" ref="jedisConnectionFactory"></property>
       </bean>
</beans>

lettuce-context.xml

<?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"
       xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd">

       <!-- Jedis ConnectionFactory -->
       <bean id="lettuceConnectionFactory" class="org.springframework.data.redis.connection.lettuce.LettuceConnectionFactory"
              p:port="6379" p:hostName="192.168.163.146"/>

       <bean id="redisTemplate" class="org.springframework.data.redis.core.RedisTemplate">
              <property name="connectionFactory" ref="lettuceConnectionFactory"></property>
       </bean>
</beans>

实际环境中，只需要选择一个客户端即可。当然，各个客户端的使用场景有所区别，这儿就不深入讨论了。

JedisRedisTemplateTest.java :使用jedis客户端

@RunWith(SpringJUnit4ClassRunner.class)
@ContextConfiguration("classpath:jedis-context.xml")
public class JedisRedisTemplateTest {
    @Resource
    RedisTemplate redisTemplate;
     @Test
    public void testOpsForValue() {   
        String redisKey1 = "jedis_redis_key_1";
        String originValue = "redis by jedis!";
        Jackson2JsonRedisSerializer<String> serializer = new Jackson2JsonRedisSerializer(String.class);
        redisTemplate.setKeySerializer(serializer);
        redisTemplate.setValueSerializer(serializer);
        redisTemplate.opsForValue().set(redisKey1, originValue);
        redisStoredValue = redisTemplate.opsForValue().get(redisKey1);
        assertEquals(redisStoredValue, originValue);
    }
}

LettuceRedisTemplateTest.java :使用lettuce客户端

@RunWith(SpringJUnit4ClassRunner.class)
@ContextConfiguration("classpath:lettuce-context.xml")
public class LettuceRedisTemplateTest{
    @Resource
    RedisTemplate redisTemplate;
     @Test
    public void testOpsForValue() {   
        String redisKey1 = "lettuce_redis_key_1";
        String originValue = "redis by lettuce!";
        Jackson2JsonRedisSerializer<String> serializer = new Jackson2JsonRedisSerializer(String.class);
        redisTemplate.setKeySerializer(serializer);
        redisTemplate.setValueSerializer(serializer);
        redisTemplate.opsForValue().set(redisKey1, originValue);
        redisStoredValue = redisTemplate.opsForValue().get(redisKey1);
        assertEquals(redisStoredValue, originValue);
    }
}

对比两个测试用例, 测试用例方法，基本一致，很清晰的感受到spring data redis框架带来的扩展性。修改底层redis客户端实现技术，而不会影响到上层现有方法（如redisTemplate方法）

运行2个用例结果

127.0.0.1:6379> keys *
1) "\"lettuce_redis_key_1\""
2) "\"jedis_redis_key_1\""
127.0.0.1:6379> get  "\"lettuce_redis_key_1\""
"\"redis by lettuce!\""
127.0.0.1:6379> get  "\"jedis_redis_key_1\""
"\"redis by jedis!\""

现在环境搭建完毕。

2.序列工具

从框架的角度来看，Redis中存储的数据只是字节数。虽然Redis本身支持各种类型，但大多数情况下，这些指的是数据存储的方式，而不是它所代表的格式。由用户决定信息是否转换为字符串或任何其他对象。用户（自定义）类型和原始数据（反之亦然）之间的转换通过RedisSerializer接口（包org.springframework.data.redis.serializer）在Spring Data Redis中处理，顾名思义，它负责处理序列化过程。Spring data redis提供了多个序列化工具。

2.1 RedisSerializer API

//对象到字节数组（二进制数据）的基本接口序列化和反序列化
public interface RedisSerializer<T> {

   /**
    *将给定对象序列化为二进制数据
    */
   byte[] serialize(T t) throws SerializationException;

   /**
    * 从给定的二进制数据反序列化对象。
    */
   T deserialize(byte[] bytes) throws SerializationException;
}

2.2 内置序列化实现

org.springframework.data.redis.serializer.GenericJackson2JsonRedisSerializer

org.springframework.data.redis.serializer.GenericToStringSerializer

org.springframework.data.redis.serializer.Jackson2JsonRedisSerializer

org.springframework.data.redis.serializer.JacksonJsonRedisSerializer

org.springframework.data.redis.serializer.JdkSerializationRedisSerializer

org.springframework.data.redis.serializer.OxmSerializer

org.springframework.data.redis.serializer.StringRedisSerializer

2.3 RedisSerializer使用场景

在RedisTemplate，RedisMessageListenerContainer，DefaultStringRedisConnection使用。

比如RedisTemplate。

public class RedisTemplate<K, V> extends RedisAccessor implements RedisOperations<K, V> {
...
/ **
* @return是否应使用默认的序列化程序。 如果没有，任何序列化不明确集将会
*保持为空，值将不会被序列化或反序列化。
* /
public boolean isEnableDefaultSerializer（）{
    return enableDefaultSerializer;
}


/ **
* @param enableDefaultSerializer是否应使用默认的序列化程序。 如果没有，任何serializer不
*展示集将保持为空，值将不会被序列化或反序列化。
* /
public void setEnableDefaultSerializer（boolean enableDefaultSerializer）{
    this.enableDefaultSerializer = enableDefaultSerializer;
}


/ **
*返回此模板使用的默认序列化程序。
*：
* @return模板默认序列化
* /
public RedisSerializer <?> getDefaultSerializer（）{
    return defaultSerializer;
}


/ **
*设置要用于此模板的默认序列化程序。 所有序列化（期望
* @link #setStringSerializer（RedisSerializer））初始化为此值，除非显式设置。 默认为
* @link JdkSerializationRedisSerializer。
*：
* @param serializer默认序列化程序使用
* /
public void setDefaultSerializer（RedisSerializer <?> serializer）{
    this.defaultSerializer = serializer;
}


/ **
*设置此模板使用的密钥序列化程序。 默认为@link #getDefaultSerializer（）。
*：
* @param serializer此模板使用的密钥序列化程序。
* /
public void setKeySerializer（RedisSerializer <?> serializer）{
    this.keySerializer = serializer;
}


/ **
*返回此模板使用的密钥序列化程序。
*：
* @返回此模板使用的密钥序列化程序。
* /
public RedisSerializer <?> getKeySerializer（）{
    return keySerializer;
}


/ **
*设置此模板使用的值序列化程序。 默认为@link #getDefaultSerializer（）。
*：
* @param serializer此模板使用的值序列化程序。
* /
public void setValueSerializer（RedisSerializer <?> serializer）{
    this.valueSerializer = serializer;
}


/ **
*返回此模板使用的值序列化程序。
*：
* @返回此模板使用的值序列化程序。
* /
public RedisSerializer <?> getValueSerializer（）{
    return valueSerializer;
}
...
}

2.4  测试

上面的JedisRedisTemplateTest 使用的序列化工具Jackson2JsonRedisSerializer。

127.0.0.1:6379> keys *
1) "\"jedis_redis_key_1\""
127.0.0.1:6379> get "\"jedis_redis_key_1\""
"\"redis by jedis!\""

改用StringRedisSerializer，操作redis后效果

127.0.0.1:6379> flushdb
OK
127.0.0.1:6379> keys *
1) "jedis_redis_key_1"
127.0.0.1:6379> get jedis_redis_key_1
"redis by jedis!"

3.认识RedisConnectionFactory&RedisTemplate

通过这个结构，可以实现客户端工具的无缝切换。

RedisConnection

RedisTemplate模板提供了操作视图（根据Redis命令引用进行分组），它提供丰富的，一般化的接口，用于对某种类型或某个键（通过KeyBound接口）进行处理，如下所述

操作视图：Operational views

本文出自 “简单” 博客，请务必保留此出处http://dba10g.blog.51cto.com/764602/1889115

Spring Data Redis 管理Redis 之1

标签：redis   spring data   

原文地址：http://dba10g.blog.51cto.com/764602/1889115