Java操作Redis2種方法代碼詳解

Java操作Redis的方式有下面兩種：

　　一、jedis

　　（1）maven配置

<dependency>
  <groupId>redis.clients</groupId>
  <artifactId>jedis</artifactId>
  <version>2.9.0</version>
</dependency>

　　（2）相關類

單節點：redis.clients.jedis.Jedis

集群：redis.clients.jedis.JedisCluster

　　（3）說明

• 使用的類和api不一樣,導致對redis單節點和集群要特地區別對待。
• 無法集成springCache。
• JedisCluster沒有對象序列化/反序列化 api，需要自己實現。
• jedis2.7版本才正式支持JedisCluster。
  

　　二、spring-data-redis

　　（1）maven配置

<dependency>
  <groupId>org.springframework.data</groupId>
  <artifactId>spring-data-redis</artifactId>
  <version>1.8.4.RELEASE</version>
</dependency>

　　（2）相關類

單節點：org.springframework.data.redis.core.RedisTemplate

集群：org.springframework.data.redis.core.RedisTemplate

　　（3）說明

使用方式統一，如：

redisTemplate.opsForValue().set(key, object);
redisTemplate.opsForHash().put(key, hashKey, object);

可以集成SpringCache。

自帶序列化功能，4種：

• stringRedisSerializer
• JdkSerializationRedisSerializer
• Jackson2JsonRedisSerializer
• OxmSerializer
  

　　（4）SpringCache功能

　　Spring 3.1 引入了基于注解（annotation）的緩存（cache）技術，通過在既有代碼中添加少量它定義的各種annotation，即能夠達到緩存方法的返回對象的效果，支持和主流的專業緩存例如 EHCache，Memcache，Redis等集成,也支持以自行擴展。注解可以標記在一個類上，也可以標記在方法上。

開啟SpringCache功能：@EnableCaching

SpringCache注解：

• @Cacheable --執行方法前,判斷有無緩存，如果有直接從緩存中獲取結果進行返回,否則放入緩存
• @CacheEvict --觸發緩存的清除操作
• @CachePut --每次都會執行該方法，并將執行結果以鍵值對的形式存入指定的緩存中
  

優點：

減少手寫緩存代碼量，通過少量的注釋標簽和配置文件，即可達到使代碼具備緩存的能力。

底層Cache類型更換代碼無需改動，如由EHCache換成Redis。

缺點：

注解無過期時間expire屬性,需自行擴展。

使用限制：基于proxy 的spring aop帶來的內部調用問題，如this內部調用，非public方法調用等。

放入緩存方法只使用connection.set，即緩存存入Redis都是String字符串類型。

　　（5）Tomcat插件RedisSessionManager

　　分布式系統要將HttpSession放入Redis共享，代碼又不想改動的話，那么可以通過RedisSessionManager來集成，可以引入第三方插件RedisSessionManager和相關jar，在tomcat下配置即可。

配置

引入插件:

\Tomcat7\conf\context.xml下配置
<Valve className="com.r.tomcat.session.management.RequestSessionHandlerValve"/>
<Manager className="com.r.tomcat.session.management.RequestSessionManager"/>

\Tomcat7\conf\RedisDataCache.properties配置
redis.hosts=127.0.0.1:6379, 127.0.0.2:6379, 127.0.0.2:6380, ....
redis.password=
redis.cluster.enabled=true

優點

　　session的代碼寫法不用動，依然使用傳統寫法session.setAttribute(key,value)；引入插件后session由本地tomcat存儲改為了Redis，重啟tomcat也不用擔心session消失。

缺點

　　只能用于tomcat。

　　（6）SpringSession

　　這個技術重寫了HttpSession，以SpringSession來做，Spring Session提供了集群Session（Clustered Sessions）功能， 默認采用外置的Redis來存儲Session數據，以此來解決Session共享的問題。

配置

maven:
  <dependency> 
   <groupId>org.springframework.session</groupId> 
    <artifactId>spring-session-data-redis</artifactId> 
  </dependency>
開啟Reids鍵空間通知功能:
  notify-keyspace-events AKE

開啟Redis存儲springSession:
  @EnableRedisHttpSession(maxInactiveIntervalInSeconds=1800)

優點

• 和web服務器無關，甚至可以不用web服務器，也能支持session，是一種獨立于應用服務器的方案。
• 配合spring-data-redis.jar使用，能夠支持Redis單節點、Sentinel、Redis3.x集群等。
• HttpSession代碼無需做任何改動，依然使用傳統寫法session.setAttribute(key,value)。
• SpringSession最新版本支持HttpSessionListener。
  

缺點

依賴Spring。

Spring版本要是4.1.6以上，servlet要是3.0.1以上，這樣對JDK(1.6+)和web服務器(tomcat7+)版本有限制。

　　（7）SpringSession使用session監聽器

　　SpringSession最新版本支持HttpSessionListener，該監聽器可以捕捉到session創建和銷毀，內部采用Redis的Sub/Pub+鍵空間通知功能實現。

監聽器類

@EnableRedisHttpSession(maxInactiveIntervalInSeconds=1800)
public class RedisHttpSessionConfig {
  /**
   * 注入監聽器
   */
  @Bean
  public SessionEventHttpSessionListenerAdapter listenerAdapter() {
    List<HttpSessionListener> listenerList = new ArrayList<>();
    listenerList.add(new SessionListener()); // 注入自己的SessionListener類
    return new SessionEventHttpSessionListenerAdapter(listenerList);    
  }
}

說明

HttpSessionListener不推薦在RedisCluster下使用：因sessionDestoryed采取的是Redis鍵空間通知功能，鍵空間通知功能是在Redis2.8開始新推出的，但在RedisCluster下鍵空間通知功能有bug，event觸發時不會publish通知到所有節點，只對本節點的master/slave通知，故使用redisCluster的環境下，有可能會訂閱收不到sessionDestroyed消息，故不推薦在RedisCluster下使用HttpSessionListener。需要自己去實現SUBSCRIBE各個Redis節點捕捉sessionDestoryed功能。

重復監聽：當一個session銷毀時，那么我們的listener的sessionDestroyed方法、所有微服務實例都會收到事件通知。會導致重復，故需要注意這點，需要應用自行控制重復問題。

以上就是本文的全部內容，希望對大家的學習有所幫助，也希望大家多多支持億速云。