便宜有便宜的办法-小微企业云上的springboot集群方案2：session和redis

在谈到集群方案的时候，第一个会遇到的问题就是session问题，在单机上，session的问题历来都是web容器解决的，咱们主要是用，可是集群意味着多容器。若是负载均衡是随机分配服务器访问的话，很容易形成在A服务器登陆后，下次访问是走的是B服务器，结果B服务器的web容器里面并无该用户的session，结果就悲剧了。那么怎么办呢，固然是redis来处理，redis把session集中存储起来，无论哪台服务器存取session都是走redis，本地服务器不保存session，这个问题就完美的解决了。这个方案落到具体的实现上，首先我想到的就是spring本身的解决方案，spring session。

一、spring session+redis跑起来

spring session+redis的方案很是的简单，你们请按步骤来：

步骤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的存储位置并作相关操做的依赖。

步骤2：把redis的配置写到application.properties里面去

# REDIS
# Redis数据库索引（默认为0）
spring.redis.database=0  
# Redis服务器地址
spring.redis.host=myip
# Redis服务器链接端口
spring.redis.port=6379  
# Redis服务器链接密码（默认为空）
spring.redis.password=password
# 链接池最大链接数（使用负值表示没有限制） 默认 8
spring.redis.lettuce.pool.max-active=8
# 链接池最大阻塞等待时间（使用负值表示没有限制） 默认 -1
spring.redis.lettuce.pool.max-wait=-1
# 链接池中的最大空闲链接 默认 8
spring.redis.lettuce.pool.max-idle=8
# 链接池中的最小空闲链接 默认 0
spring.redis.lettuce.pool.min-idle=0

步骤3：把相关注解加到启动类里面去

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

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

其中@EnableCaching表示开启缓存，由于咱们在application.proerties文件里面配置了redis，因此默认redis就做为项目的缓存；@EnableRedisHttpSession表示redis存储httpsession，后面session就会自动存储到redis里面了。

咱们开一个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的方法很简单，一个存session，一个取session

咱们用redis-cli查看下这个session是否存到了redis：

可见，session自动就存储到了redis。可见，实现session到redis，而后共享，很是的简单。

这一块的源码能够看这里

二、session在redis的存储结构

上面用redis-cli查看session的时候，能够看到的确session存进去了，但这个存储的方式却不是那么明了，能够拿来讲道说道。

2.一、namespace和其余属性

首先是存储的key值，好比上面截图中的，是这么一段：

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

其中spring:session是spring session在redis里面的命名空间，默认就是“spring:session"，在org.springframework.session.data.redis.config.annotation.web.http.RedisHttpSessionConfiguration的源代码里面能够看到：

这个namespace是能够改的，在@EnableRedisHttpSession的源代码里面咱们能够看到，有这么几个参数是能够传进去配置的

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中的数据的过时时间(不是session在redis中的过时时间)
• redisNamespace就是session在spring session在redis里面key的命名空间
• redisFlushMode是redis保存session的方式,默认 ON_SAVE。有两种方式:?IMMEDIATE:一旦建立session的时候就当即保存；ON_SAVE:建立session的时候不会保存,但当往session中添加数据的时候就会保存
• cleanupCron session过时时的数据清扫定时任务，默认的配置时1分钟1次，为何要配置这个，后面会讲。

咱们在@EnableRedisHttpSession配置一个namespace看下效果

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

访问上面的saveSession方法，看下session在redis里面的数据结构：

2.2 session在redis里面的存储结构

上图能够看到命名空间已经修改了。咱们再来看下key后面的value是什么样的

失败了，缘由是session存到redis并非用字符串类型来存，它存储的格式是

用的是hash，咱们用hget来看一下

查不到，缘由是mySession并非完整的field name，完整的是这样的

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

这个就要靠翻源代码了，因而我开始到spring-session-data-redis-XXX.jar里面去找，看到了SpringSessionRedisOperations这个类，这个名字一看就象是把session推到redis的操做类（它自己是个注解，代码里面做者很贴心的告诉咱们具体实现去看哪些）。

在RedisOperationsSessionRepository类里面，我意外的发现了这个

原来sessionAttr:是在这里定义的，我还发现了这个

原来namespace要加上sessions是在这里，但咱们此次翻代码的主要缘由，查看value内容里面的乱字符串却不在这里，在另一个类ReactiveRedisOperationsSessionRepository里面。它实际操做session存储的方法是调用另一个接口类：

这个接口的实现类最终只有两个，仍是继承关系。

看到RedisTemplate总算看到了老朋友，咱们使用redis的时候最经常使用到的工具。看下它操做hash的方法

从参数的名字就能看出来，这个确定通过了序列化（serialization）处理，因此进到RedisSerializationContext里面能够看到这一句

看来，全部session存入redis里面的时候，须要作序列化的处理，而真正字符串前面的那一堆，就是序列化的标记内容。

这一章就讲到这，下一章，咱们还要继续泡在spring session和redis里面，把cleanupCron（还记得在哪里出现过吗）相关的事再唠唠。