2. 程式人生 > >Redis實戰之Redis + Jedis

Redis實戰之Redis + Jedis

阿新 • • 發佈：2018-12-25

用Memcached，對於快取物件大小有要求，單個物件不得大於1MB，且不支援複雜的資料型別，譬如SET

等。基於這些限制，有必要考慮Redis！

相關連結：

言歸正傳，目前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>

如果只是簡單使用Jedis，以下這麼幾行程式碼足夠：

Java程式碼  
  1. Jedis jedis = new Jedis("10.11.20.140");  
  2. String keys = "name";  
  3. // 刪資料
  4. jedis.del(keys);  
  5. // 存資料
  6. jedis.set(keys, "snowolf");  
  7. // 取資料
  8. String value = jedis.get(keys);  
  9. 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

 在靜態程式碼段中完成初始化：

Java程式碼  
  1. privatestatic JedisPool pool;  
  2. static {  
  3.     ResourceBundle bundle = ResourceBundle.getBundle("redis");  
  4.     if (bundle == null) {  
  5.         thrownew 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. jedis.del(keys);  
  6. // 存資料
  7. jedis.set(keys, "snowolf");  
  8. // 取資料
  9. String value = jedis.get(keys);  
  10. System.out.println(value);  
  11. // 釋放物件池
  12. 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. List<JedisShardInfo> list = new LinkedList<JedisShardInfo>();  
  6. list.add(jedisShardInfo1);  
  7. 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. System.out.println(v);  
  12. // 釋放物件池
  13. 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-placeholderlocation="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-argindex="1">
  27.         <list>
  28.             <beanclass="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.             <beanclass="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. @Before
  4. publicvoid before() throws Exception {  
  5.     app = new ClassPathXmlApplicationContext("applicationContext.xml");  
  6.     pool = (ShardedJedisPool) app.getBean("shardedJedisPool");  
  7. }  
  8. @Test
  9. publicvoid test() {  
  10.     // 從池中獲取一個Jedis物件
  11.     ShardedJedis jedis = pool.getResource();  
  12.     String keys = "name";  
  13.     String value = "snowolf";  
  14.     // 刪資料
  15.     jedis.del(keys);  
  16.     // 存資料
  17.     jedis.set(keys, value);  
  18.     // 取資料
  19.     String v = jedis.get(keys);  
  20.     System.out.println(v);  
  21.     // 釋放物件池
  22.     pool.returnResource(jedis);  
  23.     assertEquals(value, v);  
  24. }  
	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 + Jedis

用Memcached，對於快取物件大小有要求，單個物件不得大於1MB，且不支援複雜的資料型別，譬如SET 等。基於這些限制，有必要考慮Redis！ 相關連結： 言歸正傳，目前Redis大概有3中基於Java語言的Client： JredisJedisRedis4

Redis實戰之Redis命令

　　Redis可以儲存鍵與5種不同資料結構型別之間的對映，這5種資料結構型別分別為string（字串），list（列表），set（集合），hash（雜湊），zset（有序集合），下面將分別對這5種資料型別的控制命令進行總結，熟話說好記性不如爛筆頭，方便以後檢視。 1. 字串命令 　　Redis種的字串有三

Redis實戰之Redis 在 Win7 64bit + VS2013 使用

簡介 Redis是一個高效能的key-value資料庫，所支援的value型別包括string（字串）、list（連結串列）、set（集合）、zset（sorted set，有序集合）和hash（雜

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

不得不說，用雜湊操作來存物件，有點自討苦吃！ 不過，既然吃了苦，也做個記錄，也許以後API升級後，能好用些呢？！ 或許，是我的理解不對，沒有真正的理解雜湊表。 相關連結： 一、預期 接上一篇，擴充User屬性： Java程式碼   publiccla

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

一開始以為Spring下操作雜湊表，列表，真就是那麼土。恍惚間發現“stringRedisTemplate.opsForList()”的強大，抓緊時間惡補下。 通過spring-data-redis完成LINDEX, LLEN, LPOP, LPUSH, LRANGE, L

docker 實戰之redis

edi 實戰 持久化存儲 div redis 端口 aac -s docker 容器 1. 拉取redis鏡像 docker pull 2. 啟動redis docker run -d -p 6379:6379 redis// 開啟持久化存儲 　　運行容器 　　run

Raft協議實戰之Redis Sentinel的選舉Leader原始碼解析

http://www.blogjava.net/jinfeng_wang/archive/2016/12/14/432108.html Raft協議是用來解決分散式系統一致性問題的協議，在很長一段時間，Paxos被認為是解決分散式系統一致性的代名詞。但是Paxos難於

redis實戰之使用redis儲存最近瀏覽的商品資料

注：本文只做教學目的，而在實際的應用場景中，大型的電商網站的訪問量較大，將瀏覽資料儲存於redis中並不可行，望讀者知悉。 關於使用redis儲存最近瀏覽的商品資料，之前沒想到的是，cookie和redis存在本質上的區別。如果使用如本文中所述的方法儲存該資料，所有使用者共

redis實戰之計數訊號量(未完)

計數訊號量是一種鎖，可以讓使用者限制一項資源最多能夠同時被多少個使用者訪問 計數訊號量有如下幾個特徵： 1. 使用前必須要獲取到資源，使用結束後必須要釋放資源 2. 獲取資源失敗後立即將失敗結果返回給使用者 示例： 構建基本的計數訊號量 使用

redis實戰之使用redis儲存session資料

在之前的一篇伺服器由單機轉換為負載均衡時需要做哪些處理博文中提到，在多臺伺服器的情況下，建議使用redis儲存session資料，具體如何實現呢？ 其實實現起來非常簡單，以php為例： 只需要在php.ini檔案中修改相關session配置，如下所示： session.s

Docker實戰之Redis-Cluster叢集

概述 接上一篇Docker實戰之MySQL主從複製, 這裡是Docker實戰系列的第二篇，主要進行Redis-Cluster叢集環境的快速搭建。Redis作為基於鍵值對的NoSQL資料庫，具有高效能、豐富的資料結構、持久化、高可用、分散式等特性，同時Redis本身非常穩定，已經得到業界的廣泛認可和使用。 在R

Redis Persistence 之 redis database

database 子程序 rdb redis persistence 1、關於redis持久化問題，看看官網文檔： 註：redis提供了多種不同方式的持久化選項： RDB（即 redis database）持久化表現在特定的時間間隔內某一個時間點的快照。可以理解為，

redis入門之redis的事務

pre multi 序列 客戶端 exec 原子操作 class logs 全部 Redis 事務可以一次執行多個命令，並且能夠帶有入選兩個保證： 事務是一個單獨的隔離操作：事務中的所有命令都會序列化、按順序地執行。事務在執行的過程中，不會被其他客戶端發送來的命令請求所打

redis二之redis主從配置

轉載：https://www.cnblogs.com/jellyzhang/p/5812015.html       接下來會寫一個redis實戰系列，在此記錄，有什麼問題大家請隨時批評。 　　好了，進入正題，這篇會將redis以windows服務形式提供服務（

Redis系列之——redis.conf配置檔案

#redis.conf # Redis configuration file example. # ./redis-server /path/to/redis.conf ################################## INCLUDES ######

3.redis實戰：redis自動備份與備份管理

redis實戰：redis自動備份與備份管理 使用redis開啟多個服務 在實際的部署中redis需要開啟多個埠來向外提供服務，不僅要設定不同的啟動引數，還需要我們及時做好備份的相關操作，這就需要藉助shell或者python等指令碼來進行管理配置。

Redis實戰總結-Redis的高可用性

在之前的部落格《Redis實戰總結-配置、持久化、複製》給出了一種Redis主從複製機制，簡單地實現了Redis高可用。然後，如果Master伺服器宕機，會導致整個Redis癱瘓，這種方式的高可用性較低。正常會採用多臺Redis伺服器構成一個叢集，即使某臺，或者

【搞定Redis】之 Redis 面試題整理

redis單執行緒問題 單執行緒指的是網路請求模組使用了一個執行緒（所以不需考慮併發安全性），即一個執行緒處理所有網路請求，其他模組仍用了多個執行緒。 為什麼說redis能夠快速執行？ 絕大部分請求是純粹的記憶體操作（非常快速）； 採用單執行緒，避免了不必要的上下文切換和競爭條件

Redis入門之Redis 安裝超詳細文件

    PREFIX=/usr/local/redis    我的安裝目錄即為  /usr/local/redis/bin     3）在原始檔目錄下執行  make && make install      即在 /usr/local/redis/redis-3.0.5 下面執行  make

redis實戰：redis限制某ip的惡意請求

在我們日常開發工作中，經常會遇到介面被惡意請求的情況，應用redis，我們可以很方便的限制某ip一定時間段內對介面的請求次數。 具體實現程式碼如下： 介面檔案：api.php <?php require_once 'redis.php'; $ip = $_SERV