pringboot集群之如何看待session和redis

這篇文章將為大家詳細(xì)講解有關(guān)pringboot集群之如何看待session和redis，文章內(nèi)容質(zhì)量較高，因此小編分享給大家做個(gè)參考，希望大家閱讀完這篇文章后對(duì)相關(guān)知識(shí)有一定的了解。

在談到集群方案的時(shí)候，第一個(gè)會(huì)遇到的問題就是session問題，在單機(jī)上，session的問題從來都是web容器解決的，我們主要是用，但是集群意味著多容器。如果負(fù)載均衡是隨機(jī)分配服務(wù)器訪問的話，很容易造成在A服務(wù)器登錄后，下次訪問是走的是B服務(wù)器，結(jié)果B服務(wù)器的web容器里面并沒有該用戶的session，結(jié)果就悲劇了。那么怎么辦呢，當(dāng)然是redis來處理，redis把session集中存儲(chǔ)起來，不管哪臺(tái)服務(wù)器存取session都是走redis，本地服務(wù)器不保存session，這個(gè)問題就完美的解決了。這個(gè)方案落到具體的實(shí)現(xiàn)上，首先我想到的就是spring自己的解決方案，spring session。

1、spring session+redis跑起來

spring session+redis的方案非常的簡(jiǎn)單，大家請(qǐng)按步驟來：

步驟1：pom文件加starter

        <dependency>
			<groupId>org.springframework.boot</groupId>
			<artifactId>spring-boot-starter-data-redis</artifactId>
		</dependency>
        <dependency>
			<groupId>org.springframework.boot</groupId>
			<artifactId>spring-boot-starter-web</artifactId>
		</dependency>
		<dependency>
			<groupId>org.springframework.session</groupId>
			<artifactId>spring-session-data-redis</artifactId>
		</dependency>

spring-boot-starter-web是引入web依賴，spring-boot-starter-data-redis是redis的存取，spring-session-data-redis就是把redis作為session的存儲(chǔ)位置并做相關(guān)操作的依賴。

步驟2：把redis的配置寫到application.properties里面去

# REDIS
# Redis數(shù)據(jù)庫索引（默認(rèn)為0）
spring.redis.database=0  
# Redis服務(wù)器地址
spring.redis.host=myip
# Redis服務(wù)器連接端口
spring.redis.port=6379  
# Redis服務(wù)器連接密碼（默認(rèn)為空）
spring.redis.password=password
# 連接池最大連接數(shù)（使用負(fù)值表示沒有限制） 默認(rèn) 8
spring.redis.lettuce.pool.max-active=8
# 連接池最大阻塞等待時(shí)間（使用負(fù)值表示沒有限制） 默認(rèn) -1
spring.redis.lettuce.pool.max-wait=-1
# 連接池中的最大空閑連接 默認(rèn) 8
spring.redis.lettuce.pool.max-idle=8
# 連接池中的最小空閑連接 默認(rèn) 0
spring.redis.lettuce.pool.min-idle=0

步驟3：把相關(guān)注解加到啟動(dòng)類里面去

@SpringBootApplication
@EnableCaching
@EnableRedisHttpSession(maxInactiveIntervalInSeconds = 86400*30)
public class RedisApplication {

	public static void main(String[] args) {
		SpringApplication.run(RedisApplication.class, args);
	}
}

其中@EnableCaching表示開啟緩存，因?yàn)槲覀冊(cè)赼pplication.proerties文件里面配置了redis，所以默認(rèn)redis就作為項(xiàng)目的緩存；@EnableRedisHttpSession表示redis存儲(chǔ)httpsession，后面session就會(huì)自動(dòng)存儲(chǔ)到redis里面了。

我們開一個(gè)controller，試一下是不是這樣：

@RestController
public class IndexController {
  
    @RequestMapping("/saveSession")
    String saveSession(HttpSession session) {
        session.setAttribute("mySession", "lalala");
        return session.getId();
    }
    
    @RequestMapping("/getSession")
    String getSession(HttpSession session) {
        String mySessionString = session.getAttribute("mySession").toString();
        return mySessionString;
    }

saveSession和getSession的方法很簡(jiǎn)單，一個(gè)存session，一個(gè)取session

我們用redis-cli查看下這個(gè)session是否存到了redis：

可見，session自動(dòng)就存儲(chǔ)到了redis。可見，實(shí)現(xiàn)session到redis，然后共享，非常的簡(jiǎn)單。

這一塊的源碼可以看這里

2、session在redis的存儲(chǔ)結(jié)構(gòu)

上面用redis-cli查看session的時(shí)候，可以看到的確session存進(jìn)去了，但這個(gè)存儲(chǔ)的方式卻不是那么明了，可以拿來說道說道。

2.1、namespace和其他屬性

首先是存儲(chǔ)的key值，比如上面截圖中的，是這么一段：

spring:session:sessions:54abb3f7-909a-46c8-ab4c-1b515eff69b1

其中spring:session是spring session在redis里面的命名空間，默認(rèn)就是“spring:session"，在org.springframework.session.data.redis.config.annotation.web.http.RedisHttpSessionConfiguration的源代碼里面可以看到：

這個(gè)namespace是可以改的，在@EnableRedisHttpSession的源代碼里面我們可以看到，有這么幾個(gè)參數(shù)是可以傳進(jìn)去配置的

public @interface EnableRedisHttpSession {

	/**
	 * The session timeout in seconds. By default, it is set to 1800 seconds (30 minutes).
	 * This should be a non-negative integer.
	 * @return the seconds a session can be inactive before expiring
	 */
	int maxInactiveIntervalInSeconds() default MapSession.DEFAULT_MAX_INACTIVE_INTERVAL_SECONDS;

	/**
	 * Defines a unique namespace for keys. The value is used to isolate sessions by
	 * changing the prefix from default {@code spring:session:} to
	 * {@code <redisNamespace>:}.
	 * <p>
	 * For example, if you had an application named "Application A" that needed to keep
	 * the sessions isolated from "Application B" you could set two different values for
	 * the applications and they could function within the same Redis instance.
	 * @return the unique namespace for keys
	 */
	String redisNamespace() default RedisOperationsSessionRepository.DEFAULT_NAMESPACE;

	/**
	 * Flush mode for the Redis sessions. The default is {@code ON_SAVE} which only
	 * updates the backing Redis when {@link SessionRepository#save(Session)} is invoked.
	 * In a web environment this happens just before the HTTP response is committed.
	 * <p>
	 * Setting the value to {@code IMMEDIATE} will ensure that the any updates to the
	 * Session are immediately written to the Redis instance.
	 * @return the {@link RedisFlushMode} to use
	 * @since 1.1
	 */
	RedisFlushMode redisFlushMode() default RedisFlushMode.ON_SAVE;

	/**
	 * The cron expression for expired session cleanup job. By default runs every minute.
	 * @return the session cleanup cron expression
	 * @since 2.0.0
	 */
	String cleanupCron() default RedisHttpSessionConfiguration.DEFAULT_CLEANUP_CRON;

}

• maxInactiveIntervalInSeconds是session中的數(shù)據(jù)的過期時(shí)間(不是session在redis中的過期時(shí)間)

• redisNamespace就是session在spring session在redis里面key的命名空間

• redisFlushMode是redis保存session的方式,默認(rèn) ON_SAVE。有兩種方式:?IMMEDIATE:一旦創(chuàng)建session的時(shí)候就立即保存；ON_SAVE:創(chuàng)建session的時(shí)候不會(huì)保存,但當(dāng)往session中添加數(shù)據(jù)的時(shí)候就會(huì)保存

• cleanupCron session過期時(shí)的數(shù)據(jù)清掃定時(shí)任務(wù)，默認(rèn)的配置時(shí)1分鐘1次，為什么要配置這個(gè)，后面會(huì)講。

我們?cè)贎EnableRedisHttpSession配置一個(gè)namespace看下效果

@EnableRedisHttpSession(maxInactiveIntervalInSeconds = 86400*30,redisNamespace = "wphmoon:session")
public class RedisApplication {
......
}

訪問上面的saveSession方法，看下session在redis里面的數(shù)據(jù)結(jié)構(gòu)：

2.2 session在redis里面的存儲(chǔ)結(jié)構(gòu)

上圖可以看到命名空間已經(jīng)修改了。我們?cè)賮砜聪耴ey后面的value是什么樣的

失敗了，原因是session存到redis并不是用字符串類型來存，它存儲(chǔ)的格式是

用的是hash，我們用hget來看一下

查不到，原因是mySession并不是完整的field name，完整的是這樣的

看到熟悉的lalala就知道這次終于查到了，完整的fieldName要在我們命名的Attribute前面加上sessionAttr。但是在lalala前面的”\xac\xed\x00\x05t\x00\x06“又是什么鬼？

這個(gè)就要靠翻源代碼了，于是我開始到spring-session-data-redis-XXX.jar里面去找，看到了SpringSessionRedisOperations這個(gè)類，這個(gè)名字一看就象是把session推到redis的操作類（它本身是個(gè)注解，代碼里面作者很貼心的告訴我們具體實(shí)現(xiàn)去看哪些）。

在RedisOperationsSessionRepository類里面，我意外的發(fā)現(xiàn)了這個(gè)

原來sessionAttr:是在這里定義的，我還發(fā)現(xiàn)了這個(gè)

原來namespace要加上sessions是在這里，但我們這次翻代碼的主要原因，查看value內(nèi)容里面的亂字符串卻不在這里，在另外一個(gè)類ReactiveRedisOperationsSessionRepository里面。它實(shí)際操作session存儲(chǔ)的方法是調(diào)用另外一個(gè)接口類：

這個(gè)接口的實(shí)現(xiàn)類最終只有兩個(gè)，還是繼承關(guān)系。

看到RedisTemplate總算看到了老朋友，我們使用redis的時(shí)候最常用到的工具?？聪滤僮鱤ash的方法

從參數(shù)的名字就能看出來，這個(gè)肯定經(jīng)過了序列化（serialization）處理，所以進(jìn)到RedisSerializationContext里面可以看到這一句

看來，所有session存入redis里面的時(shí)候，需要做序列化的處理，而真正字符串前面的那一堆，就是序列化的標(biāo)記內(nèi)容。

關(guān)于pringboot集群之如何看待session和redis就分享到這里了，希望以上內(nèi)容可以對(duì)大家有一定的幫助，可以學(xué)到更多知識(shí)。如果覺得文章不錯(cuò)，可以把它分享出去讓更多的人看到。