javascript
使用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-placeholderignore-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>操作:
@AutowiredRedisTemplate 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
總結
以上是生活随笔為你收集整理的使用Spring Data Redis操作Redis(集群版)的全部內容,希望文章能夠幫你解決所遇到的問題。
- 上一篇: RocketMQ Apache顶级项目之
- 下一篇: linux命令:case选择结构语句