码迷，mamicode.com
首页 > 其他好文 > 详细

Redis实战之Redis + Jedis[转]

时间：2014-11-19 18:03:40      阅读：264      评论：0      收藏：0      [点我收藏+]

标签：style   blog   http   io   ar   os   使用   sp   java   

http://blog.csdn.net/it_man/article/details/9730605

2013-08-03 11:01 1786人阅读 评论(0) 收藏 举报
 
 

用Memcached，对于缓存对象大小有要求，单个对象不得大于1MB，且不支持复杂的数据类型，譬如SET

等。基于这些限制，有必要考虑Redis！

相关链接：

Redis实战

Redis实战之Redis + Jedis

Redis实战之征服 Redis + Jedis + Spring （一）

Redis实战之征服 Redis + Jedis + Spring （二）

Redis实战之征服 Redis + Jedis + Spring （三）

 

言归正传，目前Redis大概有3中基于Java语言的Client：

  • Jredis
  • Jedis
  • Redis4J

这里只说Jedis，因为它是官方提供的唯一Redis Client For Java Provider！bubuko.com,布布扣

 

一、简单使用Jedis

需要Jedis就从Maven获取吧！
Maven Pom.xml

 

Xml代码  
  1. <dependency>  
  2.     <groupId>redis.clients</groupId>  
  3.     <artifactId>jedis</artifactId>  
  4.     <version>2.1.0</version>  
  5.     <type>jar</type>  
  6.     <scope>compile</scope>  
  7. </dependency>  
[xml] view plaincopy
 
  1. <dependency>  
  2.     <groupId>redis.clients</groupId>  
  3.     <artifactId>jedis</artifactId>  
  4.     <version>2.1.0</version>  
  5.     <type>jar</type>  
  6.     <scope>compile</scope>  
  7. </dependency>  

 

 

 

如果只是简单使用Jedis，以下这么几行代码足够：

 

Java代码  
  1. Jedis jedis = new Jedis("10.11.20.140");  
  2. String keys = "name";  
  3.   
  4. // 删数据  
  5. jedis.del(keys);  
  6. // 存数据  
  7. jedis.set(keys, "snowolf");  
  8. // 取数据  
  9. String value = jedis.get(keys);  
  10.   
  11. System.out.println(value);  
[java] view plaincopy
 
  1. Jedis jedis = new Jedis("10.11.20.140");  
  2. String keys = "name";  
  3.   
  4. // 删数据  
  5. jedis.del(keys);  
  6. // 存数据  
  7. jedis.set(keys, "snowolf");  
  8. // 取数据  
  9. String value = jedis.get(keys);  
  10.   
  11. System.out.println(value);  

 

 

二、池化使用Jedis

Jedis使用commons-pool完成池化实现。

先做个配置文件：

Properties代码  
  1. #最大分配的对象数  
  2. redis.pool.maxActive=1024  
  3. #最大能够保持idel状态的对象数  
  4. redis.pool.maxIdle=200  
  5. #当池内没有返回对象时，最大等待时间  
  6. redis.pool.maxWait=1000  
  7. #当调用borrow Object方法时，是否进行有效性检查  
  8. redis.pool.testOnBorrow=true  
  9. #当调用return Object方法时，是否进行有效性检查  
  10. redis.pool.testOnReturn=true  
  11. #IP  
  12. redis.ip=10.11.20.140  
  13. #Port  
  14. redis.port=6379  

 

 

 在静态代码段中完成初始化：

 

Java代码  
  1. private static JedisPool pool;  
  2. static {  
  3.     ResourceBundle bundle = ResourceBundle.getBundle("redis");  
  4.     if (bundle == null) {  
  5.         throw new IllegalArgumentException(  
  6.                 "[redis.properties] is not found!");  
  7.     }  
  8.     JedisPoolConfig config = new JedisPoolConfig();  
  9.     config.setMaxActive(Integer.valueOf(bundle  
  10.             .getString("redis.pool.maxActive")));  
  11.     config.setMaxIdle(Integer.valueOf(bundle  
  12.             .getString("redis.pool.maxIdle")));  
  13.     config.setMaxWait(Long.valueOf(bundle.getString("redis.pool.maxWait")));  
  14.     config.setTestOnBorrow(Boolean.valueOf(bundle  
  15.             .getString("redis.pool.testOnBorrow")));  
  16.     config.setTestOnReturn(Boolean.valueOf(bundle  
  17.             .getString("redis.pool.testOnReturn")));  
  18.     pool = new JedisPool(config, bundle.getString("redis.ip"),  
  19.             Integer.valueOf(bundle.getString("redis.port")));  
  20. }  
[java] view plaincopy
 
  1. private static JedisPool pool;  
  2. static {  
  3.     ResourceBundle bundle = ResourceBundle.getBundle("redis");  
  4.     if (bundle == null) {  
  5.         throw new IllegalArgumentException(  
  6.                 "[redis.properties] is not found!");  
  7.     }  
  8.     JedisPoolConfig config = new JedisPoolConfig();  
  9.     config.setMaxActive(Integer.valueOf(bundle  
  10.             .getString("redis.pool.maxActive")));  
  11.     config.setMaxIdle(Integer.valueOf(bundle  
  12.             .getString("redis.pool.maxIdle")));  
  13.     config.setMaxWait(Long.valueOf(bundle.getString("redis.pool.maxWait")));  
  14.     config.setTestOnBorrow(Boolean.valueOf(bundle  
  15.             .getString("redis.pool.testOnBorrow")));  
  16.     config.setTestOnReturn(Boolean.valueOf(bundle  
  17.             .getString("redis.pool.testOnReturn")));  
  18.     pool = new JedisPool(config, bundle.getString("redis.ip"),  
  19.             Integer.valueOf(bundle.getString("redis.port")));  
  20. }  

 

 然后，修改前面那段jedis操作Redis

Java代码  
  1. // 从池中获取一个Jedis对象  
  2. Jedis jedis = pool.getResource();  
  3. String keys = "name";  
  4.   
  5. // 删数据  
  6. jedis.del(keys);  
  7. // 存数据  
  8. jedis.set(keys, "snowolf");  
  9. // 取数据  
  10. String value = jedis.get(keys);  
  11.   
  12. System.out.println(value);  
  13.   
  14. // 释放对象池  
  15. pool.returnResource(jedis);  
[java] view plaincopy
 
  1. // 从池中获取一个Jedis对象  
  2. Jedis jedis = pool.getResource();  
  3. String keys = "name";  
  4.   
  5. // 删数据  
  6. jedis.del(keys);  
  7. // 存数据  
  8. jedis.set(keys, "snowolf");  
  9. // 取数据  
  10. String value = jedis.get(keys);  
  11.   
  12. System.out.println(value);  
  13.   
  14. // 释放对象池  
  15. pool.returnResource(jedis);  

 

 改为从对象池中，获取Jedis实例：

 

Java代码  
  1. // 从池中获取一个Jedis对象  
  2. Jedis jedis = pool.getResource();  
[java] view plaincopy
 
  1. // 从池中获取一个Jedis对象  
  2. Jedis jedis = pool.getResource();  

 

 

 

 切记，最后使用后，释放Jedis对象：

 

Java代码  
  1. // 释放对象池  
  2. pool.returnResource(jedis);  
[java] view plaincopy
 
  1. // 释放对象池  
  2. pool.returnResource(jedis);  

 

 

 

三、一致性哈希

 

Memcached完全基于分布式集群，而Redis是Master-Slave，如果想把Reids，做成集群模式，无外乎多做几套Master-Slave，每套Master-Slave完成各自的容灾处理，通过Client工具，完成一致性哈希。

PS:Memcached是在Server端完成Sharding，Redis只能依靠各个Client做Sharding。可能会在Redis 3.0系列支持Server端Sharding。

 

保留前面的JedisPoolConfig，新增两个Redis的IP（redis1.ip，redis2.ip），完成两个JedisShardInfo实例，并将其丢进List中：

 

Java代码  
  1. JedisShardInfo jedisShardInfo1 = new JedisShardInfo(  
  2.                 bundle.getString("redis1.ip"), Integer.valueOf(bundle                       .getString("redis.port")));  
  3. JedisShardInfo jedisShardInfo2 = new JedisShardInfo(  
  4.                 bundle.getString("redis2.ip"), Integer.valueOf(bundle                       .getString("redis.port")));  
  5.   
  6. List<JedisShardInfo> list = new LinkedList<JedisShardInfo>();  
  7. list.add(jedisShardInfo1);  
  8. list.add(jedisShardInfo2);  
[java] view plaincopy
 
  1. JedisShardInfo jedisShardInfo1 = new JedisShardInfo(  
  2.                 bundle.getString("redis1.ip"), Integer.valueOf(bundle                       .getString("redis.port")));  
  3. JedisShardInfo jedisShardInfo2 = new JedisShardInfo(  
  4.                 bundle.getString("redis2.ip"), Integer.valueOf(bundle                       .getString("redis.port")));  
  5.   
  6. List<JedisShardInfo> list = new LinkedList<JedisShardInfo>();  
  7. list.add(jedisShardInfo1);  
  8. list.add(jedisShardInfo2);  

 

 初始化ShardedJedisPool代替JedisPool：

 

Java代码  
  1. ShardedJedisPool pool = new ShardedJedisPool(config, list);  
[java] view plaincopy
 
  1. ShardedJedisPool pool = new ShardedJedisPool(config, list);  

 

 改由ShardedJedis，获取Jedis对象：

 

Java代码  
  1. // 从池中获取一个Jedis对象  
  2. ShardedJedis jedis = pool.getResource();  
  3. String keys = "name";  
  4. String value = "snowolf";  
  5. // 删数据  
  6. jedis.del(keys);  
  7. // 存数据  
  8. jedis.set(keys, value);  
  9. // 取数据  
  10. String v = jedis.get(keys);  
  11.   
  12. System.out.println(v);  
  13.   
  14. // 释放对象池  
  15. pool.returnResource(jedis);  
[java] view plaincopy
 
  1. // 从池中获取一个Jedis对象  
  2. ShardedJedis jedis = pool.getResource();  
  3. String keys = "name";  
  4. String value = "snowolf";  
  5. // 删数据  
  6. jedis.del(keys);  
  7. // 存数据  
  8. jedis.set(keys, value);  
  9. // 取数据  
  10. String v = jedis.get(keys);  
  11.   
  12. System.out.println(v);  
  13.   
  14. // 释放对象池  
  15. pool.returnResource(jedis);  

 

 

 

 

四、Spring封装参考

 Ok，完成上述代码足够完成简单任务，如果有必要，可以用Spring封装初始化：

 

Xml代码  
  1. <context:property-placeholder location="classpath:redis.properties" />  
  2. <bean  
  3.     id="jedisPoolConfig"  
  4.     class="redis.clients.jedis.JedisPoolConfig"  
  5. >  
  6.     <property  
  7.         name="maxActive"  
  8.         value="${redis.pool.maxActive}" />  
  9.     <property  
  10.         name="maxIdle"  
  11.         value="${redis.pool.maxIdle}" />  
  12.     <property  
  13.         name="maxWait"  
  14.         value="${redis.pool.maxWait}" />  
  15.     <property  
  16.         name="testOnBorrow"  
  17.         value="${redis.pool.testOnBorrow}" />  
  18. </bean>  
  19. <bean  
  20.     id="shardedJedisPool"  
  21.     class="redis.clients.jedis.ShardedJedisPool"  
  22. >  
  23.     <constructor-arg  
  24.         index="0"  
  25.         ref="jedisPoolConfig" />  
  26.     <constructor-arg index="1">  
  27.         <list>  
  28.             <bean class="redis.clients.jedis.JedisShardInfo">  
  29.                 <constructor-arg  
  30.                     index="0"  
  31.                     value="${redis1.ip}" />  
  32.                 <constructor-arg  
  33.                     index="1"  
  34.                     value="${redis.port}"  
  35.                     type="int" />  
  36.             </bean>  
  37.             <bean class="redis.clients.jedis.JedisShardInfo">  
  38.                 <constructor-arg  
  39.                     index="0"  
  40.                     value="${redis2.ip}" />  
  41.                 <constructor-arg  
  42.                     index="1"  
  43.                     value="${redis.port}"  
  44.                     type="int" />  
  45.             </bean>  
  46.         </list>  
  47.     </constructor-arg>  
  48. </bean>  
[xml] view plaincopy
 
  1. <context:property-placeholder location="classpath:redis.properties" />  
  2. <bean  
  3.     id="jedisPoolConfig"  
  4.     class="redis.clients.jedis.JedisPoolConfig"  
  5. >  
  6.     <property  
  7.         name="maxActive"  
  8.         value="${redis.pool.maxActive}" />  
  9.     <property  
  10.         name="maxIdle"  
  11.         value="${redis.pool.maxIdle}" />  
  12.     <property  
  13.         name="maxWait"  
  14.         value="${redis.pool.maxWait}" />  
  15.     <property  
  16.         name="testOnBorrow"  
  17.         value="${redis.pool.testOnBorrow}" />  
  18. </bean>  
  19. <bean  
  20.     id="shardedJedisPool"  
  21.     class="redis.clients.jedis.ShardedJedisPool"  
  22. >  
  23.     <constructor-arg  
  24.         index="0"  
  25.         ref="jedisPoolConfig" />  
  26.     <constructor-arg index="1">  
  27.         <list>  
  28.             <bean class="redis.clients.jedis.JedisShardInfo">  
  29.                 <constructor-arg  
  30.                     index="0"  
  31.                     value="${redis1.ip}" />  
  32.                 <constructor-arg  
  33.                     index="1"  
  34.                     value="${redis.port}"  
  35.                     type="int" />  
  36.             </bean>  
  37.             <bean class="redis.clients.jedis.JedisShardInfo">  
  38.                 <constructor-arg  
  39.                     index="0"  
  40.                     value="${redis2.ip}" />  
  41.                 <constructor-arg  
  42.                     index="1"  
  43.                     value="${redis.port}"  
  44.                     type="int" />  
  45.             </bean>  
  46.         </list>  
  47.     </constructor-arg>  
  48. </bean>  

 

 代码可以更简洁一些：

 

Java代码  
  1. private ApplicationContext app;  
  2. private ShardedJedisPool pool;  
  3.   
  4. @Before  
  5. public void before() throws Exception {  
  6.     app = new ClassPathXmlApplicationContext("applicationContext.xml");  
  7.     pool = (ShardedJedisPool) app.getBean("shardedJedisPool");  
  8. }  
  9.   
  10. @Test  
  11. public void test() {  
  12.   
  13.     // 从池中获取一个Jedis对象  
  14.     ShardedJedis jedis = pool.getResource();  
  15.     String keys = "name";  
  16.     String value = "snowolf";  
  17.     // 删数据  
  18.     jedis.del(keys);  
  19.     // 存数据  
  20.     jedis.set(keys, value);  
  21.     // 取数据  
  22.     String v = jedis.get(keys);  
  23.   
  24.     System.out.println(v);  
  25.   
  26.     // 释放对象池  
  27.     pool.returnResource(jedis);  
  28.   
  29.     assertEquals(value, v);  
  30. }  
[java] view plaincopy
 
  1. private ApplicationContext app;  
  2. private ShardedJedisPool pool;  
  3.   
  4. @Before  
  5. public void before() throws Exception {  
  6.     app = new ClassPathXmlApplicationContext("applicationContext.xml");  
  7.     pool = (ShardedJedisPool) app.getBean("shardedJedisPool");  
  8. }  
  9.   
  10. @Test  
  11. public void test() {  
  12.   
  13.     // 从池中获取一个Jedis对象  
  14.     ShardedJedis jedis = pool.getResource();  
  15.     String keys = "name";  
  16.     String value = "snowolf";  
  17.     // 删数据  
  18.     jedis.del(keys);  
  19.     // 存数据  
  20.     jedis.set(keys, value);  
  21.     // 取数据  
  22.     String v = jedis.get(keys);  
  23.   
  24.     System.out.println(v);  
  25.   
  26.     // 释放对象池  
  27.     pool.returnResource(jedis);  
  28.   
  29.     assertEquals(value, v);  
  30. }  

 

 
当然，Spring提供了对于Redis的专门支持：spring-data-redis，以后有机会再深入研究。

 

相关链接：

Redis实战

Redis实战之Redis + Jedis

Redis实战之征服 Redis + Jedis + Spring （一）

Redis实战之征服 Redis + Jedis + Spring （二）

Redis实战之征服 Redis + Jedis + Spring （三）

 

 

Redis实战之Redis + Jedis[转]

标签：style   blog   http   io   ar   os   使用   sp   java   

原文地址：http://www.cnblogs.com/steven9801/p/4108557.html
踩
(0)
赞
(0)
   
举报
评论 一句话评论（0）
登录后才能评论！
分享档案
更多>
2021年07月29日 (22)
2021年07月28日 (40)
2021年07月27日 (32)
2021年07月26日 (79)
2021年07月23日 (29)
2021年07月22日 (30)
2021年07月21日 (42)
2021年07月20日 (16)
2021年07月19日 (90)
2021年07月16日 (35)
周排行
mamicode.com排行更多图片
更多
友情链接
兰亭集智   国之画   百度统计   站长统计   阿里云   chrome插件   新版天听网
关于我们 - 联系我们 - 留言反馈
© 2014 mamicode.com 版权所有  联系我们:gaon5@hotmail.com
迷上了代码！