Springboot实现分布式Session

前言

现在随着分布式，微服务架构的日益成熟，越来越多的企业将传统的单体服务改造成微服务或者分布式架构。当然不是说单体服务现在是百无一用，只能说没有最好的，只要适合就好。

在分布式服务改造中，大家都遇到过一个问题，那就是分布式session管理。之前的单体服务session是保存在容器的内存中的。微服务架构中一个服务为了实现高可用都是至少3个点部署，这样就遇到一个问题，就是这个部署在不同服务器上的三个点如何实现共享session呢？

其实解决方案是很多的，原理也是差不多的。比如说我们现在项目就是将session保存在数据库中，这样三个点都去读取数据库来实现session共享。还有的方案就是大家比较熟悉的将session存储在redis中，而且redis支持key设置过期时间，这个和用户会话的过期就不谋而合了。只不过传统的集成方案需要我们手动的将session存储在redis中，然后再在redis中读取，这种方式操作起来可能比较重复繁琐。

所以spring已经在spring全家桶中提供了分布式session共享集成方案，就是标题中所说的springsession。这里基于springboot来搭建个入门demo，以便大家快速了解springsession，它其实就是把你本来需要手动存储redis的操作给做了，让开发者不需要自己手动去存储session

配置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.xx.xx
    port: 6379
    timeout: 5000ms

开启`@EnableRedisHttpSession`注解

//主类首先开启EnableRedisHttpSession注解
@SpringBootApplication
@EnableRedisHttpSession
public class DistributeSessionApplication {

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

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;

@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;
    }
}

配置集群服务器

配置两个配置文件分别是dev和pro，服务器端口分别设置为8081和8082,

java -jar name.jar   --spring.profiles.active=dev
java -jar name.jar   --spring.profiles.active=pro

测试

一台服务器访问：http://localhost:8081/set
另外一台服务器访问：http://localhost:8082/get
此处声明下，在实际项目中域名端口号肯定是一致的，此时是为了模拟分布式环境测试

总结

本质上利用Tomcat的Filter的实现类SpringSessionRepositoryFilter实现了对每一次请求的拦截，拦截之后把Session放到Redis里面

这篇博文主要是介绍如何利用redis来实现session，当然redis只是一个内存数据库也可以使用其他的，只是redis是目前社区中最活跃的，springboot也有利用cache整合redis还有如何整合redis的工具类