继上一篇文章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:
<dependency> <groupId>org.springframework.data</groupId> <artifactId>spring-data-redis</artifactId> <version>1.7.5.RELEASE</version> </dependency>
他会依赖一些包,比如说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