使用Spring Data Redis操作Redis（集群版）

說明：請注意Spring Data Redis的版本以及Spring的版本！最新版本的Spring Data Redis已經去除Jedis的依賴包，需要自行引入，這個是個坑點。並且會與一些低版本的Spring有沖突，要看官方文檔和不斷的測試。

繼上一篇文章http://www.cnblogs.com/EasonJim/p/7804545.html使用Spring Data Redis操作Redis用的是單機版，如果是集群版的集成其實差別不大。主要思路如下：

1、先建立連接工廠，這個連接工廠是用來設置IP，端口，賬號密碼等。（在這一步時，傳遞一個集群的地址列表，不再是單獨一個去指定）

2、通過連接工廠建立Session。

3、然后在代碼上注入Session進行使用。

簡要實現步驟，操作的方法和單機版的類似：

一、使用spring-data-redis的Jar包准備

首先spring-data-redis需要在1.7 版本以上。

POM：

        <!-- Redis -->
        <dependency>
            <groupId>org.springframework.data</groupId>
            <artifactId>spring-data-redis</artifactId>
            <version>1.7.11.RELEASE</version>
        </dependency>
        <dependency>
            <groupId>redis.clients</groupId>
            <artifactId>jedis</artifactId>
            <version>2.8.2</version>
        </dependency>

這個版本是我在Spring Boot項目引入包得到的靈感，用1.4.7的版本，然后它就引入了上面的包，並且MVC版本為4.3.9。

他會依賴一些包，比如說spring-data-commons ，在spring-data-x系列里，都要依賴這個包。如果你之前項目里使用到了spring-data-x系列的包，可能需要升級，因為都共同依賴了spring-data-commons ，但是在當前集群要使用的spring-data-redis中spring-data-commons必須要1.12.x版本以上，這個問題要注意一下。

二、spring-data-redis配置文件配置

<description>Jedis Cluster Configuration</description>
<!-- 加載配置屬性文件 按需加載 -->
<context:property-placeholder
    ignore-unresolvable="true" location="classpath:redis.cluster.properties" />
<!-- 配置Cluster -->
<bean id="redisClusterConfiguration"
    class="org.springframework.data.redis.connection.RedisClusterConfiguration">
    <property name="maxRedirects" value="3"></property>
    <!-- 節點配置 -->
    <property name="clusterNodes">
        <set>
            <bean class="org.springframework.data.redis.connection.RedisClusterNode">
                <constructor-arg name="host" value="192.168.0.201"></constructor-arg>
                <constructor-arg name="port" value="30006"></constructor-arg>
            </bean>
            <bean class="org.springframework.data.redis.connection.RedisClusterNode">
                <constructor-arg name="host" value="192.168.0.201"></constructor-arg>
                <constructor-arg name="port" value="30001"></constructor-arg>
            </bean>
            <bean class="org.springframework.data.redis.connection.RedisClusterNode">
                <constructor-arg name="host" value="192.168.0.201"></constructor-arg>
                <constructor-arg name="port" value="30002"></constructor-arg>
            </bean>
            <bean class="org.springframework.data.redis.connection.RedisClusterNode">
                <constructor-arg name="host" value="192.168.0.201"></constructor-arg>
                <constructor-arg name="port" value="30003"></constructor-arg>
            </bean>
            <bean class="org.springframework.data.redis.connection.RedisClusterNode">
                <constructor-arg name="host" value="192.168.0.201"></constructor-arg>
                <constructor-arg name="port" value="30004"></constructor-arg>
            </bean>
            <bean class="org.springframework.data.redis.connection.RedisClusterNode">
                <constructor-arg name="host" value="192.168.0.201"></constructor-arg>
                <constructor-arg name="port" value="30005"></constructor-arg>
            </bean>
        </set>
    </property>
</bean>
<bean id="jedisPoolConfig" class="redis.clients.jedis.JedisPoolConfig">
    <property name="maxIdle" value="100" />
    <property name="maxTotal" value="600" />
</bean>
<bean id="jeidsConnectionFactory"
    class="org.springframework.data.redis.connection.jedis.JedisConnectionFactory">
    <constructor-arg ref="redisClusterConfiguration" />
    <constructor-arg ref="jedisPoolConfig" />
</bean>
<!-- redis 訪問的模版 -->
<bean id="redisTemplate" class="org.springframework.data.redis.core.RedisTemplate">
    <property name="connectionFactory" ref="jeidsConnectionFactory" />
</bean>

操作：

    @Autowired
    RedisTemplate redisTemplate;
    @Test 
    public void testUserInfo() {
        
        redisTemplate.execute(new RedisCallback<Integer>() {
            //這里返回值是個上面的RedisCallback<Integer> 中的泛型一直，
            public Integer doInRedis(RedisConnection connection) {
                int i = 0;
                for (; i < 100; i++) {
                    byte[] key = ("key:" + i).getBytes();
                    byte[] value = ("value:" + i).getBytes();
                    connection.set(key, value);
                }
                //這里返回值是個上面的RedisCallback<Integer> 中的泛型一直，
                return i;
                
            }
        });
        
    }

 

參考：

https://docs.spring.io/spring-data/redis/docs/1.8.8.RELEASE/reference/html/#cluster（官方文檔，基於注解的形式注入）

http://www.sojson.com/blog/203.html（以上內容轉自此篇文章，基於XML的配置）

http://blog.csdn.net/MOTUI/article/details/52903397

http://blog.csdn.net/moshenglv/article/details/72637305