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.99.100
    port: 6379
    timeout: 5000ms

主類首先開啟EnableRedisHttpSession注解

//主類首先開啟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;
    }
}

配置集群服務器

配置兩個配置文件分別是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:8081/get
此處聲明下，在實際項目中域名端口號肯定是一致的 ，此時是為了模擬分布式環境測試

總結

本質上利用Tomcat的Filter的實現類SpringSessionRepositoryFilter實現了對每一次請求的攔截，攔截之后把Session放到Redis里面

這篇博文主要是介紹如何利用redis來實現session，當然redis只是一個內存數據庫也可以使用其他的，只是redis是目前社區中最活躍的，springboot也有利用cache整合redis還有如何整合redis的工具類，SpringBoot整合Redis及Redis工具類撰寫