碼上歡樂
相關內容    簡體    繁體

Redis實戰之Redis + Jedis

本文轉載自   查看原文   2013-08-03 22:21   16025 

用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！

 

一、簡單使用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>  
<dependency>
	<groupId>redis.clients</groupId>
	<artifactId>jedis</artifactId>
	<version>2.1.0</version>
	<type>jar</type>
	<scope>compile</scope>
</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);  
		Jedis jedis = new Jedis("10.11.20.140");
		String keys = "name";

		// 刪數據
		jedis.del(keys);
		// 存數據
		jedis.set(keys, "snowolf");
		// 取數據
		String value = jedis.get(keys);

		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  
#最大分配的對象數
redis.pool.maxActive=1024
#最大能夠保持idel狀態的對象數
redis.pool.maxIdle=200
#當池內沒有返回對象時，最大等待時間
redis.pool.maxWait=1000
#當調用borrow Object方法時，是否進行有效性檢查
redis.pool.testOnBorrow=true
#當調用return Object方法時，是否進行有效性檢查
redis.pool.testOnReturn=true
#IP
redis.ip=10.11.20.140
#Port
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. }  
	private static JedisPool pool;
	static {
		ResourceBundle bundle = ResourceBundle.getBundle("redis");
		if (bundle == null) {
			throw new IllegalArgumentException(
					"[redis.properties] is not found!");
		}
		JedisPoolConfig config = new JedisPoolConfig();
		config.setMaxActive(Integer.valueOf(bundle
				.getString("redis.pool.maxActive")));
		config.setMaxIdle(Integer.valueOf(bundle
				.getString("redis.pool.maxIdle")));
		config.setMaxWait(Long.valueOf(bundle.getString("redis.pool.maxWait")));
		config.setTestOnBorrow(Boolean.valueOf(bundle
				.getString("redis.pool.testOnBorrow")));
		config.setTestOnReturn(Boolean.valueOf(bundle
				.getString("redis.pool.testOnReturn")));
		pool = new JedisPool(config, bundle.getString("redis.ip"),
				Integer.valueOf(bundle.getString("redis.port")));
	}

 

 然后，修改前面那段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);  
		// 從池中獲取一個Jedis對象
		Jedis jedis = pool.getResource();
		String keys = "name";

		// 刪數據
		jedis.del(keys);
		// 存數據
		jedis.set(keys, "snowolf");
		// 取數據
		String value = jedis.get(keys);

		System.out.println(value);

		// 釋放對象池
		pool.returnResource(jedis);

 

 改為從對象池中，獲取Jedis實例：

 

Java代碼  
  1. // 從池中獲取一個Jedis對象  
  2. Jedis jedis = pool.getResource();  
// 從池中獲取一個Jedis對象
Jedis jedis = pool.getResource();

 

 

 

 切記，最后使用后，釋放Jedis對象：

 

Java代碼  
  1. // 釋放對象池  
  2. pool.returnResource(jedis);  
// 釋放對象池
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);  
JedisShardInfo jedisShardInfo1 = new JedisShardInfo(
				bundle.getString("redis1.ip"), Integer.valueOf(bundle						.getString("redis.port")));
JedisShardInfo jedisShardInfo2 = new JedisShardInfo(
				bundle.getString("redis2.ip"), Integer.valueOf(bundle						.getString("redis.port")));

List<JedisShardInfo> list = new LinkedList<JedisShardInfo>();
list.add(jedisShardInfo1);
list.add(jedisShardInfo2);

 

 初始化ShardedJedisPool代替JedisPool：

 

Java代碼  
  1. ShardedJedisPool pool = new ShardedJedisPool(config, list);  
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);  
		// 從池中獲取一個Jedis對象
		ShardedJedis jedis = pool.getResource();
		String keys = "name";
		String value = "snowolf";
		// 刪數據
		jedis.del(keys);
		// 存數據
		jedis.set(keys, value);
		// 取數據
		String v = jedis.get(keys);

		System.out.println(v);

		// 釋放對象池
		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>  
	<context:property-placeholder location="classpath:redis.properties" />
	<bean
		id="jedisPoolConfig"
		class="redis.clients.jedis.JedisPoolConfig"
	>
		<property
			name="maxActive"
			value="${redis.pool.maxActive}" />
		<property
			name="maxIdle"
			value="${redis.pool.maxIdle}" />
		<property
			name="maxWait"
			value="${redis.pool.maxWait}" />
		<property
			name="testOnBorrow"
			value="${redis.pool.testOnBorrow}" />
	</bean>
	<bean
		id="shardedJedisPool"
		class="redis.clients.jedis.ShardedJedisPool"
	>
		<constructor-arg
			index="0"
			ref="jedisPoolConfig" />
		<constructor-arg index="1">
			<list>
				<bean class="redis.clients.jedis.JedisShardInfo">
					<constructor-arg
						index="0"
						value="${redis1.ip}" />
					<constructor-arg
						index="1"
						value="${redis.port}"
						type="int" />
				</bean>
				<bean class="redis.clients.jedis.JedisShardInfo">
					<constructor-arg
						index="0"
						value="${redis2.ip}" />
					<constructor-arg
						index="1"
						value="${redis.port}"
						type="int" />
				</bean>
			</list>
		</constructor-arg>
	</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. }  
	private ApplicationContext app;
	private ShardedJedisPool pool;

	@Before
	public void before() throws Exception {
		app = new ClassPathXmlApplicationContext("applicationContext.xml");
		pool = (ShardedJedisPool) app.getBean("shardedJedisPool");
	}

	@Test
	public void test() {

		// 從池中獲取一個Jedis對象
		ShardedJedis jedis = pool.getResource();
		String keys = "name";
		String value = "snowolf";
		// 刪數據
		jedis.del(keys);
		// 存數據
		jedis.set(keys, value);
		// 取數據
		String v = jedis.get(keys);

		System.out.println(v);

		// 釋放對象池
		pool.returnResource(jedis);

		assertEquals(value, v);
	}

 

 
當然，Spring提供了對於Redis的專門支持：spring-data-redis，以后有機會再深入研究。

 

相關鏈接：

Redis實戰

Redis實戰之Redis + Jedis

Redis實戰之征服 Redis + Jedis + Spring （一）

Redis實戰之征服 Redis + Jedis + Spring （二）

Redis實戰之征服 Redis + Jedis + Spring （三）

 

 


免責聲明！

本站轉載的文章為個人學習借鑒使用，本站對版權不負任何法律責任。如果侵犯了您的隱私權益，請聯系本站郵箱yoyou2525@163.com刪除。



猜您在找 Redis實戰之征服 Redis + Jedis + Spring （一） Redis（二）：Jedis操作Redis Redis實戰--使用Jedis實現百萬數據秒級插入 Redis實戰--Jedis實現分布式鎖 【Redis】使用Jedis操作Redis 使用Jedis操作Redis 使用Jedis操作redis 使用Jedis操作redis Jedis操作Redis 使用jedis連接redis
 
粵ICP備18138465號   © 2018-2025 CODEPRJ.COM