1. 程式人生 > 程式設計 >Java操作Redis2種方法程式碼詳解

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方法、所有微服務例項都會收到事件通知。會導致重複,故需要注意這點,需要應用自行控制重複問題。

以上就是本文的全部內容,希望對大家的學習有所幫助,也希望大家多多支援我們。