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