前言
由于Http连接是无状态的,所以使用Tomcat做服务器的时候Tomcat内部会维护一个叫做Session的东东用来保存客户端的状态,一般情况下每个客户端都有一个cookie里面保存着叫jsessionid的cookie,每次访问tomcat的时候都会携带上,Tomcat可以根据这个jsessionid找到对应的session。就像你去超市买东西,门口的储物柜可以视作一个session容器,而打出的二维码条就是cookie。
在分布式系统中,对于同一个客户端,访问哪个Tomcat服务器就会在哪个Tomcat里面创建session。简单来说我做一个登录功能,即第一次访问Tomcat的时候需要输入用户名密码,访问成功后就在自己的sesison里面写入用户名,那么我下次访问的时候直接检测session里是否有自己的用户名来判断自己是否处于登录状态了。现在问题来了,如果我第一次访问的是TomcatA,登录成功后由于nginx的负载均衡第二次访问打到了TomcatB上,那么TomcatB里面并没有我的用户名信息,所以我还需要重新登录。一个最直观的想法就是把TomcatA和TomcatB的session抽出来放到某一个位置,这样不管访问TomcatA还是TomcatB都会从同一个Session里面获取用户信息。
SpringBoot以一个非常简洁易用的方式帮我们实现了分布式Session,我们需要做的仅仅是1个注解,几行配置,几行代码。
一、配置maven
<dependencies>
<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>
</dependencies>
二、配置application.yml
spring:
session:
store-type: redis
timeout: 3600s
redis:
flush-mode: on_save
namespace: spring:session
redis:
host: 192.168.99.100
port: 6379
timeout: 5000ms
三、使用
//主类首先开启EnableRedisHttpSession注解
@SpringBootApplication
@EnableRedisHttpSession
public class DistributeSessionApplication {
public static void main(String[] args) {
SpringApplication.run(DistributeSessionApplication.class, args);
}
}
//编写controller,set用于向session添加属性,get用于从session获取属性
package com.example.distributesession.controller;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RestController;
import javax.servlet.http.HttpServletRequest;
import java.util.HashMap;
import java.util.Map;
/**
* @Author: 小混蛋
* @CreateDate: 2018/12/11 17:20
*/
@RestController
public class TestController {
@GetMapping("/set")
public void test(HttpServletRequest request){
request.getSession().setAttribute("message",request.getQueryString());
}
@GetMapping("/get")
public Map<String,Object> two(HttpServletRequest request){
Map<String,Object> map = new HashMap<>();
map.put("sessionId",request.getSession().getId());
map.put("message",request.getSession().getAttribute("message"));
return map;
}
}
四、复制项目
复制项目,设置端口为8081,
访问8080端口的接口/set,添加queryStirng为name='xxx'

然后访问8081端口的接口/get,结果如下

五、原理浅析
本质上利用Tomcat的Filter的实现类SpringSessionRepositoryFilter实现了对每一次请求的拦截,拦截之后把Session放到Redis里面
网友评论